src/sample/XXX.Plugin.FreeRedis/Service/RedisService.cs

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

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

using FreeRedis;

namespace XXX.Plugin.FreeRedis
{
    public interface IRedisService
    {
        int DistributeLock(string lockKey, int timeoutSeconds = 30, bool autoDelay = false);
        string Get(string key = "one_key");
        long Publish(string channel, string message);
        bool Set(string key, string value, TimeSpan timeSpan);
    }

    public class RedisService : IRedisService
    {
        private readonly ILogger<RedisService> _logger;
        private readonly RedisClient _redisClient;

        private static int _tempInt = 0;

        /// <summary>
        /// 
        /// </summary>
        /// <param name="logger"></param>
        /// <param name="redisIdleBus"></param>
        public RedisService(ILogger<RedisService> logger, IdleBus<RedisClient> redisIdleBus)
        {
            _logger = logger;
            // FreeRedis原生对象，以最原生方式调用，支持操作多个redis库；_redisIdleBus.Get("别名")
            _redisClient = redisIdleBus.Get("2");
        }

        /// <summary>
        /// Redis插入
        /// </summary>
        /// <param name="key"></param>
        /// <param name="value"></param>
        /// <param name="timeSpan"></param>
        /// <returns></returns>
        public bool Set(string key, string value, TimeSpan timeSpan)
        {
            //remark:
            //一秒后过期
            TimeSpan.FromSeconds(1);
            //一小时后过期
            TimeSpan.FromHours(1);

            _redisClient.Set(key, value, timeSpan);
            //var succeed = await _redisManager.SetAsync(key, value, timeSpan,"2");
            //var succeed1 = await _redisManager.SetAsync(key, value, timeSpan,"1");
            _logger.LogInformation("redis 插入成功 ");
            return true;
        }

        /// <summary>
        /// 通过key或者Redis值
        /// </summary>
        /// <param name="key"></param>
        /// <returns></returns>
        public string Get(string key)
        {