C#使用Redis集群作为缓存服务器-武穆逸仙

简介

基于 abp.net 框架的缓存模块，如何使用 Redis 集群来实现案例呢？

项目结构

类型：Console
依赖类库：Abp.RedisCache、Abp

主要代码

1.程序模块

根据 abp 编码规则，定义 console 的模块


    /// <summary>
    /// reids 集群测试 module
    /// </summary>
    [DependsOn(typeof(AbpRedisCacheModule))]
    public class ReidsSentinelCacheModule : AbpModule
    {
        public override void PreInitialize()
        {
            this.Configuration.Caching.ConfigureAll(cache =>
                {
                    //cache.DefaultSlidingExpireTime = TimeSpan.FromMinutes(1);// 多久未访问
                    // 设置 1min 缓存失效
                    cache.DefaultAbsoluteExpireTime = TimeSpan.FromMinutes(1);// 定时销毁
                });
            this.Configuration.Caching.UseRedis();

        }
    }

2.初始化 ABP


        /// <summary>
        ///     初始化 abp
        /// </summary>
        private static void InitAbp()
        {
            var bootstrapper = AbpBootstrapper.Create<ReidsSentinelCacheModule>();
            bootstrapper.Initialize();
            _cacheManager = IocManager.Instance.Resolve<ICacheManager>();
        }

3.可配置 console 标题


        private static void InitConsole()
        {
            var title= ConfigurationManager.AppSettings["title"];
            Console.Title = title.IsNullOrEmpty() ? "master" : title;
        }

4.取值


        /// <summary>
        ///     获取缓存值
        /// </summary>
        /// <returns>随机值</returns>
        public static int GetCacheItem()
        {
            var cache = _cacheManager.GetCache("RANDOMCACHE");
            
            return int.Parse((cache.Get(
                "RandomValue",
                () =>
                {
                    Console.WriteLine("非缓存数据");
                    Random rd = new Random();
                    return rd.Next(1, 100000);
                })).ToString());
        }

5.main 方法


        static void Main(string[] args)
        {
            InitConsole();
            InitAbp();
            
            var randomValue = GetCacheItem();
            Console.WriteLine("第一次取值:{0}",randomValue);
            
            Stopwatch watch = new Stopwatch();
            watch.Start();
            while (true)
            {
                Thread.Sleep(5000); // 等待 500ms
                // 每 500 ms 取一次
                randomValue = GetCacheItem();
                Console.WriteLine("{1}取值:{0}", randomValue, DateTime.Now.ToString("HH:mm:ss.fff"));

                if (watch.ElapsedMilliseconds > 10*60 * 1000)
                {
                    // 运行 1min
                    break;
                }
            }

            watch.Stop();

            Console.ReadKey(true);
        }

程序运行 10min,每 5s 取一次数据，缓存设定定时 1min 失效!

6.配置文件

<?xml version="1.0" encoding="utf-8" ?>
<configuration>
  <configSections>
    
  </configSections>
  <appSettings>
    <!--区分程序-->
    <add key="title" value="" />
    <!--指定 redis 数据库-->
    <add key="Abp.Redis.Cache.DatabaseId" value="-1" />
    
  </appSettings>
  <connectionStrings>
    <!--设置 redis 数据库连接-->
    <add name="Abp.Redis.Cache" connectionString="localhost:6379,localhost:6380,localhost:6381"/>
  </connectionStrings>
    <startup> 
        <supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.5.2" />
    </startup>
</configuration>