Yi.Framework.Net6/Yi.Framework.Core/Cache/RedisCacheClient.cs

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

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

using Microsoft.Extensions.Options;
using System;
using System.Collections;
using System.Collections.Generic;
using System.Diagnostics;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.IO;
using Yi.Framework.Common.IOCOptions;
using CSRedis;
using static CSRedis.CSRedisClient;

namespace Yi.Framework.Core.Cache
{
    public class RedisCacheClient : CacheInvoker
    {
        private readonly RedisConnOptions _RedisOptions;

        private CSRedisClient _client;

        public RedisCacheClient(IOptionsMonitor<RedisConnOptions> redisConnOptions)
        {
            this._RedisOptions = redisConnOptions.CurrentValue;
            _client = new CSRedisClient($"{_RedisOptions.Host}:{_RedisOptions.Prot},password={_RedisOptions.Password},defaultDatabase ={ _RedisOptions.DB }");
        }
        public override bool Exits(string key)
        {
            return _client.Exists(key);
        }
        public override T Get<T>(string key)
        {
            return _client.Get<T>(key);
        }

        public override bool Set<T>(string key, T data, TimeSpan time)
        {
            return _client.Set(key, data, time);
        }

        public override bool Set<T>(string key, T data)
        {
            return _client.Set(key, data);
        }

        public override long Del(string key)
        {
            return _client.Del(key);
        }

        public override bool HSet(string key, string fieId, object data)
        {
            return _client.HSet(key, fieId, data);
        }

        public override bool HSet(string key, string fieId, object data, TimeSpan time)
        {
            var res = _client.HSet(key, fieId, data);
            var res2 = _client.Expire(key, time);
            return res && res2;