ShiQuan.Redis/RedisClient.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

using ShiQuan.Logger;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Net.Sockets;
using System.Text;

namespace ShiQuan.Redis
{
    /// <summary>
    /// redis允许客户端以TCP方式连接，默认6379端口。传输数据都以\r\n结尾。
    /// </summary>
    public class RedisClient : IDisposable
    {
        /// <summary>
        /// 请求头部格式， *<number of arguments>\r\n
        /// </summary>
        public const string Header = "*{0}\r\n";
        /// <summary>
        /// 参数信息$<number of bytes of argument N>\r\n<argument data>\r\n
        /// </summary>
        public const string Bulk = "${0}\r\n{1}\r\n";

        //通信socket
        private Socket _Socket;

        public string IP { get; private set; }

        public int Port { get; private set; }

        private bool _NoDelay = false;
        /// <summary>
        /// Socket 是否正在使用 Nagle 算法。
        /// </summary>
        public bool NoDelay {
            get { return this._NoDelay; }
            set { this._NoDelay = value; }
        }

        public RedisClient(string ip,int port=6379)
        {
            this.IP = ip;
            this.Port = port;
        }
        /// <summary>
        /// 连接
        /// </summary>
        /// <returns></returns>
        public bool Connect(bool connection = false)
        {
            /*2020-05-24 侯连文 是否重新建立连接*/
            if(connection == false)
            {
                if (_Socket != null && _Socket.Connected)
                    return true;
            }
            _Socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)
            {
                NoDelay = this.NoDelay
            };