.net core使用redis基于StackExchange.Redis
. core使用redis基于StackExchange.Redis教程,具体如下
一.添加引用包
StackExchange.Redis
Microsoft.Extensions.Configuration
二.修改配置文件 appsettings.json
{ "RedisConfig": { "Redis_Default": { "Connection": "127.0.0.1: 6379", "InstanceName": "Redis1: " }, "Redis_6": { "Connection": "127.0.0.1: 6379", "DefaultDatabase": 6, "InstanceName": "Redis2: " } } }
三.简单封装
RedisClient.cs类
public class RedisClient : IDisposable { private IConfigurationRoot _config; private ConcurrentDictionary<string, ConnectionMultiplexer> _connections; public RedisClient(IConfigurationRoot config) { _config = config; _connections = new ConcurrentDictionary<string, ConnectionMultiplexer>(); } /// <summary> /// 获取ConnectionMultiplexer /// </summary> /// <param name="redisConfig">RedisConfig配置文件</param> /// <returns></returns> private ConnectionMultiplexer GetConnect(IConfigurationSection redisConfig) { var redisInstanceName = redisConfig["InstanceName"]; var connStr = redisConfig["Connection"]; return _connections.GetOrAdd(redisInstanceName, p => ConnectionMultiplexer.Connect(connStr)); } /// <summary> /// 检查入参数 /// </summary> /// <param name="configName">RedisConfig配置文件中的 Redis_Default/Redis_6 名称</param> /// <returns></returns> private IConfigurationSection CheckeConfig(string configName) { IConfigurationSection redisConfig = _config.GetSection("RedisConfig").GetSection(configName); if (redisConfig == null) { throw new ArgumentNullException($"{configName}找不到对应的RedisConfig配置!"); } var redisInstanceName = redisConfig["InstanceName"]; var connStr = redisConfig["Connection"]; if (string.IsNullOrEmpty(redisInstanceName)) { throw new ArgumentNullException($"{configName}找不到对应的InstanceName"); } if (string.IsNullOrEmpty(connStr)) { throw new ArgumentNullException($"{configName}找不到对应的Connection"); } return redisConfig; } /// <summary> /// 获取数据库 /// </summary> /// <param name="configName"></param> /// <param name="db">默认为0优先代码的db配置,config中的配置</param> /// <returns></returns> public IDatabase GetDatabase(string configName = null, int? db = null) { int defaultDb = 0; IConfigurationSection redisConfig = CheckeConfig(configName); if (db.HasValue) { defaultDb = db.Value; } else { var strDefalutDatabase = redisConfig["DefaultDatabase"]; if (!string.IsNullOrEmpty(strDefalutDatabase) && Int32.TryParse(strDefalutDatabase, out var intDefaultDatabase)) { defaultDb = intDefaultDatabase; } } return GetConnect(redisConfig).GetDatabase(defaultDb); } public IServer GetServer(string configName = null, int endPointsIndex = 0) { IConfigurationSection redisConfig = CheckeConfig(configName); var connStr = redisConfig["Connection"]; var confOption = ConfigurationOptions.Parse((string)connStr); return GetConnect(redisConfig).GetServer(confOption.EndPoints[endPointsIndex]); } public ISubscriber GetSubscriber(string configName = null) { IConfigurationSection redisConfig = CheckeConfig(configName); return GetConnect(redisConfig).GetSubscriber(); } public void Dispose() { if (_connections != null && _connections.Count > 0) { foreach (var item in _connections.Values) { item.Close(); } } } }
因为RedisClient 中使用了ConcurrentDictionary
所以,有了RedisClientSingleton.cs类
public class RedisClientSingleton { private static RedisClient _redisCli; private RedisClientSingleton() { } private static object _lockObj = new object(); public static RedisClient GetInstance(IConfigurationRoot config) { if (_redisCli == null) { lock (_lockObj) { if (_redisCli == null) { _redisCli = new RedisClient(config); } } } return _redisCli; } }
四.测试
1、控制台程序
1)创建一个Controller程序
2)添加引用包
Microsoft.Extensions.Configuration
Microsoft.Extensions.Configuration.Json
3)添加appsettings.json
添加以下
"RedisConfig": { "Redis_Default": { "Connection": "127.0.0.1:6379", "InstanceName": "Redis1:" }, "Redis_6": { "Connection": "127.0.0.1:6379", "DefaultDatabase": 6, "InstanceName": "Redis2:" } }
4)修改Program类
①添加引用using Microsoft.Extensions.Configuration;
②修改Main
static void Main(string[] args) { var builder = new ConfigurationBuilder() .SetBasePath(Directory.GetCurrentDirectory()) .AddJsonFile("appsettings.json"); IConfigurationRoot configuration = builder.Build(); var redisClient = RedisClientSingleton.GetInstance(configuration); var redisDatabase = redisClient.GetDatabase("Redis_Default"); redisDatabase.StringSet("TestStrKey", "TestStrValue"); }
③运行后可以看到
2、web程序
①创建一个core的mvc项目
②修改Startup.cs文件
修改ConfigureServices函数
public void ConfigureServices(IServiceCollection services) { ... services.AddSingleton(Configuration); ... }
其中的Configuration是 public IConfigurationRoot Configuration { get; }
③创建一个TestController
在修改构造函数
SimpleRedisExt _redisExt;
public TokenTranslateController(IConfigurationRoot config)//, IConfigurationRoot config) { _config = config; IDatabase redisDataBase = RedisClientSingleton.GetInstance(_config).GetDatabase("Redis_Default"); } public string Post(string value) { redisDataBase.StringSet("TestMvcRedis", value); }
④运行value = TestMvcRedisValue 后得到
随手写的,写得比较糙。
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持狼蚁SEO。
编程语言
- 如何快速学会编程 如何快速学会ug编程
- 免费学编程的app 推荐12个免费学编程的好网站
- 电脑怎么编程:电脑怎么编程网咯游戏菜单图标
- 如何写代码新手教学 如何写代码新手教学手机
- 基础编程入门教程视频 基础编程入门教程视频华
- 编程演示:编程演示浦丰投针过程
- 乐高编程加盟 乐高积木编程加盟
- 跟我学plc编程 plc编程自学入门视频教程
- ug编程成航林总 ug编程实战视频
- 孩子学编程的好处和坏处
- 初学者学编程该从哪里开始 新手学编程从哪里入
- 慢走丝编程 慢走丝编程难学吗
- 国内十强少儿编程机构 中国少儿编程机构十强有
- 成人计算机速成培训班 成人计算机速成培训班办
- 孩子学编程网上课程哪家好 儿童学编程比较好的
- 代码编程教学入门软件 代码编程教程