【www.bbyears.com--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类
代码如下
publicclassRedisClient : IDisposable
{
privateIConfigurationRoot _config;
privateConcurrentDictionary
publicRedisClient(IConfigurationRoot config)
{
_config = config;
_connections =newConcurrentDictionary
}
///
/// 获取ConnectionMultiplexer
///
///RedisConfig配置文件
///
privateConnectionMultiplexer GetConnect(IConfigurationSection redisConfig)
{
var redisInstanceName = redisConfig["InstanceName"];
var connStr = redisConfig["Connection"];
return_connections.GetOrAdd(redisInstanceName, p => ConnectionMultiplexer.Connect(connStr));
}
///
/// 检查入参数
///
///RedisConfig配置文件中的 Redis_Default/Redis_6 名称
///
privateIConfigurationSection CheckeConfig(stringconfigName)
{
IConfigurationSection redisConfig = _config.GetSection("RedisConfig").GetSection(configName);
if(redisConfig ==null)
{
thrownewArgumentNullException($"{configName}找不到对应的RedisConfig配置！");
}
var redisInstanceName = redisConfig["InstanceName"];
var connStr = redisConfig["Connection"];
if(string.IsNullOrEmpty(redisInstanceName))
{
thrownewArgumentNullException($"{configName}找不到对应的InstanceName");
}
if(string.IsNullOrEmpty(connStr))
{
thrownewArgumentNullException($"{configName}找不到对应的Connection");
}
returnredisConfig;
}
///
/// 获取数据库
///
///
///默认为0：优先代码的db配置，其次config中的配置
///
publicIDatabase GetDatabase(stringconfigName =null,int? db =null)
{
intdefaultDb = 0;
IConfigurationSection redisConfig = CheckeConfig(configName);
if(db.HasValue)
{
defaultDb = db.Value;
}
else
{
var strDefalutDatabase = redisConfig["DefaultDatabase"];
if(!string.IsNullOrEmpty(strDefalutDatabase) && Int32.TryParse(strDefalutDatabase,outvar intDefaultDatabase))
{
defaultDb = intDefaultDatabase;
}
}
returnGetConnect(redisConfig).GetDatabase(defaultDb);
}
publicIServer GetServer(stringconfigName =null,intendPointsIndex = 0)
{
IConfigurationSection redisConfig = CheckeConfig(configName);
var connStr = redisConfig["Connection"];
var confOption = ConfigurationOptions.Parse((string)connStr);
returnGetConnect(redisConfig).GetServer(confOption.EndPoints[endPointsIndex]);
}
publicISubscriber GetSubscriber(stringconfigName =null)
{
IConfigurationSection redisConfig = CheckeConfig(configName);
returnGetConnect(redisConfig).GetSubscriber();
}
publicvoidDispose()
{
if(_connections !=null&& _connections.Count > 0)
{
foreach(var itemin_connections.Values)
{
item.Close();
}
}
}
}
word-wrap: break-word; margin: 5px 0px; color: rgb(0, 0, 0); font-family: " sans="" font-size:="" font-style:="" font-variant-ligatures:="" font-variant-caps:="" font-weight:="" letter-spacing:="" orphans:="" text-align:="" text-indent:="" text-transform:="" white-space:="" widows:="" word-spacing:="" -webkit-text-stroke-width:="">因为RedisClient 中使用了ConcurrentDictionary
所以，有了RedisClientSingleton.cs类
代码如下
publicclassRedisClientSingleton
{
privatestaticRedisClient _redisClinet;
privateRedisClientSingleton() { }
privatestaticobject_lockObj =newobject();
publicstaticRedisClient GetInstance(IConfigurationRoot config)
{
if(_redisClinet ==null)
{
lock(_lockObj)
{
if(_redisClinet ==null)
{
_redisClinet =newRedisClient(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
代码如下
staticvoidMain(string[] args)
{
var builder =newConfigurationBuilder()
.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函数
代码如下
publicvoidConfigureServices(IServiceCollection services)
{
...
services.AddSingleton(Configuration);
...
}
其中的Configuration是 public IConfigurationRoot Configuration { get; }
③创建一个TestController
在修改构造函数
SimpleRedisExt _redisExt;
代码如下
publicTokenTranslateController(IConfigurationRoot config)//, IConfigurationRoot config)
{
_config = config;
IDatabase redisDataBase = RedisClientSingleton.GetInstance(_config).GetDatabase("Redis_Default");
}
publicstringPost(stringvalue)
{
redisDataBase.StringSet("TestMvcRedis", value);
}
④运行value = TestMvcRedisValue 后得到
随手写的，写得比较糙。
以上就是本文的全部内容，希望对大家的学习有所帮助