实现一个基于WCF的分布式缓存系统

时间：2014-08-14 20:23:09 阅读：250 评论：0 收藏：0 [点我收藏+]

标签：style blog http color 使用 os io for

前言：

用到分布式的东西很多了，一直想做一个简单的分布式小项目练练手学习下。后来决定来一个简单的分布式缓存的系统。

在企业应用开发中缓存的用例不胜枚举，但是每次更多的是单机的部署与使用，没有对应的需求是一个原因，另一个原因总是好高骛远做过的总是不想再进行修正。

这次的分布式就从最简单的分布式缓存开始。说简单是因为没有实现分布式缓存高深的寻址，或者对备份处理的牛X实现。只是实现了“分布”这个目的，不足之处还请大家指导。

分布的实现方式有哪些？

既然做“分布”，当然要看看主流的“分布”实现方式。小弟简单的在网上搜罗了一下，常见的方式有两种（或者说是最简单的）：

交由客户端分布；
交由服务端分布；

针对于第一种，最显而易见的是MM的实现，如：

string[] serverlist = { "10.0.0.131:11211", "10.0.0.132:11211" };
 MemcachedClient mc = new MemcachedClient();
 mc.Set("test", "my value");

这3行代码是我们再使用MM时候常用的，可以把值放在指定的集群上。

针对于第二种，交由服务端又可以分为两种实现：

主目标服务器维护着一个Cache集群，每当主Server接收到一个缓存请求时，则通知集群机器进行缓存。
第二种类似于上一条的实现，只不过是交由一个后台线程去做通知工作。

两种很类似，但是要想达到最优的效果应该需要一个强有力的算法去支撑了。

制定策略

既然分析了这两种实现的方式，个人更喜欢第二种中的第一种，起码在角色上更加的清晰。

bubuko.com,布布扣

虽然图画的有点惨，但是大致说明了问题，就是Client通知ServerHost缓存，ServerHost帮助分布式，当Client请求缓存值时，Serverhost则呼叫离Client最近的Host返回cache值。

但是考虑到万一ServerHost挂掉了，真个系统是不是就瘫痪了，于是修改方案：

bubuko.com,布布扣

也就没有了ServerHost每一个Host都起到了ServerHost的功效。

代码实现：

每个Host是一个控制台作为Wcf的host,当然最好的情况应该是使用WindowsServer：

class Program
    {
        static void Main(string[] args)
        {
            ServiceHost host = new ServiceHost(typeof(DistributedCache.Services.NetCacheService));
            try
            {
                host.Open();
                Console.WriteLine("NetCacheService Service Started");
                Console.ReadKey();
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.Message);
                if (ex.InnerException != null)
                {
                    Console.WriteLine("\n" + ex.InnerException.Message);
                }
            }
            finally
            {
                host.Close();
            }
            Console.ReadKey();
        }
    }

在CacheService上提供的简单API：

    [ServiceContract]
    public interface INetCacheService
    {
        [OperationContract]
        String AppendCache(String key, Object value);

        [OperationContract]
        String RemoveCache(String key);

        [OperationContract]
        String ClearCache();

        [OperationContract]
        Object GetCache(String key);
    }

每一个Client对应着自己的Host：

        static void Main(string[] args)
        {
            DistributedCacheService.INetCacheService service = new DistributedCacheService.NetCacheServiceClient();
            string value = "test string";
            service.AppendCache("zhazha", value);
            System.Console.WriteLine("set ‘zhazha‘ value : [{0}] to {1} succeed!", value, "172.16.15.121");
            System.Console.Read();
        }

为了达到动态管理分布Server的目的：

首先两个IP的集群：

  <appSettings>
    <add key="hostIP" value="172.16.15.121:9876,172.16.15.205:9876"/>
  </appSettings>

缓存集群的同步：

                HttpRuntime.Cache.Insert(key, value, null, DateTime.UtcNow.AddMinutes(EXPIRETIME), TimeSpan.Zero);
                System.Console.WriteLine("{0} ： localhost write cache succeed!", DateTime.Now.ToString());

                string[] hostIP = ChannelFactory.GetHost();
                object obj = null;
                CacheService02.INetCacheService service = null;
                for (int i = 0; i < hostIP.Length; i++)
                {
                    service = ChannelFactory.CreateWCFServiceByURI<CacheService02.INetCacheService>(hostIP[i]);
                    obj = service.GetCache(key);
                    if (null == obj)
                    {
                        service.AppendCache(key, value);
                        System.Console.WriteLine("{0} ： {1} write cache succeed!", DateTime.Now.ToString(), hostIP[i]);
                    }
                }

                System.Console.WriteLine("{0} ： write cache succeed!", DateTime.Now.ToString());
                return "Success";