.net core中关于Redis单例模式，依赖注入配置类

当前位置：网站建设 > 技术支持

.net core中关于Redis单例模式，依赖注入配置类

资料来源：网络整理时间：2023/2/14 1:08:32 共计：3630 浏览

安装依赖

StackExchange.Redis

appsettings.json

{

"Logging": {

"LogLevel": {

"Default": "Information",

"Microsoft.AspNetCore": "Warning"

}

"AllowedHosts": "*",

"Redis": {

"Password": "",

"AllowAdmin": false,

"Ssl": false,

"ConnectTimeout": 6000,

"ConnectRetry": 2,

"Hosts": [

{

"Host": "localhost",

"Port": "6379"

}

"Database": 0

"RedisConnectionString": {"Value":"127.0.0.1,DefaultDatabase=0" }

}

RedisConfig.cs

namespace CoreRedis.Config

{

public class RedisConfig

{

public string Value { get; set; }

}

builder.Services.Configure<RedisConfig>(

builder.Configuration.GetSection("RedisConnectionString")

);

//如下，是个单例的服务，这个服务中需要注入配置项

builder.Services.AddSingleton<RedisString>();

如何在单例中注入

关键是使用 IOptionsMonitor

https://andrewlock.net/creating-singleton-named-options-with-ioptionsmonitor/

using Microsoft.AspNetCore.Mvc;

using StackExchange.Redis;

using StackExchange.Redis.Extensions.Core.Abstractions;

using System.Threading;

using System.Threading.Tasks;

using System.Configuration;

using Microsoft.Extensions.Options;

using CoreRedis.Config;

using Newtonsoft.Json;

namespace CoreRedis.RedisDataType

{

public class RedisString

{

private static readonly object _lock = new object();

private ConnectionMultiplexer redisMultiplexer;

//private static RedisString _redisClient = null;

private readonly RedisConfig _redisConfig;

IDatabase db = null;

//public static RedisString RedisClient

//{

// get

// {

// if (_redisClient == null)

// {

// lock(_lock)

// {

// _redisClient = new RedisString();

// }

// return _redisClient;

// }

//}

public RedisString(IOptionsMonitor<RedisConfig> optionsSnapshot)

{

_redisConfig = optionsSnapshot.CurrentValue;

//_redisConfig = optionsSnapshot;

var RedisConnection = _redisConfig.Value;

redisMultiplexer = ConnectionMultiplexer.Connect(RedisConnection);

db = redisMultiplexer.GetDatabase();

}

//添加一个key 或者覆盖key的值

public async Task<Task<bool>> SetKey(string key, string value)

{

return db.StringSetAsync(key, value, null, false, StackExchange.Redis.When.Always);

}

//只有在键不存在的时候才设置

public async Task<Task<bool>> SetKeyNx(string key, string value)

{

return db.StringSetAsync(key, value, null, false, When.NotExists);

}

/// <summary>

/// 获取一个key的对象

/// </summary>

public async Task<T> GetStringKey<T>(string key)

{

if (db == null)

{

return default;

}

var value = await db.StringGetAsync(key);

if (value.IsNullOrEmpty)

{

return default;

}

return JsonConvert.DeserializeObject<T>(value);

}

//getset一个key，获取旧值并设置新值

public async Task<T> GetSetKey<T>(string key,string value)

{

var oldvalue = await db.StringGetSetAsync(key, value);

return JsonConvert.DeserializeObject<T>(oldvalue);

}

//mset 一次设置多个数据

public async Task<Task<bool>> MSET(KeyValuePair<RedisKey, RedisValue>[] values )

{

return db.StringSetAsync(values, When.NotExists);

}

//mget 一次获取多个数据

public async Task<Task<RedisValue[]>> MGET(RedisKey[] keys)

{

return db.StringGetAsync(keys);

}

//获取string的length

public async Task<Task<long>> KeyLen(string key)

{

return db.StringLengthAsync(key);

}

//append

public async Task<Task<long>> Append(string key , string appendvalue)

{

return db.StringAppendAsync(key, appendvalue);

}

//get range

public async Task<Task<RedisValue>> GetRange(string key , int start, int end)

{

return db.StringGetRangeAsync(key, start, end);

}

//增加

public async Task<Task<long>> Incr(string key,int count)

{

return db.StringIncrementAsync(key, count);

}

//减少

public async Task<Task<long>> Decr(string key,int count)

{

return db.StringDecrementAsync(key, count);

}

版权说明：
本网站凡注明“广州京杭原创”的皆为本站原创文章，如需转载请注明出处！
本网转载皆注明出处，遵循行业规范，如发现作品内容版权或其它问题的，请与我们联系处理！
欢迎扫描右侧微信二维码与我们联系。

·上一条：ASPNET.Core结合Redis实践消息队列，从此放心安全迭代 | ·下一条：Asp.Net Core 2.0 项目实战（6）Redis配置、封装帮助类RedisHelper及使用实例