全网整合营销服务商

电脑端+手机端+微信端=数据同步管理

免费咨询热线:400-708-3566

.net core使用redis基于StackExchange.Redis

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

随手写的,写得比较糙。

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。


# .net  # core  # redis  # StackExchange.Redis  # Redis数据库基础与ASP.NET Core缓存实现  # ASP.NET Core扩展库ServiceStack.Redis用法介绍  # .NET Core中使用Redis与Memcached的序列化问题详析  # .net core如何使用Redis发布订阅  # 详解Asp.net Core 使用Redis存储Session  # 详解如何在ASP.NET Core中使用Redis  # ASP.NET Core中使用Redis实现缓存  # 找不到  # 创建一个  # 配置文件  # 可以看到  # 写得  # 大家多多  # 默认为  # 使用了  # returns  # redisConfig  # param  # GetConnect  # var  # IConfigurationSection  # redisInstanceName  # string  # ConnectionMultiplexer  # GetOrAdd  # lt  # config 


相关文章: C++中引用和指针有什么区别?(代码说明)  官网建站费用明细查询_企业建站套餐价格及收费标准指南  猪八戒网站制作视频,开发一个猪八戒网站,大约需要多少?或者自己请程序员,需要什么程序员,多少程序员能完成?  建站之星3.0如何解决常见操作问题?  建站之星如何修改网站生成路径?  郑州企业网站制作公司,郑州招聘网站有哪些?  建站之星安装模板失败:服务器环境不兼容?  头像制作网站在线制作软件,dw网页背景图像怎么设置?  成都品牌网站制作公司,成都营业执照年报网上怎么办理?  潍坊网站制作公司有哪些,潍坊哪家招聘网站好?  建站主机如何选?性能与价格怎样平衡?  学校免费自助建站系统:智能生成+拖拽设计+多端适配  西安市网站制作公司,哪个相亲网站比较好?西安比较好的相亲网站?  建站之星好吗?新手能否轻松上手建站?  相册网站制作软件,图片上的网址怎么复制?  开封网站制作公司,网络用语开封是什么意思?  网站制作壁纸教程视频,电脑壁纸网站?  如何在阿里云虚拟服务器快速搭建网站?  定制建站如何定义?其核心优势是什么?  网站制作知乎推荐,想做自己的网站用什么工具比较好?  如何在阿里云域名上完成建站全流程?  网站网页制作专业公司,怎样制作自己的网页?  详解jQuery中基本的动画方法  公司门户网站制作公司有哪些,怎样使用wordpress制作一个企业网站?  怎么制作一个起泡网,水泡粪全漏粪育肥舍冬季氨气超过25ppm,可以有哪些措施降低舍内氨气水平?  如何在局域网内绑定自建网站域名?  标准网站视频模板制作软件,现在有哪个网站的视频编辑素材最齐全的,背景音乐、音效等?  定制建站方案优化指南:企业官网开发与建站费用解析  网站制作员失业,怎样查看自己网站的注册者?  建站之星代理平台如何选择最佳方案?  ,有什么在线背英语单词效率比较高的网站?  宝塔新建站点报错如何解决?  南宁网站建设制作定制,南宁网站建设可以定制吗?  如何通过虚拟机搭建网站?详细步骤解析  建站之星后台管理系统如何操作?  商务网站制作工程师,从哪几个方面把握电子商务网站主页和页面的特色设计?  临沂网站制作公司有哪些,临沂第四中学官网?  电商网站制作公司有哪些,1688网是什么意思?  网站建设制作需要多少钱费用,自己做一个网站要多少钱,模板一般多少钱?  如何使用Golang table-driven基准测试_多组数据测量函数效率  公司网站制作费用多少,为公司建立一个网站需要哪些费用?  如何通过云梦建站系统实现SEO快速优化?  淘宝制作网站有哪些,淘宝网官网主页?  建站主机数据库如何配置才能提升网站性能?  如何高效生成建站之星成品网站源码?  在线制作视频的网站有哪些,电脑如何制作视频短片?  如何快速搭建高效可靠的建站解决方案?  如何快速搭建高效简练网站?  导航网站建站方案与优化指南:一站式高效搭建技巧解析  建站之星备案流程有哪些注意事项? 

您的项目需求

*请认真填写需求信息,我们会在24小时内与您取得联系。