作者：水晶玻璃新座 | 来源：互联网 | 2023-06-06 16:22
.netcore使用redis基于StackExchange.Redis教程，具体如下一.添加引用包StackExchange.RedisMicrosoft.Extensions.Configuration二.修改配置文件appsetting
.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 _connections;
public RedisClient(IConfigurationRoot config)
{
_cOnfig= config;
_cOnnections= new ConcurrentDictionary();
}
///
/// 获取ConnectionMultiplexer
///
/// RedisConfig配置文件
///
private ConnectionMultiplexer GetConnect(IConfigurationSection redisConfig)
{
var redisInstanceName = redisConfig["InstanceName"];
var cOnnStr= redisConfig["Connection"];
return _connections.GetOrAdd(redisInstanceName, p => ConnectionMultiplexer.Connect(connStr));
}
///
/// 检查入参数
///
/// RedisConfig配置文件中的 Redis_Default/Redis_6 名称
///
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;
}
///
/// 获取数据库
///
///
/// 默认为0：优先代码的db配置，其次config中的配置
///
public IDatabase GetDatabase(string cOnfigName= null, int&＃63; 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 后得到
随手写的，写得比较糙。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。
京公网安备 11010802041100号