CommonLib/CommonLib.Redis/StackRedisHelper.cs

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

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

namespace CommonLib
{
    using Newtonsoft.Json;

    using StackExchange.Redis;

    using System;
    using System.Collections.Generic;
    using System.Linq;
    using System.Threading.Tasks;

    /// <summary>
    /// 基于StackExchange.Redis封装
    /// 
    /// </summary>
    public class StackRedisHelper
    {
        /// <summary>
        /// 自定义缓存Key前缀
        /// </summary>
        /// <value>
        /// The custom key prefix.
        /// </value>
        private string CustomKeyPrefix { get; }

        /// <summary>
        /// ConnectionMultiplexer对象
        /// </summary>
        private readonly ConnectionMultiplexer conn;

        /// <summary>
        /// Redis数据库对象
        /// </summary>
        public readonly IDatabase db;

        /// <summary>
        /// Initializes a new instance of the <see cref="StackRedisHelper"/> class.
        /// </summary>
        /// <param name="dbSerialNumber">The database serial number.</param>
        /// <param name="connectionString">The redis connection string.</param>
        /// <param name="customKeyPrefix">The custom key prefix.</param>
        public StackRedisHelper(int dbSerialNumber
            , string connectionString
            , string customKeyPrefix = null)
        {
            CustomKeyPrefix = customKeyPrefix;
#if customSingleton
            RedisConnectionMultiplexerHelper.RedisConnectionString = redisConnectionString;
            conn = RedisConnectionMultiplexerHelper.Instance;
#endif
            if (string.IsNullOrEmpty(connectionString))
                throw new ArgumentNullException(nameof(connectionString));

            conn = ConnectionMultiplexer.Connect(connectionString);
            db = conn.GetDatabase(dbSerialNumber);
        }

        /// <summary>
        /// 保存单个k/v
        /// </summary>