119 lines
3.9 KiB
C#
119 lines
3.9 KiB
C#
using Microsoft.Extensions.Caching.StackExchangeRedis;
|
||
using Microsoft.Extensions.Options;
|
||
using StackExchange.Redis;
|
||
using System;
|
||
using System.Collections.Generic;
|
||
using System.Linq;
|
||
using System.Text;
|
||
using System.Threading.Tasks;
|
||
|
||
namespace Syc.Abp.Caching.Redis
|
||
{
|
||
public static class RedisConnectionManage
|
||
{
|
||
private static readonly object Locker = new object();
|
||
private static ConnectionMultiplexer _instance;
|
||
internal static string ConfigurationOptions;
|
||
internal static ConfigurationOptions Configuration;
|
||
/// <summary>
|
||
/// 单例获取
|
||
/// </summary>
|
||
public static ConnectionMultiplexer Instance
|
||
{
|
||
get
|
||
{
|
||
if (_instance == null)
|
||
{
|
||
lock (Locker)
|
||
{
|
||
if (_instance == null || !_instance.IsConnected)
|
||
{
|
||
_instance = GetManager();
|
||
}
|
||
}
|
||
}
|
||
return _instance;
|
||
}
|
||
}
|
||
|
||
private static ConnectionMultiplexer GetManager()
|
||
{
|
||
var connect = ConnectionMultiplexer.Connect(ConfigurationOptions);
|
||
|
||
//注册如下事件
|
||
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)
|
||
{
|
||
Console.WriteLine("Configuration changed: " + e.EndPoint);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 发生错误时
|
||
/// </summary>
|
||
/// <param name="sender"></param>
|
||
/// <param name="e"></param>
|
||
private static void MuxerErrorMessage(object sender, RedisErrorEventArgs e)
|
||
{
|
||
Console.WriteLine("ErrorMessage: " + e.Message);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 重新建立连接之前的错误
|
||
/// </summary>
|
||
/// <param name="sender"></param>
|
||
/// <param name="e"></param>
|
||
private static void MuxerConnectionRestored(object sender, ConnectionFailedEventArgs e)
|
||
{
|
||
Console.WriteLine("ConnectionRestored: " + e.EndPoint);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 连接失败 ， 如果重新连接成功你将不会收到这个通知
|
||
/// </summary>
|
||
/// <param name="sender"></param>
|
||
/// <param name="e"></param>
|
||
private static void MuxerConnectionFailed(object sender, ConnectionFailedEventArgs e)
|
||
{
|
||
Console.WriteLine("重新连接：Endpoint failed: " + e.EndPoint + ", " + e.FailureType + (e.Exception == null ? "" : (", " + e.Exception.Message)));
|
||
}
|
||
|
||
/// <summary>
|
||
/// 更改集群
|
||
/// </summary>
|
||
/// <param name="sender"></param>
|
||
/// <param name="e"></param>
|
||
private static void MuxerHashSlotMoved(object sender, HashSlotMovedEventArgs e)
|
||
{
|
||
Console.WriteLine("HashSlotMoved:NewEndPoint" + e.NewEndPoint + ", OldEndPoint" + e.OldEndPoint);
|
||
}
|
||
|
||
/// <summary>
|
||
/// redis类库错误
|
||
/// </summary>
|
||
/// <param name="sender"></param>
|
||
/// <param name="e"></param>
|
||
private static void MuxerInternalError(object sender, InternalErrorEventArgs e)
|
||
{
|
||
Console.WriteLine("InternalError:Message" + e.Exception.Message);
|
||
}
|
||
|
||
#endregion 事件
|
||
}
|
||
}
|