.net core使用redis基于StackExchange.Redis

 更新时间:2017年04月25日 11:37:41   作者:卮言  
这篇文章主要为大家详细介绍了.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 后得到

随手写的,写得比较糙。

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

相关文章

  • ASP.NET表单验证方法详解

    ASP.NET表单验证方法详解

    在表单提交的时候,经常需要对录入信息的长度、格式、内容等进行验证,以便获得合理的信息。在ASP.NET开发中主要的验证方法,我总结了一下,主要有一下几种,如有不足之处请朋友们予以指出。
    2008-09-09
  • Global.cs中自动获取未处理的异常

    Global.cs中自动获取未处理的异常

    在一个项目中为了能捕获异常最常用的方法就是try{}catch{}了,但是事实上并不可能将所有的异常考虑到位。因此有人就想除了被try{}catch{}捕获的异常其余未被处理的异常均由全局应用程序也就是Global来捕获处理
    2011-12-12
  • .NET6使用ImageSharp实现给图片添加水印

    .NET6使用ImageSharp实现给图片添加水印

    这篇文章主要为大家详细介绍了.NET6使用ImageSharp实现给图片添加水印功能的相关资料,文中的示例代码讲解详细,感兴趣的小伙伴可以了解一下
    2022-12-12
  • 微软ajax库的使用方法(ajax.ajaxMethod)

    微软ajax库的使用方法(ajax.ajaxMethod)

    使用AjaxMethod可以在客户端异步调用服务端方法,简单地说就是在JS里调用后台.cs文件里的方法,做一些JS无法做到的操作,如查询数据库
    2013-08-08
  • Asp.net基于ajax和jquery-ui实现进度条

    Asp.net基于ajax和jquery-ui实现进度条

    这篇文章主要介绍了Asp.net基于ajax和jquery-ui实现进度条,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-12-12
  • ASP.NET MVC5网站开发之业务逻辑层的架构和基本功能(四)

    ASP.NET MVC5网站开发之业务逻辑层的架构和基本功能(四)

    这篇文章主要为大家详细介绍了ASP.NET MVC5网站开发之业务逻辑层的架构和基本功能,感兴趣的小伙伴们可以参考一下
    2016-08-08
  • asp.net C#生成和解析二维码的实例代码

    asp.net C#生成和解析二维码的实例代码

    这篇文章介绍了asp.net C#生成和解析二维码的实例代码,有需要的朋友可以参考一下
    2013-10-10
  • asp.net 利用NPOI导出Excel通用类的方法

    asp.net 利用NPOI导出Excel通用类的方法

    本篇文章主要介绍了asp.net 利用NPOI导出Excel通用类的方法,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2017-06-06
  • .NET 8 实现无实体库表 API 部署服务的详细过程

    .NET 8 实现无实体库表 API 部署服务的详细过程

    本文介绍了一个无需实体数据库、支持多种查询和功能的API部署系统,系统支持动态API、Auth授权、接口限流等,适合各平台使用,提供完整接口文档,助力开发者高效工作,无需加班,适用于.NET开发,可直接从项目地址下载使用
    2024-10-10
  • Quartz.NET的具体使用

    Quartz.NET的具体使用

    本文详细的介绍了Quartz.NET的具体使用,文中通过示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2021-08-08

最新评论