利用Spring.Net技術打造可切換的分布式緩存讀寫類

利用Spring.Net技術打造可切換的Memcached分布式緩存讀寫類

Memcached是一個高性能的分布式內存對象緩存系統，因為工作在內存，讀寫速率比數據庫高的不是一般的多，和Radis一樣具有高效的讀寫和分布式的優勢，上一篇博文《Memcached在Windows下的配置和使用》已經對介紹過它在windows上的配置和使用。

新建ICacheWriter類--CacheWriter的接口，以達到通過配置文件可以切換緩存讀寫方式，例如，緩存讀寫也可以通過httpruntime.cache來進行。

代碼如下：

public interface ICacheWriter
{
        void Set(string key, object value, DateTime exp);
        void Set(string key, object value);
        object Get(string key);
}

在配置文件中的appSettings節點下添加memcached服務器地址。例如：

<add key="memcachedServer" value="127.0.0.1:11211" />

新建MemcachedWriter類，代碼如下：

        //單例模式
        private static readonly MemcachedClient client;
        static MemcachedWriter()
        {           

            string[] servers = ConfigurationManager.AppSettings["memcachedServer"].Split(new char[] { ',' }, StringSplitOptions.RemoveEmptyEntries);

            //初始化socket池
            SockIOPool pool = SockIOPool.GetInstance();
            pool.SetServers(servers);
            pool.InitConnections = 1;
            pool.MinConnections = 1;
            pool.MaxConnections = 3;
            pool.SocketConnectTimeout = 1000;//socket連接超時，閑置多少毫秒后銷毀socket
            pool.SocketTimeout = 3000;
            pool.MaintenanceSleep = 30;//維護線程休息時間
            pool.Failover = true;//失效轉移(一種備份操作模式)    
            pool.Nagle = false;//是否用nagle算法啟動socket 
            pool.Initialize();//應用設置並初始化socket池

            //創建memcached客戶端
            client = new MemcachedClient();
            client.EnableCompression = false;//是否進行壓縮

        }
        public void Set(string key, object value, DateTime exp)
        {
            client.Set(key, value, exp);
        }

        public void Set(string key, object value)
        {
            client.Set(key, value);
        }

        public object Get(string key)
        {
            return client.Get(key);
        }        

這樣就可以通過配置來添加和修改服務器。

有了接口類和實現類，下一步我們就要利用Spring.Net實現它的工廠。

新建CacheHelper類，代碼如下：

　　 public class CacheHelper
    {
        public static ICacheWriter CacheWriter { get; set; }

        static CacheHelper() 
        { 
            //如果是靜態的屬性，想讓它有注入的值，就必須先創建一個實例后，才能注入
            //靜態方法調用的時候，不需要Spring容器創建實例，所以屬性CacheWriter沒有注入實例
            //在類的靜態構造函數中強制讓Spring容器為我們創建一個屬性的實例，因為屬性是靜態的，所以只需要創建一次即可

            IApplicationContext ctx = ContextRegistry.GetContext();
            ctx.GetObject("CacheHelper");

        }
        public static void WriteCache(string key,object value,DateTime exp)
        {
            CacheWriter.Set(key, value, exp);
        }
        public static void WriteCache(string key, object value)
        {
            CacheWriter.Set(key, value);
        }

        public static object GetCache(string key)
        {
            return CacheWriter.Get(key);
        }
    }

public static ICacheWriter CacheWriter { get; set; }

這個屬性就是Spring.Net的注入點。

需要注意的是，因為Spring.Net只會在類有了第一個實例后才會進行注入，而靜態方法內只能調用靜態字段，靜態方法和靜態字段是在程序開始運行時就已經創建好了，此時CacheHelper還沒有第一個實例，所以靜態字段CacheWriter沒有被注入，需要手動實例化CacheHelper，讓CacheWriter被注入。

在配置文件的Spring節點中添加關於CacheHelper和CacheWriter的配置信息：

<objects xmlns="http://www.springframework.net">
  <!--CacheHelper中的CacheWriter的注入，CacheWriter是單例的-->
  <object name="CacheHelper" type="MyOA_Common.CacheHelper, MyOA_Common"  singleton="false">
    <property name="CacheWriter" ref="MemcachedWriter" />
  </object>
  <object name="MemcachedWriter" type="MyOA_Common.MemcachedWriter, MyOA_Common"  singleton="true">
    
  </object>
</objects>

如果我們想使用httpruntime.cache而不想用Memcached進行緩存讀寫，只需要修改

<object name="MemcachedWriter" type="MyOA_Common.MemcachedWriter, MyOA_Common"  singleton="true">

使用Spring.Net和接口增強了我們程序的靈活性。

好了，我們在控制器上測試一下代碼：

    public class TestController : Controller
    {
        // GET: /Test/
        public ActionResult Test()
        {
            CacheHelper.CacheWriter.Set("test", "測試成功");
            return View();
        }

        [HttpPost]
        public ActionResult Test(FormCollection form)
        {
            string value = (string)CacheHelper.CacheWriter.Get("test");
            return Content(value);
        }

    }

網頁上顯示“測試成功”，即分布式緩存完成！

本文目的是與各位園友交流和分享經驗，如果您發現本文中有什么錯誤或者您有什么更好的建議，歡迎您提出！如果您對文中描述的東西有不了解的地方也可以回復或者查看我的其他博文。