.NET Core StackExchange.Redis使用方法

一、引入StackExchange.Redis

打开NuGet, 点击“浏览”页面，输入“StackExchange.Redis”，进行安装。

二、创建Redis链接管理RedisConnectionHelp

using StackExchange.Redis;
using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.Text;namespace Common.Redis
{public static class RedisConnectionHelp{private static readonly string RedisConnectionString = "127.0.0.1:6379,password=111111";//"192.168.8.73,password=111111,connectTimeout=10000,abortConnect=false";// ConfigurationManager.AppSettings["RedisExchangeHosts"];private static readonly object Locker = new object();private static ConnectionMultiplexer _instance;/// <summary>/// 单例获取/// </summary>public static ConnectionMultiplexer Instance{get{if (_instance == null || !_instance.IsConnected){lock (Locker){_instance = GetManager();}}else if (_instance != null){//LogHelper.WriteToLog("获取连接 IsConnected：" + _instance.IsConnected, "RedisConnectionHelp");}return _instance;}}private static ConnectionMultiplexer GetManager(string connectionString = null){connectionString = connectionString ?? RedisConnectionString;var connect = ConnectionMultiplexer.Connect(connectionString);//LogHelper.WriteToLog("获取连接：" + connectionString, "RedisConnectionHelp");//注册如下事件connect.ConnectionFailed += MuxerConnectionFailed;connect.ConnectionRestored += MuxerConnectionRestored;connect.ErrorMessage += MuxerErrorMessage;connect.ConfigurationChanged += MuxerConfigurationChanged;connect.HashSlotMoved += MuxerHashSlotMoved;connect.InternalError += MuxerInternalError;return connect;}#region 事件/// <summary>/// 配置更改时/// </summary>/// <param name="sender"></param>/// <param name="e"></param>private static void MuxerConfigurationChanged(object sender, EndPointEventArgs e){//LogHelper.WriteToLog("Configuration changed: " + e.EndPoint, "RedisConnectionHelp");}/// <summary>/// 发生错误时/// </summary>/// <param name="sender"></param>/// <param name="e"></param>private static void MuxerErrorMessage(object sender, RedisErrorEventArgs e){//LogHelper.WriteToLog("ErrorMessage: " + e.Message, "RedisConnectionHelp");}/// <summary>/// 重新建立连接之前的错误/// </summary>/// <param name="sender"></param>/// <param name="e"></param>private static void MuxerConnectionRestored(object sender, ConnectionFailedEventArgs e){//LogHelper.WriteToLog("ConnectionRestored: " + e.EndPoint, "RedisConnectionHelp");}/// <summary>/// 连接失败 ， 如果重新连接成功你将不会收到这个通知/// </summary>/// <param name="sender"></param>/// <param name="e"></param>private static void MuxerConnectionFailed(object sender, ConnectionFailedEventArgs e){//LogHelper.WriteToLog("重新连接：Endpoint failed: " + e.EndPoint + ", " + e.FailureType + (e.Exception == null ? "" : (", " + e.Exception.Message)), "RedisConnectionHelp");}/// <summary>/// 更改集群/// </summary>/// <param name="sender"></param>/// <param name="e"></param>private static void MuxerHashSlotMoved(object sender, HashSlotMovedEventArgs e){//LogHelper.WriteToLog("HashSlotMoved:NewEndPoint" + e.NewEndPoint + ", OldEndPoint" + e.OldEndPoint, "RedisConnectionHelp");}/// <summary>/// redis类库错误/// </summary>/// <param name="sender"></param>/// <param name="e"></param>private static void MuxerInternalError(object sender, InternalErrorEventArgs e){//LogHelper.WriteToLog("InternalError:Message" + e.Exception.Message, "RedisConnectionHelp");}#endregion 事件}
}

三、创建Redis处理方法

using StackExchange.Redis;
using System;
using System.Collections.Generic;
using System.Text;namespace Common.Redis
{public class RedisHandler{private int DbId = 0;private RedisHandler(int dbId = 0){DbId = dbId;}public IDatabase DataBase => GetRedisConn().GetDatabase(DbId);private static RedisHandler _instance = null;/// <summary>/// 实例列表，每个redis的每个db建立一个Instance/// </summary>private static Dictionary<int, RedisHandler> _insList = null;/// <summary>/// 单例访问/// </summary>public static RedisHandler Instance{get{if (null == _instance)_instance = new RedisHandler(0);if (null == _insList)_insList = new Dictionary<int, RedisHandler> { [0] = _instance };return _instance;}}public RedisHandler this[int dbId]{get{if (dbId > 255 || dbId < 0)throw new ArgumentOutOfRangeException(nameof(dbId), @"must be integer between 0 to 255");if (null == _insList)_insList = new Dictionary<int, RedisHandler>();if (!_insList.ContainsKey(dbId))_insList.Add(dbId, new RedisHandler(dbId));var ins = _insList[dbId];return ins;}}public ConnectionMultiplexer GetRedisConn(){return RedisConnectionHelp.Instance;}public int RetryTimes { get; set; } = 1;#region 字符串操作/// <summary>/// 获取字符串类型的redis值/// </summary>/// <param name="key"></param>/// <returns></returns>public RedisValue StringGet(RedisKey key){var errCount = 0;redo:try{return DataBase.StringGet(key);}catch (Exception e){if (errCount < RetryTimes){errCount++;goto redo;}throw;}}/// <summary>/// 添加带无生命周期的数据/// </summary>/// <param name="key"></param>/// <param name="value"></param>/// <param name="expire"></param>/// <returns></returns>public bool StringSet(RedisKey key, RedisValue value){int errCount = 0;redo:try{var ret = false;ret = DataBase.StringSet(key, value);return ret;}catch{if (errCount < RetryTimes){errCount++;goto redo;}throw;}}#endregion#region 哈希值操作public bool HashSet(RedisKey key, RedisValue hashField, RedisValue value){var errCount = 0;redo:try{return DataBase.HashSet(key, hashField, value);}catch (Exception e){if (errCount < RetryTimes){errCount++;goto redo;}throw;}}public RedisValue[] HashValues(RedisKey key){var errCount = 0;redo:try{return DataBase.HashValues(key);}catch (Exception e){if (errCount < RetryTimes){errCount++;goto redo;}throw;}}#endregion}
}

在StackExchange.Redis 下有很多方法可供调用

四、调用方法

public class RedisController
{//Redis DB数据库索引为0private RedisHandler redisHelper = RedisHandler.Instance[0];//string类型，新增key为“str”,value为“value”  public ActionResult<bool> StringSet(string key = "key", string value = "value"){var obj = redisHelper.StringSet(key, value);return obj;}//string类型，例如通过key为“str”获取value  public ActionResult<string> StringGet(string str = "str"){var obj = redisHelper.StringGet(str);return obj.ToString();}//Hash类型, 新增public ActionResult<bool> HashSet(string key , string hashField, string value){var obj = redisHelper.HashSet(key, hashField, value);return obj;}//Hash类型, 获取public ActionResult<bool> HashValues(string key){var obj = redisHelper.HashValues(key);return true;}
}

欢迎加群，日用儿童母婴，分享大牌淘宝京东优惠券

.NET Core StackExchange.Redis使用方法相关推荐

.net core 使用redis 基于 StackExchange.Redis
一.添加引用包 StackExchange.Redis Microsoft.Extensions.Configuration 二.修改配置文件 appsettings.json {"Redi ...
stackexchange.mysql_.net core使用redis基于StackExchange.Redis
.net core使用redis基于StackExchange.Redis教程,具体如下一.添加引用包 StackExchange.Redis Microsoft.Extensions.Config ...
【BCVP更新】StackExchange.Redis 的异步开发方式
有哪些习惯坚持 LESS IS MORE,SIMPLER IS BETTER THAN MORE 你一定会有很大的收获各种小问题? 如果你之前用过Redis的话,肯定会使用过StackExchan ...
StackExchange.Redis客户端读写主从配置，以及哨兵配置
今天简单分享一下StackExchange.Redis客户端中配置主从分离以及哨兵的配置. 关于哨兵如果有不了解的朋友,可以看我之前的一篇分享,当然主从复制文章也可以找到.http://www.cnb ...
StackExchange.Redis 使用-配置
Configuration redis有很多不同的方法来配置连接字符串 , StackExchange.Redis 提供了一个丰富的配置模型,当调用Connect 或者 ConnectAsync 时需 ...
StackExchange.Redis 访问封装类
最近需要在C#中使用Redis,在Redis的官网找到了ServiceStack.Redis,最后在测试的时候发现这是个坑,4.0已上已经收费,后面只好找到3系列的最终版本,最后测试发现还是有BUG或 ...
StackExchange.Redis通用封装类分享(转)
阅读目录 ConnectionMultiplexer 封装 RedisHelper 通用操作类封 String类型的封装 List类型的封装 Hash类型的封装 SortedSet 类型的封装 key ...
StackExchange.Redis 官方文档(二) Configuration
配置有多种方式可以配置redis,StackExchange.Redis提供了一个丰富的配置模型,在执行Connect (or ConnectAsync) 时被调用: var conn = Conn ...
StackExchange.Redis 使用（一）
在StackExchange.Redis中最重要的对象是ConnectionMultiplexer类, 它存在于StackExchange.Redis命名空间中. 这个类隐藏了Redis服务的操作细节 ...

.NET Core StackExchange.Redis使用方法

一、引入StackExchange.Redis

二、创建Redis链接管理RedisConnectionHelp

三、创建Redis处理方法

四、调用方法

.NET Core StackExchange.Redis使用方法相关推荐

最新文章

热门文章