項目架構開發：數據訪問層之Cache

數據訪問層簡單介紹

數據訪問層，提供整個項目的數據訪問與持久化功能。在分層系統中所有有關數據訪問、檢索、持久化的任務，最終都將在這一層完成。

來看一個比較經典的數據訪問層結構圖

大概可以看出如下信息

1、有緩存、日志、異常處理、數據CRUD、查詢及數據事務等功能

2、無縫對接如EF、ADO.NET、NH、Dapper等數據訪問技術

3、對外只開放接口層，隱藏具體實現，這樣就可以解耦業務層與數據訪問層

 

今天斗膽通過一個簡單實例來實踐一下，如有不妥的地方，歡迎指正

創建接口層，定義可以提供的一些服務接口

 

這里我們一個有5種服務接口，方法的功能就不介紹了，應該都能看懂

緩存接口：ICache.cs

    public interface ICache<T> where T : class
    {
        IEnumerable<T> Gets(string key);
        T Get(string key);
        bool Sets(string key, IEnumerable<T> value, TimeSpan expiresIn);
        bool Set(string key, T value, TimeSpan expiresIn);
        bool Remove(string key);
    }

 

緩存服務的實現

因為可能支持多種緩存，所以我實現了Web緩存與Redis緩存，這2中緩存分別在項目初期和后期集群中可能會用到

 

我們來看HttpRuntimeCache.cs （還有一種Web緩存HttpContext.Cache，不夠這種只能在Web應用使用，所以一般不推薦）

public class HttpRuntimeCache<T> : ICache<T> where T : class
    {
        public HttpRuntimeCache()
        {

        }

        public T Get(string key)
        {
            if (System.Web.HttpRuntime.Cache[key] == null)
            {
                return default(T);
            }

            return System.Web.HttpRuntime.Cache[key] as T;
        }

        public bool Set(string key, T value, TimeSpan expiresIn)
        {
            Set(key, value, expiresIn.Seconds);
            return true;
        }

        public bool Remove(string key)
        {
            System.Web.HttpRuntime.Cache.Remove(key);
            return true;
        }

        private void Set(string key, object value, int absoluteSeconds)
        {
            System.Web.HttpRuntime.Cache.Insert(key, value, null, DateTime.Now.AddSeconds(absoluteSeconds), TimeSpan.FromSeconds(0));
        }
    }

 

現在緩存功能已經實現了；大家應該很容易想到怎麼使用了，比如在業務層這樣使用

ICache<User>  cache = new HttpRuntimeCache<User>();
var user = cache.Get("key");

 

其實這樣是不對的，因為這樣的話接口ICache相當於沒什么用處，沒有起到應有的作用（隔離具體實現）

如果要換另一種緩存實現（比如redis），那還要在所有使用了 new HttpRuntimeCache<User>() 的地方改正過來

這樣的耦合要去掉；有2種方式，通過IOC在實例化的時候依賴注入；另一種就是新建一個基礎設施層，業務層依賴於這一層

因為業務層肯定是需要調用一些Utilities、Helper等類型的工具類，這個應該是躲不掉的，再怎么接口隔離也去除不了這點

 

基礎設施層的實現

 

Cache.cs 

    public sealed class Cache<T> where T : class
    {
        private readonly static ICache<T> cacheProvider;

        static Cache()
        {
            cacheProvider = ProviderHelper<T>.GetCacheProvider();
        }

        public static IEnumerable<T> Gets(string key)
        {
            return cacheProvider.Gets(key);
        }

        public static T Get(string key)
        {
            return cacheProvider.Get(key);
        }

        public static bool Sets(string key, IEnumerable<T> value, TimeSpan expiresIn)
        {
            return cacheProvider.Sets(key, value, expiresIn);
        }

        public static bool Set(string key, T value, TimeSpan expiresIn)
        {
            return cacheProvider.Set(key, value, expiresIn);
        }

        public static bool Remove(string key)
        {
            return cacheProvider.Remove(key);
        }
    }

 

 ProviderHelper.cs 實現如下圖

 

至此，緩存功能實現完畢，我們新建一個測試項目看看結果

    [TestClass]
    public class CacheTest
    {
        [TestMethod]
        public void Set()
        {
            var user = new LoginUser()
            {
                Id = Guid.NewGuid(), 
                LoginName = "LoginName",
                IsEnabled = 1,
                Password = "mima1987",
                CreateTime = DateTime.Now
            };

            Cache<LoginUser>.Set("UnitTest3.TestMethod1", user, TimeSpan.FromSeconds(10));
            var user2 = Cache<LoginUser>.Get("UnitTest3.TestMethod1");

            Assert.AreEqual(user.Id, user2.Id);
        }
    }

 

看來沒有什么問題。

 

項目架構開發系列

• 項目架構開發：數據訪問層之Cache
• 項目架構開發：數據訪問層之Logger
• 項目架構開發：數據訪問層之Repository
• 項目架構開發：數據訪問層之Query
• 項目架構開發：數據訪問層之UnitOfWork