【轮子狂魔】手把手教你自造Redis Client

为什么做Redis Client？

Redis Client顾名思义，redis的客户端，主要是封装了一些对于Redis的操作。

而目前用的比较广泛的 ServiceStack.Redis 不学好，居然开始收费了。

作为轮子狂魔，是可忍孰不可忍啊。于是我决定自己造轮子了。

Redis通信协议

先给个Redis官方的通信协议地址：http://redisdoc.com/topic/protocol.html

关键是我截图的部分，我们可以得到以下几个信息：

1.tcp协议

2.默认端口6379

3.命令以 结尾

实现Redis交互（Get、Set）

Set命令说明：http://redisdoc.com/string/set.html

Get命令说明：http://redisdoc.com/string/get.html

C#的Tcp交互选用TcpClient

实现Set指令

 代码意图大概说一下：

1.创建TcpClient

2.连接Redis （127.0.0.1:6379）

3.发送指令 set test csharp （注意 是一开始通信协议就提到的，命令以 结尾）

4.使用UTF8来编码和解码

5.接收返回信息

PS：get指令类似，我就不贴出来了

            var tcpClient = new System.Net.Sockets.TcpClient();

            tcpClient.Connect("127.0.0.1", 6379);

            string setCommand = "set test csharp
";
            tcpClient.Client.Send(Encoding.UTF8.GetBytes(setCommand));
            System.Diagnostics.Trace.Write(setCommand);
            byte[] buffer = new byte[256];
            tcpClient.Client.Receive(buffer);
            System.Diagnostics.Trace.Write(Encoding.UTF8.GetString(buffer).Replace("", ""));    

想象中的调用方式

 1.第一行有个关键思维是单例模式，即我希望全局只有一个Redis Client。（多个的话可以直接用RedisClient）

 2.RedisClient的连接地址可自由指定

 3. 从单例中取出Client就可以简单粗暴的上ta。client.Set(key,value)

            var client = RedisSingleton.GetInstance.Client = new Client.RedisClient("127.0.0.1", 6379);
            client.Set("test", "Framework.Redis");
            var value = client.Get("test");
            Trace.Write("client get:" + value);

重构一个RedisManager和RedisClient

RedisManager 其实就是个简单的单例模式，封装了一个全局唯一的对象而已。如果不想全局唯一，直接用RedisClient就可以了。

    public class RedisSingleton
    {
        #region 单例

        private static RedisSingleton _redisSingleton = null;
        private static object _locker = new object();

        public static RedisSingleton GetInstance
        {
            get
            {
                if (_redisSingleton == null)
                {
                    lock (_locker)
                    {
                        if (_redisSingleton == null)
                        {
                            _redisSingleton = new RedisSingleton();
                        }
                    }
                }

                return _redisSingleton;
            }
        }

        #endregion

        public RedisClient Client { get; set; }
    }

RedisClient 是真正的与Redis交互的代码（因为这只是个简单粗暴的Demo，所以代码不太美观，见谅！之后会继续完善我的这个自造的Redis）

    public class RedisClient
    {
        private TcpClient _tcpClient = null;

        public RedisClient(string serverIP, int serverPort)
        {
            _tcpClient = new TcpClient();
            _tcpClient.Connect(serverIP, serverPort);
        }

        public void Set(string key, string value)
        {
            string setCommand = "set " + key + " " + value + "
";
            _tcpClient.Client.Send(Encoding.UTF8.GetBytes(setCommand));
            Logger.Info(setCommand);
            var result = GetRaw();
            if (result != "+OK")
            {
                throw new Exception("redis error:" + result);
            }
        }

        public string Get(string key)
        {
            string setCommand = "get " + key + "
";
            _tcpClient.Client.Send(Encoding.UTF8.GetBytes(setCommand));
            Logger.Info(setCommand);
            string value = GetRaw();
            Logger.Info("get " + key + " value:" + value);
            return value.Split(new string[] { "
" }, StringSplitOptions.None)[1];
        }

        private string GetRaw()
        {
            byte[] buffer = new byte[256];
            _tcpClient.Client.Receive(buffer);
            string value = Encoding.UTF8.GetString(buffer).Replace("", "").TrimEnd("
".ToCharArray());
            return value;
        }
    }

最后是大家喜欢的广告环节

全部代码就这么多我就不分享我的oschina上的项目地址了，因为目前正在做一个开源的mvc项目需要使用Redis，所以自己造了这么个轮子。

如果你有兴趣加入我们，请加群：7424099

哦，不好意思，补上有图有真相