草庐IT

redis - 在集群中选举出新的 master 时恢复连接

coder 2023-07-18 原文

我有一个包含 3 个节点的 Redis 集群； 1个是master，另外2个是slave，持有master的副本。当我杀死 master 实例时，Redis Sentinel 将另一个节点提升为 master，它开始接受写入。

在我的测试过程中，我注意到一旦提升了新的 master，Redis 中使用 SE.Redis 的第一个操作就会失败:

StackExchange.Redis.RedisConnectionException: SocketFailure on GET ---> System.IO.IOException: Unable to read data from the transport connection: An existing connection was forcibly closed by the remote host. ---> System.Net.Sockets.SocketException: An existing connection was forcibly closed by the remote host

为了避免这种情况，我实现了如下重试逻辑。有没有更好的选择？

private RedisValue RedisGet(string key)
{
    return RedisOperation(() =>
    {
        RedisKey redisKey = key;
        RedisValue redisValue = connection.StringGet(redisKey);
        return (redisValue);
    });
}

private T RedisOperation<T>(Func<T> act)
{
    int timeToSleepBeforeRetryInMiliseconds = 20;
    DateTime startTime = DateTime.Now;

    while (true)
    {
        try
        {
            return act();
        }
        catch (Exception e)
        {
            Debug.WriteLine("Failed to perform REDIS OP");

            TimeSpan passedTime = DateTime.Now - startTime;
            if (this.retryTimeout < passedTime)
            {
                Debug.WriteLine("ABORTING re-try to REDIS OP");
                throw;
            }
            else
            {
                int remainingTimeout = (int)(this.retryTimeout.TotalMilliseconds - passedTime.TotalMilliseconds);
                // if remaining time is less than 1 sec than wait only for that much time and than give a last try
                if (remainingTimeout < timeToSleepBeforeRetryInMiliseconds)
                {
                    timeToSleepBeforeRetryInMiliseconds = remainingTimeout;
                }
            }

            Debug.WriteLine("Sleeping " + timeToSleepBeforeRetryInMiliseconds + " before next try");
            System.Threading.Thread.Sleep(timeToSleepBeforeRetryInMiliseconds);
        }
    }
}

最佳答案

TLDR:不要将 Sentinel 与 Stackexchange.Redis 一起使用，因为此客户端库中仍未实现 Sentinel 支持。

参见 https://github.com/StackExchange/StackExchange.Redis/labels/sentinel对于所有 Unresolved 问题，还有一个相当不错的 PR 开放了大约 1 年。

话虽如此，我在重试方面也有相对较好的经验，但我绝不会在生产中使用这种方法，因为它根本不可靠。

关于redis - 在集群中选举出新的 master 时恢复连接，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/44554571/

举出中选timeToSleepBeforeRetryInMiliseconsectionRedisstackexchange.redis

有关redis - 在集群中选举出新的 master 时恢复连接的更多相关文章

  1. ruby - 使用 Vim Rails，您可以创建一个新的迁移文件并一次性打开它吗？ - 2

    使用带有Rails插件的vim，您可以创建一个迁移文件，然后一次性打开该文件吗？textmate也可以这样吗？ 最佳答案 你可以使用rails.vim然后做类似的事情::Rgeneratemigratonadd_foo_to_bar插件将打开迁移生成的文件，这正是您想要的。我不能代表textmate。 关于ruby-使用VimRails，您可以创建一个新的迁移文件并一次性打开它吗？，我们在StackOverflow上找到一个类似的问题： https://sta

  2. ruby - 续集在添加关联时访问many_to_many连接表 - 2

    我正在使用Sequel构建一个愿望list系统。我有一个wishlists和itemstable和一个items_wishlists连接表(该名称是续集选择的名称)。items_wishlists表还有一个用于facebookid的额外列(因此我可以存储opengraph操作)，这是一个NOTNULL列。我还有Wishlist和Item具有续集many_to_many关联的模型已建立。Wishlist类也有:selectmany_to_many关联的选项设置为select:[:items.*,:items_wishlists__facebook_action_id].有没有一种方法可以

  3. ruby - 无法在 60 秒内获得稳定的 Firefox 连接 (127.0.0.1 :7055) - 2

    我使用的是Firefox版本36.0.1和Selenium-Webdrivergem版本2.45.0。我能够创建Firefox实例，但无法使用脚本继续进行进一步的操作无法在60秒内获得稳定的Firefox连接(127.0.0.1:7055)错误。有人能帮帮我吗？ 最佳答案 我遇到了同样的问题。降级到firefoxv33后一切正常。您可以找到旧版本here 关于ruby-无法在60秒内获得稳定的Firefox连接(127.0.0.1:7055)，我们在StackOverflow上找到一个类

  4. ruby-on-rails - 如何在发布新的 Ruby 或 Rails 版本时收到通知？ - 2

    有人知道在发布新版本的Ruby和Rails时收到电子邮件的方法吗？他们有邮件列表，RubyonRails有一个推特，但我不想听到那些随之而来的喧嚣，我只想知道什么时候发布新版本，尤其是那些有安全修复的版本。 最佳答案 从therailsblog获取提要.http://weblog.rubyonrails.org/feed/atom.xml 关于ruby-on-rails-如何在发布新的Ruby或Rails版本时收到通知？，我们在StackOverflow上找到一个类似的问题：

  5. ruby - 我的 Ruby IRC 机器人没有连接到 IRC 服务器。我究竟做错了什么？ - 2

    require"socket"server="irc.rizon.net"port="6667"nick="RubyIRCBot"channel="#0x40"s=TCPSocket.open(server,port)s.print("USERTesting",0)s.print("NICK#{nick}",0)s.print("JOIN#{channel}",0)这个IRC机器人没有连接到IRC服务器，我做错了什么？ 最佳答案 失败并显示此消息::irc.shakeababy.net461*USER:Notenoughparame

  6. ruby-on-rails - 连接字符串时如何在 <%=%> block 内输出 html_safe？ - 2

    考虑一下:现在这些情况:#output:http://domain.com/?foo=1&bar=2#output:http://domain.com/?foo=1&bar=2#output:http://domain.com/?foo=1&bar=2#output:http://domain.com/?foo=1&bar=2我需要用其他字符串输出URL。我如何保证＆符号不会被转义？由于我无法控制的原因，我无法发送&。求助!把我的头发拉到这里:\编辑:为了澄清，我实际上有一个像这样的数组:@images=[{:id=>"fooid",:url=>"http://

  7. ruby - Faye WebSocket，关闭处理程序被触发后重新连接到套接字 - 2

    我有一个super简单的脚本，它几乎包含了FayeWebSocketGitHub页面上用于处理关闭连接的内容:ws=Faye::WebSocket::Client.new(url,nil,:headers=>headers)ws.on:opendo|event|p[:open]#sendpingcommand#sendtestcommand#ws.send({command:'test'}.to_json)endws.on:messagedo|event|#hereistheentrypointfordatacomingfromtheserver.pJSON.parse(event.d

  8. ruby - 需要重构为新的 Ruby 1.9 哈希语法 - 2

    这个问题在这里已经有了答案:HashsyntaxinRuby[duplicate](1个回答)关闭5年前。我有一个Recipe，其中包含以下未通过lint测试的代码:service'apache'dosupports:status=>true,:restart=>true,:reload=>trueend失败并出现错误:UsethenewRuby1.9hashsyntax.supports:status=>true,:restart=>true,:reload=>true不确定新语法是什么样的...有人可以帮忙吗？

  9. ruby - 为什么我不能从 ruby​​ 中的选定键创建新的散列？ - 2

    这个问题困扰了我一段时间。这不是一件困难的事情，但我不知道为什么没有简单的方法来做到这一点，我敢打赌有但我没有看到。我只想取一个散列，像这样:cars={:bob=>'Pontiac',:fred=>'Chrysler',:lisa=>'Cadillac',:mary=>'Jaguar'}然后做类似的事情cars[:bob,:lisa]得到{:bob=>'Pontiac',:lisa=>'Cadillac'}我这样做了，效果很好:classHashdefpick(*keys)Hash[select{|k,v|keys.include?(k)}]endendruby-1.8.7-p249

  10. ruby - 如何将新的 rvm 安装与现有的 ruby​​ 版本相关联？ - 2

    我遇到了RVM的问题，所以我卸载并重新安装了它。事实是我实际上尝试过rbenv，但这对我来说没有用，所以我试图让rvm重新启动并运行-而不必安装重复版本的Ruby。我至少安装了1个现有版本的Ruby:ruby--versionruby1.8.7(2011-12-28patchlevel357)[universal-darwin11.0]但是当我执行rvmlist时，我得到一个空白列表:bash-3.2$rvmlistrvmrubies#Defaultrubynotset.Try'rvmaliascreatedefault'.#=>-current#=*-current&&default

随机推荐