Redis的增删改查 c# key value类型和hash map 类型
2024-10-11 04:43:22
using Newtonsoft.Json;
using StackExchange.Redis;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks; namespace AIMS.RedisMng
{
public class RedisContext : IRedisContext
{
private readonly static string REDIS_CONN = "127.0.0.1:6379";
private readonly static string REDIS_IP = "127.0.0.1";
private readonly static int REDIS_PORT = ; private ConnectionMultiplexer redis = null;
//private StackExchange redis = null;
private IDatabase database = null;
private IServer server = null;
private int mydb = ; public RedisContext()
{
//mydb = db;
if (redis == null)
{
redis = ConnectionMultiplexer.Connect(REDIS_CONN);
database = redis.GetDatabase(mydb);
server = redis.GetServer(REDIS_IP, REDIS_PORT);
redis.ErrorMessage += Redis_ErrorMessage; }
}
//==========================================================================
#region key value 操作
/// <summary>
/// 查询
/// </summary>
/// <param name="pattern"></param>
/// <returns></returns>
public Dictionary<string, string> GetLikeKeyValue(string pattern = "*")
{
IEnumerable<RedisKey> list = LikeKeys(pattern);
Dictionary<string, string> dic = new Dictionary<string, string>();
if (list != null && list.Count() > )
{
foreach (var item in list)
{
dic.Add(item, StringGet(item));
}
}
return dic;
} /// <summary>
/// 删除key
/// </summary>
/// <param name="key"></param>
/// <returns></returns>
public bool KeyDelete(string key)
{
return database.KeyDelete(key);
} /// <summary>
/// 看key是否存在
/// </summary>
/// <param name="key"></param>
/// <returns></returns>
public bool KeyIsExist(string key)
{
return database.KeyExists(key); } /// <summary>
/// 获取key
/// </summary>
/// <param name="pattern"></param>
/// <returns></returns>
public IEnumerable<RedisKey> LikeKeys(string pattern = "*")
{
return server.Keys(database: mydb, pattern: pattern);
} /// <summary>
/// 新增key value
/// </summary>
/// <param name="key"></param>
/// <param name="val"></param>
/// <param name="exp"></param>
/// <returns></returns>
public bool ObjectSet(string key, object val, TimeSpan? exp = default(TimeSpan?))
{
string json = Newtonsoft.Json.JsonConvert.SerializeObject(val);
return database.StringSet(key, json, exp);
} /// <summary>
/// 异常记录
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
public void Redis_ErrorMessage(object sender, RedisErrorEventArgs e)
{
LogHelper.WriteLog("Redis", "", "new Exception(e.Message)");
} /// <summary>
/// 通过key获取value
/// </summary>
/// <param name="key"></param>
/// <returns></returns>
public string StringGet(string key)
{
return database.StringGet(key);
} /// <summary>
/// 新增key value
/// </summary>
/// <param name="key"></param>
/// <param name="val"></param>
/// <param name="exp"></param>
/// <returns></returns>
public bool StringSet(string key, string val, TimeSpan? exp = default(TimeSpan?))
{
return database.StringSet(key, val, exp);
}
#endregion
//===========================================================================================
#region hash map 操作 /// <summary>
/// 移除字段
/// </summary>
/// <param name="redisKey"></param>
/// <param name="hashField"></param>
/// <returns></returns>
public bool HashDelete(string redisKey, string hashField)
{
return database.HashDelete(redisKey, hashField);
//return redis.HashDelete(redisKey, hashField);
}
/// <summary>
/// 判断是否存在
/// </summary>
/// <param name="redisKey"></param>
/// <param name="hashField"></param>
/// <returns></returns>
public bool HashExists(string redisKey, string hashField)
{
return database.HashExists(redisKey, hashField);
//return redis.KeyExists(redisKey, hashField);
}
/// <summary>
/// 获取值通过key和fieldredisKey
/// </summary>
/// <param name="redisKey"></param>
/// <param name="hashField"></param>
/// <returns></returns>
public RedisValue HashGet(string redisKey, string hashField)
{
return database.HashGet(redisKey, hashField).ToString();
//return redis.HashGet(redisKey, hashField).ToString();
} /// <summary>
/// 获取值通过key和field
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="redisKey"></param>
/// <param name="hashField"></param>
/// <returns></returns>
public T HashGet<T>(string redisKey, string hashField)
{ return JsonConvert.DeserializeObject<T>(database.HashGet(redisKey, hashField));
} /// <summary>
/// 获取值通过key
/// </summary>
/// <param name="redisKey"></param>
/// <returns></returns>
public IEnumerable<RedisValue> HashKeys(string redisKey)
{
return database.HashValues(redisKey);
//return database.HashLength(redisKey);
} /// <summary>
/// 设定值
/// </summary>
/// <param name="redisKey"></param>
/// <param name="hashField"></param>
/// <param name="value"></param>
/// <returns></returns>
public bool HashSet(string redisKey, string hashField, string value)
{
return Convert.ToBoolean( database.HashIncrement(redisKey, hashField,Convert.ToInt64(value)));
//return redis.HashIncrement(redisKey, hashField, value);
} /// <summary>
/// 设定值
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="redisKey"></param>
/// <param name="hashField"></param>
/// <param name="value"></param>
/// <returns></returns>
public bool HashSet<T>(string redisKey, string hashField, T value)
{
string val = JsonConvert.SerializeObject(value);
return database .HashSet(redisKey, hashField, val);
} #endregion
//=======================================================================================
}
}
最新文章
- linq to js使用汇总
- JPA persistence
- Storm与Spark：谁才是我们的实时处理利器
- Python入门笔记(10):字典
- 洛谷P1136 迎接仪式
- linux学习笔记 2013-09-02
- 编码中常用的SQL语法
- DevExpress XtraGrid 数据导出导入Excel
- HTML基础和表格
- C语言-06复杂数据类型-01数组
- 致命错误： Python.h：没有那个文件或目录
- SOAP消息的传递
- C# for循环①护栏长度 ②广场砖面积 ③判断闰年平年
- 第五章——支持向量机（Support Vector Machines）
- LinkedList使用方法
- sjms-1 面向对象
- 13 Connectors: show contrast/oppistion
- File 和 导出jar包
- Python Django性能测试与优化指南
- MyBatis传入集合 list 数组 map参数的写法