zoukankan      html  css  js  c++  java
  • 16,EasyNetQ-群集支持

    EasyNetQ支持RabbitMQ群集,无需部署负载均衡器。

    只需在连接字符串中列出群集的节点...

    var bus = RabbitHutch.CreateBus("host=ubuntu:5672,ubuntu:5673");

    在这个例子中,我们在一台机器上建立了一个集群'ubuntu',端口5672上的节点1和端口5673上的节点2上。当CreateBus语句执行时,EasyNetQ将尝试连接到列出的第一台主机(ubuntu:5672)。 如果连接失败,它会尝试连接到列出的第二台主机(ubuntu:5673)。 如果两个节点都不可用,则它将位于重试循环中,每五秒钟尝试连接两台服务器。 它将所有这些活动记录到注册的IEasyNetQLogger。 如果第一个节点不可用,您可能会看到类似这样的内容:

    DEBUG: Trying to connect
    ERROR: Failed to connect to Broker: 'ubuntu', Port: 5672 VHost: '/'. ExceptionMessage: 'None of the specified endpoints were reachable'
    DEBUG: OnConnected event fired
    INFO: Connected to RabbitMQ. Broker: 'ubuntu', Port: 5674, VHost: '/'

    如果EasyNetQ连接的节点发生故障,EasyNetQ将尝试连接到下一个列出的节点。 一旦连接,它将重新申报所有交易所和队列,并重新启动所有消费者。 以下是一个示例日志记录,显示一个节点出现故障,然后EasyNetQ连接到另一个节点并重新创建订户:

    INFO: Disconnected from RabbitMQ Broker
    DEBUG: Trying to connect
    DEBUG: OnConnected event fired
    DEBUG: Re-creating subscribers
    INFO: Connected to RabbitMQ. Broker: 'ubuntu', Port: 5674, VHost: '/'

    1,随机主机选择

    如果您有多个使用EasyNetQ连接到RabbitMQ群集的服务,它们将首先连接到其各自连接字符串中的第一个列出的节点。 如果您打算使用负载平衡功能,则应考虑切换到RandomClusterHostSelectionStrategy。 像这样配置它:

    var bus = RabbitHutch.CreateBus("host=myfirsthost,mysecondhost", x => x.Register<IClusterHostSelectionStrategy<ConnectionFactoryInfo>, RandomClusterHostSelectionStrategy<ConnectionFactoryInfo>>());

    在这个片段中,我们已经替换了RandomClusterHostSelectionStrategy的默认IClusterHostSelectionStrategy,它将随机选择主机。 您可以在这里找到更多有关替换EasyNetQ组件的信息。

    2,考虑使用专用的负载平衡器

    EasyNetQ集群支持的替代方案是使用专用的前端代理。 有关详细信息,请参阅RabbitMQ集群指南的结尾:http://www.rabbitmq.com/clustering.html

  • 相关阅读:
    【NOIP2007】守望者的逃离
    20200321(ABC)题解 by 马鸿儒 孙晨曦
    20200320(ABC)题解 by 王一帆
    20200319(ABC)题解 by 王一帆 梁延杰 丁智辰
    20200314(ABC)题解 by 董国梁 蒋丽君 章思航
    20200309(ABC)题解 by 梁延杰
    20200307(DEF)题解 by 孙晨曦
    20200306(ABC)题解 by 孙晨曦
    20200305(DEF)题解 by 孙晨曦
    20200303(ABC)题解 by 王锐,董国梁
  • 原文地址:https://www.cnblogs.com/zd1994/p/8652407.html
Copyright © 2011-2022 走看看