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

随手写的，写得比较糙。

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