附文档及源码下载地址：[https://github.com/jinyancao/CtrAuthPlatform/tree/course3]

一、缓存介绍及选型

网关的一个重要的功能就是缓存，可以对一些不常更新的数据进行缓存，减少后端服务开销，默认Ocelot实现的缓存为本地文件进行缓存，无法达到生产环境大型应用的需求，而且不支持分布式环境部署，所以我们需要一个满足大型应用和分布式环境部署的缓存方案。Redis应该是当前应用最广泛的缓存数据库，支持5种存储类型，满足不同应用的实现，且支持分布式部署等特性，所以缓存我们决定使用Redis作为缓存实现。

本文将介绍使用CSRedisCore来实现Redis相关操作，至于为什么选择CSRedisCore，可参考文章[.NET Core开发者的福音之玩转Redis的又一傻瓜式神器推荐],里面详细的介绍了各种Redis组件比较及高级应用，并列出了不同组件的压力测试对比，另外也附CSRedisCore作者交流QQ群：8578575，使用中有什么问题可以直接咨询作者本人。

二、缓存扩展实现

首先本地安装Redis和管理工具Redis Desktop Manager,本文不介绍安装过程，然后NuGet安装 CSRedisCore,现在开始我们重写IOcelotCache<T>的实现，新建InRedisCache.cs文件。

using Ctr.AhphOcelot.Configuration; using Ocelot.Cache; using System; using System.Collections.Generic; using System.Text;  namespace Ctr.AhphOcelot.Cache {     /// <summary>     /// 金焰的世界     /// 2018-11-14     /// 使用Redis重写缓存     /// </summary>     /// <typeparam name="T"></typeparam>     public class InRedisCache<T> : IOcelotCache<T>     {         private readonly AhphOcelotConfiguration _options;         public InRedisCache(AhphOcelotConfiguration options)         {             _options = options;             CSRedis.CSRedisClient csredis;             if (options.RedisConnectionStrings.Count == 1)             {                 //普通模式                 csredis = new CSRedis.CSRedisClient(options.RedisConnectionStrings[0]);             }             else             {                 //集群模式                 //实现思路：根据key.GetHashCode() % 节点总数量，确定连向的节点                 //也可以自定义规则(第一个参数设置)                 csredis = new CSRedis.CSRedisClient(null, options.RedisConnectionStrings.ToArray());             }             //初始化 RedisHelper             RedisHelper.Initialization(csredis);         }          /// <summary>         /// 添加缓存信息         /// </summary>         /// <param name="key">缓存的key</param>         /// <param name="value">缓存的实体</param>         /// <param name="ttl">过期时间</param>         /// <param name="region">缓存所属分类，可以指定分类缓存过期</param>         public void Add(string key, T value, TimeSpan ttl, string region)         {             key = GetKey(region, key);             if (ttl.TotalMilliseconds <= 0)             {                 return;             }             RedisHelper.Set(key, value.ToJson(), (int)ttl.TotalSeconds);          }                   public void AddAndDelete(string key, T value, TimeSpan ttl, string region)         {             Add(key, value, ttl, region);         }          /// <summary>         

                    

                        
关键字：