上一篇講解了如何在ABP中使用Redis Cache，雖然能夠正常的訪問Redis，但是Redis裡的資訊無法同步更新。本文將講解如何實現Redis Cache與實體同步更新。要實現資料的同步更新，我們能夠想到的最基本、最簡單、也是複雜的方法：在每一個增、刪、改的方法裡新增同步快取的程式碼，說它最簡單，是因為技術實現非常簡單，就是在每一個方法裡多加一句程式碼；說它複雜，是因為這樣的寫的話，會出現很多重複的程式碼，並且容易出現遺漏，維護起來很不方便。那麼有沒有一種更簡單的方式呢，在資料出現變化後，觸發一個事件，主動通知訂閱者執行相關操作呢？答案是肯定的，我們可以通過註冊領域事件來實現，在ABP中，實體增加、刪除、修改後會觸發相關事件，只要註冊就可以了。要註冊事件，有兩種方式可以實現，第一是自動註冊，實現IEventHandler就可以了，ABP會自動註冊；第二是通過IEventBus的Register方法手動註冊。ABP中推薦使用自動註冊的方式實現，本文也會採用第一種方式實現。下面我們就來看具體的實現方式，首先增加一個處理快取同步的介面ICacheSyncService，程式碼如下（本文的程式碼是在上一篇的基礎之上編寫的）：

ICacheSyncService.cs

 public interface ICacheSyncService
    {
        void Add<TEntity>(TEntity entity) where TEntity : class, IEntity<int>;
        
 
void Remove<TEntity>(int id) where TEntity : class, IEntity<int>;
        void Update<TEntity>(TEntity entity) where TEntity : class, IEntity<int>;
    }

CacheSyncService.cs

public class CacheSyncService : ICacheSyncService, ISingletonDependency
    {
        
 
public ICacheService CacheService { get; set; }

        public void Add<TEntity>(TEntity entity) where TEntity : class, IEntity<int>
        {
            CacheService.Set(entity.Id, entity);
        }

        public void Remove<TEntity>(int id) where TEntity : class, IEntity<int>
        {
            CacheService.Remove<int, TEntity>(id);
        }

        public void Update<TEntity>(TEntity entity) where TEntity : class, IEntity<int>
        {
            CacheService.Set(entity.Id, entity);
        }
    }

第二增加一個處理實體事件的泛型基類EntityChangedHandlerBase<TEntity>，程式碼如下：

public abstract class EntityChangedHandlerBase<TEntity>:
        ISingletonDependency,
        IEventHandler<EntityCreatedEventData<TEntity>>,
        IEventHandler<EntityDeletedEventData<TEntity>>,
        IEventHandler<EntityUpdatedEventData<TEntity>>
        where TEntity : class, IEntity<int>
    {
        public ICacheSyncService CacheSyncService { get; set; }

        public virtual void HandleEvent(EntityCreatedEventData<TEntity> eventData)
        {
            CacheSyncService.Add(eventData.Entity);
        }

        public virtual void HandleEvent(EntityDeletedEventData<TEntity> eventData)
        {
            CacheSyncService.Remove<TEntity>(eventData.Entity.Id);
        }

        public virtual void HandleEvent(EntityUpdatedEventData<TEntity> eventData)
        {
            CacheSyncService.Update(eventData.Entity);
        }
    }

第三，增加一個需要進行快取同步的實體類，繼承自EntityChangedHandlerBase<TEntity>就可以了，不需要編寫任何程式碼，如果有特殊情況，可以重新HandleEvent方法，程式碼如下:

public class ArticleChangedHandler : EntityChangedHandlerBase<Article>
    {
        
    }

至此，快取同步的全部程式碼已編寫完成，我們執行來看看效果：

我們新增文章後，什麼操作也不做，直接到Redis裡檢視是否有新增的資料，如果有新增的資料表示快取能夠自動更新了（刪除和修改是一樣的，這裡就不編寫相關程式碼了），直接看單元測試程式碼。

public class CacheSync_Tests : UsingRedisInAbpTestBase
    {
         [Fact]
        public void Test_Entity_Changed_Event()
        {
             LoginAsHostAdmin();
             var title = "unit_test";
             var articleId = 0;
             var service = Resolve<TestCacheSyncService>();
             service.IsCreatedEventFired.ShouldBeFalse();
             service.IsUpdatedEventFired.ShouldBeFalse();
             service.IsDeletedEventFired.ShouldBeFalse();
             
             //新增文章測試
             UsingDbContext(c =>c.Articles.Add(new Article {Title = title}));
             
             service.IsCreatedEventFired.ShouldBe(true);

             //更新文章測試
             UsingDbContext(c =>
             {
                 var article=c.Articles.First();
                 c.Articles.Attach(article);
                 article.Title = "new_title";
             });
             service.IsUpdatedEventFired.ShouldBe(true);

             //刪除文章測試
             UsingDbContext(c =>
             {
                 var article = c.Articles.First();
                 c.Articles.Remove(article);                 
             });
             service.IsDeletedEventFired.ShouldBe(true);
        }
    }

TestSyncCache.cs程式碼:

 public class TestCacheSyncService : ICacheSyncService
    {
        public bool IsCreatedEventFired { get; set; }
        public bool IsDeletedEventFired { get; set; }
        public bool IsUpdatedEventFired { get; set; }
        public void Add<TEntity>(TEntity entity) where TEntity : class, IEntity<int>
        {
            IsCreatedEventFired = true;
            
        }

        public void Remove<TEntity>(int id) where TEntity : class, IEntity<int>
        {
            IsDeletedEventFired = true;

        }

        public void Update<TEntity>(TEntity entity) where TEntity : class, IEntity<int>
        {
            IsUpdatedEventFired = true;
        }
    }  

通過以上方式已實現了ABP中Redis快取的讀取和設定，也實現了快取的同步更新，如果要在ABP中使用其他快取也是一樣的，只需要把快取實現部分換成其他快取就行。本文的所有原始碼下載地址：