最新文章专题视频专题问答1问答10问答100问答1000问答2000关键字专题1关键字专题50关键字专题500关键字专题1500TAG最新视频文章推荐1 推荐3 推荐5 推荐7 推荐9 推荐11 推荐13 推荐15 推荐17 推荐19 推荐21 推荐23 推荐25 推荐27 推荐29 推荐31 推荐33 推荐35 推荐37视频文章20视频文章30视频文章40视频文章50视频文章60 视频文章70视频文章80视频文章90视频文章100视频文章120视频文章140 视频2关键字专题关键字专题tag2tag3文章专题文章专题2文章索引1文章索引2文章索引3文章索引4文章索引5123456789101112131415文章专题3
问答文章1 问答文章501 问答文章1001 问答文章1501 问答文章2001 问答文章2501 问答文章3001 问答文章3501 问答文章4001 问答文章4501 问答文章5001 问答文章5501 问答文章6001 问答文章6501 问答文章7001 问答文章7501 问答文章8001 问答文章8501 问答文章9001 问答文章9501
当前位置: 首页 - 科技 - 知识百科 - 正文

.net core使用redis基于StackExchange.Redis

来源:懂视网 责编:小采 时间:2020-11-27 22:35:45
文档

.net core使用redis基于StackExchange.Redis

.net core使用redis基于StackExchange.Redis:.net core使用redis基于StackExchange.Redis教程,具体如下 一.添加引用包 StackExchange.Redis Microsoft.Extensions.Configuration 二.修改配置文件 appsettings.json { RedisConfig: { Redis_Defa
推荐度:
导读.net core使用redis基于StackExchange.Redis:.net core使用redis基于StackExchange.Redis教程,具体如下 一.添加引用包 StackExchange.Redis Microsoft.Extensions.Configuration 二.修改配置文件 appsettings.json { RedisConfig: { Redis_Defa

.net 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 _redisClinet;
 private RedisClientSingleton() { }

 private static object _lockObj = new object();
 public static RedisClient GetInstance(IConfigurationRoot config)
 {
 if (_redisClinet == null)
 {
 lock (_lockObj)
 {
 if (_redisClinet == null)
 {
 _redisClinet = new RedisClient(config);
 }
 }
 }
 return _redisClinet;
 }
}

四.测试

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 后得到

随手写的,写得比较糙。

声明:本网页内容旨在传播知识,若有侵权等问题请及时与本网联系,我们将在第一时间删除处理。TEL:177 7030 7066 E-MAIL:11247931@qq.com

文档

.net core使用redis基于StackExchange.Redis

.net core使用redis基于StackExchange.Redis:.net core使用redis基于StackExchange.Redis教程,具体如下 一.添加引用包 StackExchange.Redis Microsoft.Extensions.Configuration 二.修改配置文件 appsettings.json { RedisConfig: { Redis_Defa
推荐度:
标签: net 基于 core
  • 热门焦点

最新推荐

猜你喜欢

热门推荐

专题
Top