src/Test/UnitTest.StackExchangeRedis/CsRedis.cs

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

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

using CSRedis;
using Microsoft.VisualStudio.TestTools.UnitTesting;
using NetPro.CsRedis;
using System;
using System.Collections.Generic;
using System.Threading.Tasks;

namespace UnitTest.StackExchangeRedis
{
    [TestClass]
    public class CsRedis
    {
        IRedisManager _redisDatabase;

        [TestInitialize]
        public void Init()
        {
            List<string> csredisConns = new List<string>();
            string password = ""; //netpro
            int defaultDb = 0;
            string ssl = "";
            string keyPrefix = "";
            int writeBuffer = 10240;
            int poolsize = 20;
            int timeout = 10;
            csredisConns.Add($"172.16.127.229:6379,password={password},defaultDatabase={defaultDb},poolsize={poolsize},ssl={ssl},writeBuffer={writeBuffer},prefix={keyPrefix},preheat={1},idleTimeout={timeout},testcluster={true}");

            CSRedis.CSRedisClient csredis;

            try
            {
                csredis = new CSRedis.CSRedisClient(null, csredisConns.ToArray());
            }
            catch (Exception ex)
            {
                throw new ArgumentException($"请检查是否为非密码模式,Password必须为空字符串;请检查Database是否为0,只能在非集群模式下才可配置Database大于0；{ex}");
            }

            //RedisHelper.Initialization(csredis);
            IdleBus<CSRedisClient> idleBus = new IdleBus<CSRedisClient>(TimeSpan.FromSeconds(10));
            idleBus.Register("", () => csredis);

            _redisDatabase = new CsRedisManager(new RedisCacheOption
            {

            }, new NetPro.CsRedis.SystemTextJsonSerializer(), idleBus);
        }
        [TestMethod]
        public void SetAndExists()
        {
            string key = "6";
            var result = _redisDatabase.Set(key, "呼吁", TimeSpan.FromSeconds(60));
            //var result = RedisHelper.Set(key, "呼吁", TimeSpan.FromSeconds(60));
            var isExists = _redisDatabase.Exists(key);
            Assert.AreEqual(true, result);
        }

        [TestMethod]
        public void Exists()
        {