Yuebon.NetCore/Yuebon.Commons/Cache/RedisHelper.cs

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

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

using Microsoft.Extensions.Caching.StackExchangeRedis;
using StackExchange.Redis;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Text.Json;
using System.Threading.Tasks;
using Yuebon.Commons.Converter;
using Yuebon.Commons.Core.App;
using Yuebon.Commons.Helpers;

namespace Yuebon.Commons.Cache
{
    /// <summary>
    /// Redis 操作类，比YuebonCacheHelper方法更为丰富
    /// </summary>
    public class RedisHelper
    {
        /// <summary>
        /// 
        /// </summary>
        public readonly IDatabase _cache;
        /// <summary>
        /// 
        /// </summary>
        private ConnectionMultiplexer _connection;
        /// <summary>
        /// 
        /// </summary>
        private readonly string _instance;

        private readonly JsonSerializerOptions _jsonOptions;
        /// <summary>
        /// 缓存提供模式
        /// </summary>
        private static CacheProvider cacheProvider;
        /// <summary>
        /// 
        /// </summary>
        /// <param name="database"></param>
        public RedisHelper(int database = 0)
        {
            cacheProvider = Appsettings.GetService<CacheProvider>();
            RedisCacheOptions redisCacheOptions = new RedisCacheOptions()
            {
                Configuration=cacheProvider.ConnectionString
            };
            _connection = ConnectionMultiplexer.Connect(cacheProvider.ConnectionString);
            _cache = _connection.GetDatabase(database);
            _instance = cacheProvider.InstanceName;
            var options = new JsonSerializerOptions();
            options.WriteIndented = true;
            options.PropertyNamingPolicy = JsonNamingPolicy.CamelCase;
            options.AllowTrailingCommas = true;
            ////设置时间格式
            //options.Converters.Add(new DateTimeJsonConverter());
            //options.Converters.Add(new DateTimeNullableConverter());
            //设置bool获取格式
            options.Converters.Add(new BooleanJsonConverter());