RMS.Common/Tools/RedisDb.cs

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

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

using ServiceStack.Redis;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;

namespace RMS.Common
{
    public class RedisDb
    {
        //private static string[] aliReadWriteHosts = new[] {
        //        // "redis://Hewenlong123@123.56.72.214:6379"/*redis://密码@访问地址:端口*/
        //         //  "Hewenlong123@r-2ze693f636ed49f4.redis.rds.aliyuncs.com:6379",
        //           "Hewenlong123@47.93.38.132:6379"
        //         };
        //PooledRedisClientManager redisPoolManager = new PooledRedisClientManager(4500/*连接池个数*/, 5/*连接池超时时间(秒)*/, aliReadWriteHosts);
        private static string[] aliReadWriteHosts = new string[] { };
        static PooledRedisClientManager redisPoolManager;
        public RedisDb()
        {
            string redisHosts = ConfigHelper.GetAppValue("RedisHosts");
            var arry = redisHosts.Split(' ');
            aliReadWriteHosts = (from t in arry where !string.IsNullOrWhiteSpace(t) select t).ToArray();
            if (redisPoolManager == null)
            {
                redisPoolManager = new PooledRedisClientManager(500/*连接池个数*/, 10/*连接池超时时间(秒)*/, aliReadWriteHosts);
            }
        }


        #region 写入List<T>泛型集合,默认DB0
        /// <summary>  
        /// 写入List<T>泛型类  
        /// </summary>  
        /// <typeparam name="T">泛型</typeparam>  
        /// <param name="keys">键</param>  
        /// <param name="value">泛型集合</param>  
        /// <param name="dt">到期时间</param>  
        /// <param name="db">其他数据盘</param> 
        /// <returns>bool 是否成功</returns>
        public bool Set<T>(string keys, List<T> value, DBNum dbnum = DBNum.LoginUser)
            where T : class
        {
            using (var redisClient = CreatClient(dbnum))
            {
                return redisClient.Set<List<T>>(keys, value);
            }
        }
        public bool Set<T>(string keys, List<T> value, TimeSpan ts, DBNum dbnum = DBNum.LoginUser)
            where T : class
        {
            using (var redisClient = CreatClient(dbnum))
            {
                return redisClient.Set<List<T>>(keys, value, ts);
            }
        }
        #endregion