C#实现封装常用Redis工具类的示例代码
更新时间：2024年03月05日 10:20:10 作者：搬砖的诗人Z
这篇文章主要为大家详细介绍了C#实现封装常用Redis工具类的相关知识,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下
1.请先安装CSRedisCore
接口：
namespace Tools.Redis
{
public interface IRedisTool
{
bool SetLongValue(string key, string value);
bool SetValue(string key, string value, int outSecond);
bool SetValue(string key, string value);
bool Exists(string key);
bool UpdateValue(string key, string value);
string? GetValue(string key);
T? GetValue<T>(string key);
T? GetEntity<T>(string key);
List<T>? GetLike<T>(string key);
void DeleteKey(string key);
void DeleteLike(string key);
}
}
实现接口方法
using CSRedis;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace Tools.Redis
{
public class RedisTool : IRedisTool
{
CSRedisClient csRedis;
public RedisTool(string redisConfig)
{
csRedis = new CSRedisClient(redisConfig);
RedisHelper.Initialization(csRedis);
}
/// <summary>
/// 设置长时间存在的值
/// </summary>
/// <param name="key"></param>
/// <param name="value"></param>
/// <returns></returns>
public bool SetLongValue(string key, string value)
{
try
{
csRedis.Set(key, value);
return true;
}
catch (Exception ex)
{
NLogHelper.Error("RedisDataHelper-SetValue" + ex.Message);
return false;
}
}
/// <summary>
/// 设置值，并设置清除时间
/// </summary>
/// <param name="key"></param>
/// <param name="value"></param>
/// <param name="outSecond"></param>
/// <returns></returns>
public bool SetValue(string key, string value, int outSecond)
{
try
{
csRedis.Set(key, value, outSecond);
return true;
}
catch (Exception ex)
{
NLogHelper.Error("RedisDataHelper-SetValue" + ex.Message);
return false;
}
}
/// <summary>
/// 设置值，存在则覆盖，并沿用之前的清除时间
/// </summary>
/// <param name="key"></param>
/// <param name="value"></param>
/// <returns></returns>
public bool SetValue(string key, string value)
{
try
{
if (csRedis.Exists(key))
{
long time = csRedis.Ttl(key);
csRedis.Set(key, value, Convert.ToInt32(time));
}
else
csRedis.Set(key, value);
return true;
}
catch (Exception ex)
{
NLogHelper.Error($"RedisDataHelper-SetValue[{key}-{value}]" + ex.Message);
return false;
}
}
/// <summary>
/// 是否存在key
/// </summary>
/// <param name="key"></param>
/// <returns></returns>
public bool Exists(string key)
{
try
{
return csRedis.Exists(key);
}
catch (Exception ex)
{
NLogHelper.Error("RedisDataHelper-KeyExists" + ex.Message);
return false;
}
}
/// <summary>
/// 更新Key，把自动注销时间设置为原来的key的时间,不存在返回false
/// </summary>
/// <param name="key"></param>
/// <param name="value"></param>
/// <returns></returns>
public bool UpdateValue(string key, string value)
{
try
{
if (csRedis.Exists(key))
{
long time = csRedis.Ttl(key);
csRedis.Set(key, value, Convert.ToInt32(time));
return true;
}
return false;
}
catch (Exception ex)
{
NLogHelper.Error($"RedisDataHelper-SetValue[{key}-{value}]" + ex.Message);
return false;
}
}
public string? GetValue(string key)
{
try
{
return csRedis.Get(key);
}
catch (Exception ex)
{
NLogHelper.Error($"RedisDataHelper-GetValue[{key}]" + ex.Message);
return null;
}
}
/// <summary>
/// 获得json序列化后的
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="key"></param>
/// <returns></returns>
public T? GetValue<T>(string key)
{
try
{
var data = csRedis.Get(key);
return JsonConvert.DeserializeObject<T>(data);
}
catch (Exception ex)
{
NLogHelper.Error($"RedisDataHelper-GetValue[{key}]" + ex.Message);
return default;
}
}
public T? GetEntity<T>(string key)
{
try
{
var data = csRedis.Get(key);
return JsonConvert.DeserializeObject<T>(data);
}
catch (Exception ex)
{
NLogHelper.Error($"RedisDataHelper-GetList[{key}]" + ex.Message);
return default;
}
}
public List<T>? GetLike<T>(string key)
{
try
{
var dataList = csRedis.Keys(key + "*");
List<T> list = new List<T>();
foreach (string item in dataList)
{
var data = GetEntity<T>(item);
if (data != null)
{
list.Add(data);
}
}
return list;
}
catch (Exception ex)
{
NLogHelper.Error($"RedisDataHelper-GetList[{key}]" + ex.Message);
return default;
}
}
public void DeleteKey(string key)
{
try
{
csRedis.Del(key);
}
catch (Exception ex)
{
NLogHelper.Error($"RedisDataHelper-DeleteKey[{key}]" + ex.Message);
}
}
public void DeleteLike(string key)
{
try
{
var dataList = csRedis.Keys(key + "*");
foreach (string item in dataList)
{
DeleteKey(item);
}
}
catch (Exception ex)
{
NLogHelper.Error($"RedisDataHelper-DeleteLike[{key}]" + ex.Message);
}
}
private bool AcquireLock(string lockKey, string lockValue, int lockTimeoutSeconds)
{
// 尝试获取锁
bool lockAcquired = csRedis.SetNx(lockKey, lockValue);
// 如果成功获取锁，设置锁的超时时间
if (lockAcquired)
{
csRedis.Expire(lockKey, lockTimeoutSeconds);
}
return lockAcquired;
}
private void ReleaseLock(string lockKey, string lockValue)
{
// 释放锁
// 使用 Lua 脚本确保只有持有锁的客户端才能释放锁
string luaScript = @"
if redis.call('get', KEYS[1]) == ARGV[1] then
return redis.call('del', KEYS[1])
else
return 0
end";
csRedis.Eval(luaScript, lockKey, new[] { lockValue });
}
}
}
以上就是C#实现封装常用Redis工具类的示例代码的详细内容，更多关于C#封装常用Redis的资料请关注脚本之家其它相关文章！
相关文章
在本篇文章里小编给大家整理的是关于c++换行符知识点总结，需要的朋友们可以参考学习下。2020-03-03
本文主要介绍了C#中的矩形数组(多维数组)和锯齿数组的实现，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2023-04-04
字符串可以向int, bool等类型转变，但是字符串是否可以向枚举转变呢？一起看下边的例子2014-01-01
c#执行外部命令示例分享，大家参考使用吧2013-12-12
这篇文章主要介绍了C#中的TemplateMethod模式,本文通过实例代码给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2020-06-06
这篇文章主要介绍了C#实现在应用程序间发送消息的方法,结合具体实例形式分析了C#实现项目之间信息发送、接收等交互操作相关技巧,需要的朋友可以参考下2017-06-06
本文主要介绍了C# new与malloc的使用与区别，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2023-07-07
这篇文章主要介绍了C#备忘录模式(Memento Pattern),以一个支持回退操作的例子讲述了C#备忘模式的实现方法,需要的朋友可以参考下2014-09-09
这篇文章主要介绍了基于C#的电视台节目表接口调用代码的相关资料,需要的朋友可以参考下2016-06-06
这篇文章主要为大家详细介绍了unity shader实现玻璃折射效果，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2020-04-04
最新评论