src/Library/NetPro.CsRedis/CsRedisManager.cs

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

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

using CSRedis;
using Microsoft.Extensions.Caching.Memory;
using Microsoft.Extensions.Logging;
using Microsoft.Extensions.Logging.Abstractions;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;

namespace NetPro.CsRedis
{
    /// <summary>
    /// 
    /// </summary>
    public class CsRedisManager : IRedisManager
    {
        private readonly RedisCacheOption _option;
        private readonly ISerializer _serializer;
        private IMemoryCache _memorycache;
        private ILogger _logger;
        private readonly IdleBus<CSRedisClient> _cSRedisClient;

        /// <summary>
        /// 
        /// </summary>
        /// <param name="option"></param>
        /// <param name="serializer"></param>
        /// <param name="cSRedisClient"></param>
        /// <param name="memorycache"></param>
        /// <param name="logger"></param>
        public CsRedisManager(RedisCacheOption option,
            ISerializer serializer
            , IdleBus<CSRedisClient> cSRedisClient
            , IMemoryCache memorycache = null
            , ILogger<CsRedisManager> logger = null
            )
        {
            _serializer = serializer;
            _cSRedisClient = cSRedisClient;
            _option = option;
            _memorycache = memorycache;
            _logger = logger ?? NullLogger<CsRedisManager>.Instance; ;
        }

        public T Get<T>(string key, string dbKey = default)
        {
            if (string.IsNullOrWhiteSpace(dbKey))
            {
                dbKey = $"{_option.ConnectionString.FirstOrDefault()?.Key}";
            }
            var result = _cSRedisClient.Get(dbKey).Get<T>(key);
            return result;
        }

        public async Task<T> GetAsync<T>(string key, string dbKey = default)
        {
            if (string.IsNullOrWhiteSpace(dbKey))
            {
                dbKey = $"{_option.ConnectionString.FirstOrDefault()?.Key}";