ZhiYeJianKang_PeiXun/cyqdata-master/DistributedCache/CacheImplement/MemRedis/ClientBase.cs

using System;
using System.Collections.Generic;
using System.Text;
using CYQ.Data.Json;
using CYQ.Data.Table;
using CYQ.Data.Tool;

namespace CYQ.Data.Cache
{
    internal abstract partial class ClientBase
    {
        protected HostServer hostServer;
        /// <summary>
        /// 主机服务
        /// </summary>
        public HostServer HostServer { get { return hostServer; } set { hostServer = value; } }
        /// <summary>
        /// 指定数据长度超过值时进行压缩，默认128K
        /// </summary>
        protected uint compressionThreshold = 1024 * 128; //128kb


        /// <summary>
        /// Private key hashing method that uses the modified FNV hash.
        /// </summary>
        /// <param name="key">The key to hash.</param>
        /// <returns>The hashed key.</returns>
        protected uint hash(string key)
        {
            checkKey(key);
            return HashCreator.CreateCode(key);
        }

        /// <summary>
        /// Private key-checking method.
        /// Throws an exception if the key does not conform to memcached protocol requirements:
        /// It may not contain whitespace, it may not be null or empty, and it may not be longer than 250 characters.
        /// </summary>
        /// <param name="key">The key to check.</param>
        protected void checkKey(string key)
        {
            if (string.IsNullOrEmpty(key))
            {
                throw new ArgumentNullException("Key may not be empty.");
            }
            if (key.Length > 250)
            {
                throw new ArgumentException("Key may not be longer than 250 characters.");
            }
            foreach (char c in key)
            {
                if (c <= 32)
                {
                    throw new ArgumentException("Key may not contain whitespace or control characters.");
                }
            }
        }

        //Private Unix-time converter
        private static DateTime epoch = new DateTime(1970, 1, 1, 0, 0, 0, DateTimeKind.Utc);
        protected static int getUnixTime(DateTime datetime)
        {
            return (int)(datetime.ToUniversalTime() - epoch).TotalSeconds;
        }

        #region Status
        public string WorkInfo
        {
            get
            {
                var status = GetAllHostNodeStatus();//这里会重置OK和Dead数量。
                JsonHelper js = new JsonHelper(false, false);
                js.Add("OK", OkServer.ToString());
                js.Add("Dead", ErrorServer.ToString());
                js.Add("Servers", JsonHelper.ToJson(status));
                return js.ToString();
            }
        }

        //private MDataTable WorkTable
        //{
        //    get
        //    {
        //        MDataTable cacheTable = new MDataTable();

        //        #region Create Table
        //        Dictionary<string, Dictionary<string, string>> status = GetAllHostNodeStatus();
        //        if (status != null)
        //        {
        //            foreach (KeyValuePair<string, Dictionary<string, string>> item in status)
        //            {
        //                if (item.Value.Count > 0)
        //                {
        //                    MDataTable dt = MDataTable.CreateFrom(item.Value);
        //                    if (cacheTable.Columns.Count == 0)//第一次
        //                    {
        //                        cacheTable = dt;
        //                    }
        //                    else
        //                    {
        //                        cacheTable.JoinOnName = "Key";
        //                        cacheTable = cacheTable.Join(dt, "Value");
        //                    }
        //                    cacheTable.Columns["Value"].ColumnName = item.Key;
        //                }
        //            }
        //        }
        //        cacheTable.TableName = "WorkTable";
        //        #endregion

        //        return cacheTable;
        //    }
        //}

        private int OkServer = 0, ErrorServer = 0;
        /// <summary>
        /// 获取主机节点的基础信息
        /// </summary>
        private Dictionary<string, Dictionary<string, string>> GetAllHostNodeStatus()
        {
            OkServer = 0;
            ErrorServer = 0;
            Dictionary<string, Dictionary<string, string>> results = new Dictionary<string, Dictionary<string, string>>();
            foreach (KeyValuePair<string, HostNode> item in hostServer.HostList)
            {
                Dictionary<string, string> result = GetInfoByHost(item.Value, false);
                results.Add(item.Key, result);
            }
            return results;
        }
        private Dictionary<string, string> GetInfoByHost(HostNode host, bool isBackup)
        {
            Dictionary<string, string> result = new Dictionary<string, string>();
            if (!host.IsEndPointDead)
            {
                if (!isBackup) OkServer++;
                result.Add("Status", "OK");
                result.Add("Acquired sockets", host.Acquired.ToString());
                result.Add("Acquired timeout from socket pool", host.TimeoutFromSocketPool.ToString());
                result.Add("New sockets created", host.NewSockets.ToString());
                result.Add("New sockets failed", host.FailedNewSockets.ToString());
                result.Add("Sockets in pool", host.Poolsize.ToString());
                result.Add("Sockets reused", host.ReusedSockets.ToString());
                result.Add("Sockets died in pool", host.DeadSocketsInPool.ToString());
                result.Add("Sockets died on return", host.DeadSocketsOnReturn.ToString());
                result.Add("Sockets close", host.CloseSockets.ToString());
            }
            else
            {
                if (!isBackup) ErrorServer++;
                result.Add("Status", "Dead , next retry at : " + host.DeadEndPointRetryTime);
                result.Add("Error", host.Error);
                //if (host.HostNodeBak != null)
                //{
                //    result.Add("Backup - " + host.HostNodeBak.Host, JsonHelper.ToJson(GetInfoByHost(host.HostNodeBak, true)));
                //}
            }

            return result;
        }
        #endregion
    }
}