IT工程師數位筆記本

        /// <summary>
        /// 創建鏈接池管理對象
        /// </summary>
        private static void CreateManager()
        {
            //redis寫服務器集群
            string[] writeServerList = ConfigManager.Config.Redis.WriteServerList.Split(new char[] { ',' }, StringSplitOptions.RemoveEmptyEntries);
            //redis讀服務器集群
            string[] readServerList = ConfigManager.Config.Redis.ReadServerList.Split(new char[] { ',' }, StringSplitOptions.RemoveEmptyEntries);
            RedisClientManagerConfig s = new RedisClientManagerConfig();
            s.MaxWritePoolSize = ConfigManager.Config.Redis.MaxWritePoolSize;
            s.MaxReadPoolSize = ConfigManager.Config.Redis.MaxReadPoolSize;
            s.AutoStart = ConfigManager.Config.Redis.AutoStart;
            prcm = new PooledRedisClientManager(writeServerList, readServerList, s);
        }

    /// <summary>
    /// redis隊列管理者,簡單的隊列添加內容，以及實時消費等功能，與Lind.DDD.CachingQueue不同它將會連接到本地的redis服務器 ， 
    /// 默認6379端口,多個連接通過逗號分割 。 其他選項在名稱的后面包含了一個 “= ”。 例如
    /// var conn = ConnectionMultiplexer.Connect("redis0:6380,redis1:6380,allowAdmin=true");
    /// </summary>
    public class RedisQueueManager
    {
        /// <summary>
        /// redis連接對象
        /// </summary>
        static ConnectionMultiplexer conn = ConnectionMultiplexer.Connect(ConfigConstants.ConfigManager.Config.Redis.Host);
        /// <summary>
        /// 緩存數據庫
        /// </summary>
        static IDatabase cache = conn.GetDatabase();

ConfigurationOptions config = new ConfigurationOptions
{
EndPoints =
{
{ "redis0", 6379 },
{ "redis1", 6380 }
},
CommandMap = CommandMap.Create(new HashSet<string>
{ 
"INFO", "CONFIG", "CLUSTER",
"PING", "ECHO", "CLIENT"
}, available: false),
KeepAlive = 180,
DefaultVersion = new Version(2, 8, 8),
Password = "changeme"
};

redis0:6379,redis1:6380,keepAlive=180,version=2.8.8,$CLIENT=,$CLUSTER=,$CONFIG=,$ECHO=,$INFO=,$PING=