回到目錄

之前寫了不少關于倉儲的文章，所以，自己習慣把自己叫倉儲大叔，上次寫的XMLRepository得到了大家的好評，也有不少朋友給我發email，進行一些知識的探討，今天主要來實現一個RedisRepository，它始終是集成IRepository接口的，我這里的Redis倉儲主要服務為復雜類型的業務，對于只存string這種需求，不需要使用它。

對于Redis倉儲和說，它與XML倉儲有些不同，由于ＸＭＬ文件一般存儲在ＷＷＷ服務器，所以沒有網絡通訊問題，而redis一般部署在第三臺服務器上，我們一般稱為NoSQL服務器，它與ＷＷＷ通訊是通過socket協議完成的，正是如些，我們在進行倉儲設計時，應該考慮到如何去釋放它的資源，因為這種資源是非托管的，所以需要人為干預一下，.net提供了using關鍵字來做這事，而每個動作寫using這顯然是不友好的，所以，我這個redis倉儲是在析構方法里完成對資源的銷毀的，請看源代碼：

首先是redis基類，它是實現統一操作的前提

　 /// <summary>/// Redis實體基類，所有redis實體類都應該集成它/// </summary>public abstract class RedisEntity{public RedisEntity(){RootID = Guid.NewGuid().ToString();}/// <summary>/// Redis實體主鍵，方法查詢，刪除，更新等操作/// </summary>public virtual string RootID { get; set; }}

下面才是RedisRepository倉儲的代碼

/// <summary>/// Redis倉儲實現/// </summary>public class RedisRepository<TEntity> :IDisposable,IRepository<TEntity>where TEntity : RedisEntity{IRedisClient redisDB;IRedisTypedClient<TEntity> redisTypedClient;IRedisList<TEntity> table;public RedisRepository(){redisDB = RedisManager.GetClient();redisTypedClient = redisDB.GetTypedClient<TEntity>();table = redisTypedClient.Lists[typeof(TEntity).Name];}#region IRepository<TEntity>成員public void SetDbContext(IUnitOfWork unitOfWork){throw new NotImplementedException();}public void Insert(TEntity item){if (item != null){
redisTypedClient.AddItemToList(table, item);
? redisDB.Save();
}
}public void Delete(TEntity item){? if (item != null)
??????????? {
??????????????? var entity = Find(item.RootID);
??????????????? redisTypedClient.RemoveItemFromList(table, entity);
??????????????? redisDB.Save();
??????????? }}public void Update(TEntity item){if (item != null){var old = Find(item.RootID);if (old != null){redisTypedClient.RemoveItemFromList(table, old);redisTypedClient.AddItemToList(table, item);
redisDB.Save();}}}public IQueryable<TEntity> GetModel(){return table.GetAll().AsQueryable();}public TEntity Find(params object[] id){return table.Where(i => i.RootID == (string)id[0]).FirstOrDefault();}#endregion#region IDisposable成員public void Dispose(){this.ExplicitDispose();}#endregion#region Protected Methods/// <summary>/// Provides the facility that disposes the object in an explicit manner,/// preventing the Finalizer from being called after the object has been/// disposed explicitly./// </summary>protected void ExplicitDispose(){this.Dispose(true);GC.SuppressFinalize(this);}protected void Dispose(bool disposing){if (disposing)//清除非托管資源 {table = null;redisTypedClient = null;redisDB.Dispose();}}#endregion#region Finalization Constructs/// <summary>/// Finalizes the object./// </summary>~RedisRepository(){this.Dispose(false);}#endregion} }

下面是在控制臺中進行倉儲的調用

　　　　　　IRepository<Car> repository = new Redis.Data.Core.RedisRepository<Car>();repository.Insert(new Car { ID = 3, Name = "占" });var entity = repository.GetModel().Where(i => i.ID == 3).FirstOrDefault();entity.Name = "修改了";repository.Update(entity);repository.GetModel().ToList().ForEach(e =>{Console.WriteLine(e.ID + "/" + e.RootID + "/" + e.Name);});

下面是實現的結果的截圖

回到目錄

總結

以上是生活随笔為你收集整理的Redis学习笔记~是时候为Redis实现一个仓储了，RedisRepository来了的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。