ServiceStack.Redis.Sentinel的用法
我正在运行ServiceStack的许可版本,并尝试在Google Cloud Compute上获取哨兵群集设置。
群集基本上是GCE的即点即用Redis解决方案-3台服务器。这是我用来初始化的代码…
var hosts = Settings.Redis.Host.Split(';');var sentinel = new ServiceStack.Redis.RedisSentinel(hosts, "master");
redis = sentinel.Setup();
container.Register<IRedisClientsManager>(redis);
container.Register<ICacheClient>(redis.GetCacheClient());
客户端工作正常-
但是一旦我关闭了其中一个Redis实例,一切都会摇摇欲坠。客户端抱怨无法连接到丢失的实例。另外,即使当我备份实例时,它也处于只读模式,因此一切仍然失败。一旦处于这种状态,似乎就无法恢复…
难道我做错了什么?RedisSentinal客户端不知道新主服务器是谁的某些原因吗?我将所有3个主机IP地址都提供给它…
回答:
您应该只向Redis
Sentinel服务器的主机提供服务,RedisSentinel
因为它会从Sentinel主机获取其他主/从Redis服务器的活动列表。
RedisSentinel
最近在
中可用的最新
中对进行了一些更改,其中包括额外的日志记录和Redis Sentinel事件的回调。新的 API如下所示:
var sentinel = new RedisSentinel(sentinelHost, masterName);
启动RedisSentinel将连接到Sentinel主机,并返回一个预配置的RedisClientManager(即redis连接池),其中活动的
var redisManager = sentinel.Start();
然后,您可以使用以下方法在IOC中进行注册:
container.Register<IRedisClientsManager>(redisManager);
然后,它们RedisSentinel
应侦听Sentinel主机上的主/从更改,并相应地对
进行故障转移。然后,处置池中的现有连接,并用新池替换新配置的主机。如果再次使用该池之外的任何活动连接,它们将抛出连接异常,下次从该池中检索RedisClient时,它将使用新主机进行配置。
回调和记录
这是一个示例,说明如何使用新的回调来内省RedisServer事件:
var sentinel = new RedisSentinel(sentinelHost, masterName){
OnFailover = manager =>
{
"Redis Managers were Failed Over to new hosts".Print();
},
OnWorkerError = ex =>
{
"Worker error: {0}".Print(ex);
},
OnSentinelMessageReceived = (channel, msg) =>
{
"Received '{0}' on channel '{1}' from Sentinel".Print(channel, msg);
},
};
还可以通过在ServiceStack中配置Logging来启用这些事件的日志记录:
LogManager.LogFactory = new ConsoleLogFactory(debugEnabled:false);
还有一个附加的显式变量FailoverToSentinelHosts()
,可用于强制RedisSentinel
重新查找和故障转移到最新的主/从主机,例如:
var sentinelInfo = sentinel.FailoverToSentinelHosts();
新的主机在返回的sentinelInfo中可用:
"Failed over to read/write: {0}, read-only: {1}".Print( sentinelInfo.RedisMasters, sentinelInfo.RedisSlaves);
以上是 ServiceStack.Redis.Sentinel的用法 的全部内容, 来源链接: utcz.com/qa/425124.html