支持控制台（Console）开发人员开始试用联系人

14.2. 创建代理集群

您可以通过在应该参与集群中的每个代理上配置集群连接来创建代理集群。集群连接定义代理应该如何连接到其他代理。

您可以创建一个使用静态发现或动态发现的代理集群(UDP 多播或 JGroups)。

先决条件

14.2.1. 使用静态发现创建代理集群

您可以通过指定代理的静态列表来创建代理集群。如果您无法在网络上使用 UDP 多播或 JGroups，请使用这个静态发现方法。

流程

  1. 打开 & lt;broker_instance_dir> /etc/broker.xml 配置文件。

  2. 在 &lt ;core& gt; 元素中添加以下连接器：

    • 定义其他代理如何连接这个连接器
    • 定义此代理如何连接到集群中的其他代理的一个或多个连接器 
    <configuration>
    <core>
        ...
        <connectors>
            <connector name="netty-connector">tcp://localhost:61617</connector>  1
            <connector name="broker2">tcp://localhost:61618</connector>  2
            <connector name="broker3">tcp://localhost:61619</connector>
        </connectors>
        ...
    </core>
</configuration>
    1
    此连接器定义其他代理可用于连接到此连接的连接信息。此信息将在发现过程中发送到集群中的其他代理。
    2
    broker2 和 broker3 连接器定义此代理如何连接到集群中的两个其他代理，其中一个代理始终可用。如果集群中存在其他代理，则在进行初始连接时，这些连接器将发现它们。

    有关连接器的详情请参考 第 2.3 节 “关于连接器”。

  3. 添加集群连接并将其配置为使用静态发现。

    默认情况下，集群连接将为对称拓扑中的所有地址负载平衡消息。 

    <configuration>
    <core>
        ...
        <cluster-connections>
            <cluster-connection name="my-cluster">
                <connector-ref>netty-connector</connector-ref>
                <static-connectors>
                    <connector-ref>broker2-connector</connector-ref>
                    <connector-ref>broker3-connector</connector-ref>
                </static-connectors>
            </cluster-connection>
        </cluster-connections>
        ...
    </core>
</configuration>
    cluster-connection
    使用 name 属性指定集群连接的名称。
    connector-ref
    定义其他代理如何连接这个连接器的连接器。
    static-connectors
    此代理可用于向集群中的另一个代理进行初始连接的一个或多个连接器。完成此初始连接后，代理将发现集群中的其他代理。只有集群使用静态发现时，您只需要配置此属性。

  4. 为集群连接配置任何其他属性。

    这些额外的集群连接属性具有适合大多数常见用例的默认值。因此，如果您不希望默认行为，您只需要配置这些属性。更多信息请参阅 附录 C, 集群连接配置元素。

  5. 创建集群用户和密码。

    AMQ Broker 附带默认集群凭证，但您应该更改它们以防止未授权的远程客户端使用这些默认凭证来连接代理。

    重要

    在集群的每个代理中，集群密码必须相同。 

    <configuration>
    <core>
        ...
        <cluster-user>cluster_user</cluster-user>
        <cluster-password>cluster_user_password</cluster-password>
        ...
    </core>
</configuration>

  6. 在每个附加代理上重复此步骤。

    您可以将集群配置复制到每个额外代理。但是，不要复制任何其他 AMQ Broker 数据文件（如绑定、日志和大型消息目录）。这些文件在集群节点间必须是唯一的，否则集群不会被正确组成。

其他资源

14.2.2. 使用基于 UDP 的动态发现创建代理集群

您可以创建一个代理集群，代理通过 UDP 多播动态发现它们。

流程

  1. 打开 & lt;broker_instance_dir&gt; /etc/broker.xml 配置文件。

  2. 在 &lt ;core&gt; 元素中，添加一个连接器。

    此连接器定义其他代理可用于连接到此连接的连接信息。此信息将在发现过程中发送到集群中的其他代理。 

    <configuration>
    <core>
        ...
        <connectors>
            <connector name="netty-connector">tcp://localhost:61617</connector>
        </connectors>
        ...
    </core>
</configuration>

  3. 添加 UDP 广播组。

    广播组可让代理将集群连接的信息推送到集群中的其他代理。这个广播组使用 UDP 来广播连接设置： 

    <configuration>
    <core>
        ...
        <broadcast-groups>
            <broadcast-group name="my-broadcast-group">
                <local-bind-address>172.16.9.3</local-bind-address>
                <local-bind-port>-1</local-bind-port>
                <group-address>231.7.7.7</group-address>
                <group-port>9876</group-port>
                <broadcast-period>2000</broadcast-period>
                <connector-ref>netty-connector</connector-ref>
            </broadcast-group>
        </broadcast-groups>
        ...
    </core>
</configuration>

    除非另有说明，否则需要以下参数：

    broadcast-group
    使用 name 属性为广播组指定唯一名称。
    local-bind-address
    UDP 套接字绑定到的地址。如果您的代理中有多个网络接口，您应该指定要用于广播的接口。如果没有指定此属性，套接字将绑定到操作系统选择的 IP 地址。这是一个特定于 UDP 的属性。
    local-bind-port
    数据报套接字绑定到的端口。在大多数情况下，使用默认值 -1，它指定一个匿名端口。这个参数用于与 local-bind-address 连接。这是一个特定于 UDP 的属性。
    group-address
    数据要广播的多播地址。它是 224.0.0.0 - 239.255.255.255 中包含的类 D IP 地址。地址 224.0.0.0 被保留，不可用。这是一个特定于 UDP 的属性。
    group-port
    用于广播的 UDP 端口号。这是一个特定于 UDP 的属性。
    broadcast-period （可选）
    连续广播之间的间隔（毫秒）。默认值为 2000 毫秒。
    connector-ref
    之前配置的集群连接器应该广播。

  4. 添加 UDP 发现组。

    发现组定义此代理如何从其他代理接收连接器信息。代理维护了一个连接器列表（每个代理有一个条目）。从代理接收广播时，它会更新其条目。如果它没有从代理接收广播，它会删除该条目。

    此发现组使用 UDP 来发现集群中的代理： 

    <configuration>
    <core>
        ...
        <discovery-groups>
            <discovery-group name="my-discovery-group">
                <local-bind-address>172.16.9.7</local-bind-address>
                <group-address>231.7.7.7</group-address>
                <group-port>9876</group-port>
                <refresh-timeout>10000</refresh-timeout>
            </discovery-group>
        <discovery-groups>
        ...
    </core>
</configuration>

    除非另有说明，否则需要以下参数：

    discovery-group
    使用 name 属性为 discovery 组指定唯一名称。
    local-bind-address （可选）
    如果运行代理的机器使用多个网络接口，您可以指定发现组应侦听的网络接口。这是一个特定于 UDP 的属性。
    group-address
    要侦听的组多播地址。它应该与您要从中侦听的广播组中的 group-address 匹配。这是一个特定于 UDP 的属性。
    group-port
    多播组的 UDP 端口号。它应该与您要从中侦听的广播组中的 group-port 匹配。这是一个特定于 UDP 的属性。
    refresh-timeout （可选）

    发现组在从特定代理接收最后一次广播后等待的时间（毫秒），然后再从其列表中删除该代理的连接器对条目。默认值为 10000 毫秒(10 秒)。

    把它设置为比广播组中的 broadcast-period 更高的值。否则，代理可能会定期从列表中消失，即使它们仍在广播（由于时间差异）。

  5. 创建集群连接并将其配置为使用动态发现。

    默认情况下，集群连接将为对称拓扑中的所有地址负载平衡消息。 

    <configuration>
    <core>
        ...
        <cluster-connections>
            <cluster-connection name="my-cluster">
                <connector-ref>netty-connector</connector-ref>
                <discovery-group-ref discovery-group-name="my-discovery-group"/>
            </cluster-connection>
        </cluster-connections>
        ...
    </core>
</configuration>
    cluster-connection
    使用 name 属性指定集群连接的名称。
    connector-ref
    定义其他代理如何连接这个连接器的连接器。
    discovery-group-ref
    此代理应该用来定位集群其他成员的发现组。只有集群使用动态发现时，您只需要配置此属性。

  6. 为集群连接配置任何其他属性。

    这些额外的集群连接属性具有适合大多数常见用例的默认值。因此，如果您不希望默认行为，您只需要配置这些属性。更多信息请参阅 附录 C, 集群连接配置元素。

  7. 创建集群用户和密码。

    AMQ Broker 附带默认集群凭证，但您应该更改它们以防止未授权的远程客户端使用这些默认凭证来连接代理。

    重要

    在集群的每个代理中，集群密码必须相同。 

    <configuration>
    <core>
        ...
        <cluster-user>cluster_user</cluster-user>
        <cluster-password>cluster_user_password</cluster-password>
        ...
    </core>
</configuration>

  8. 在每个附加代理上重复此步骤。

    您可以将集群配置复制到每个额外代理。但是，不要复制任何其他 AMQ Broker 数据文件（如绑定、日志和大型消息目录）。这些文件在集群节点间必须是唯一的，否则集群不会被正确组成。

其他资源

14.2.3. 使用基于 JGroups 的动态发现创建代理集群

如果环境中已在环境中使用 JGroups，则可以使用它创建一个代理集群，代理会动态发现它们。

先决条件

流程

  1. 打开 & lt;broker_instance_dir&gt; /etc/broker.xml 配置文件。

  2. 在 &lt ;core&gt; 元素中，添加一个连接器。

    此连接器定义其他代理可用于连接到此连接的连接信息。此信息将在发现过程中发送到集群中的其他代理。 

    <configuration>
    <core>
        ...
        <connectors>
            <connector name="netty-connector">tcp://localhost:61617</connector>
        </connectors>
        ...
    </core>
</configuration>

  3. 在 &lt ;core& gt; 元素中，添加一个 JGroups 广播组。

    广播组可让代理将集群连接的信息推送到集群中的其他代理。这个广播组使用 JGroups 来广播连接设置： 

    <configuration>
    <core>
        ...
        <broadcast-groups>
            <broadcast-group name="my-broadcast-group">
                <jgroups-file>test-jgroups-file_ping.xml</jgroups-file>
                <jgroups-channel>activemq_broadcast_channel</jgroups-channel>
                <broadcast-period>2000</broadcast-period>
                <connector-ref>netty-connector</connector-ref>
            </broadcast-group>
        </broadcast-groups>
        ...
    </core>
</configuration>

    除非另有说明，否则需要以下参数：

    broadcast-group
    使用 name 属性为广播组指定唯一名称。
    JGroups-file
    用于初始化 JGroups 频道的 JGroups 配置文件的名称。该文件必须位于 Java 资源路径中，以便代理可以加载它。
    jgroups-channel
    用于广播的 JGroups 频道的名称。
    broadcast-period （可选）
    连续广播之间的间隔（毫秒）。默认值为 2000 毫秒。
    connector-ref
    之前配置的集群连接器应该广播。

  4. 添加 JGroups 发现组。

    发现组定义了如何接收连接器信息。代理维护了一个连接器列表（每个代理有一个条目）。从代理接收广播时，它会更新其条目。如果它没有从代理接收广播，它会删除该条目。

    此发现组使用 JGroups 来发现集群中的代理： 

    <configuration>
    <core>
        ...
        <discovery-groups>
            <discovery-group name="my-discovery-group">
                <jgroups-file>test-jgroups-file_ping.xml</jgroups-file>
                <jgroups-channel>activemq_broadcast_channel</jgroups-channel>
                <refresh-timeout>10000</refresh-timeout>
            </discovery-group>
        <discovery-groups>
        ...
    </core>
</configuration>

    除非另有说明，否则需要以下参数：

    discovery-group
    使用 name 属性为 discovery 组指定唯一名称。
    JGroups-file
    用于初始化 JGroups 频道的 JGroups 配置文件的名称。该文件必须位于 Java 资源路径中，以便代理可以加载它。
    jgroups-channel
    用于接收广播的 JGroups 频道的名称。
    refresh-timeout （可选）

    发现组在从特定代理接收最后一次广播后等待的时间（毫秒），然后再从其列表中删除该代理的连接器对条目。默认值为 10000 毫秒(10 秒)。

    把它设置为比广播组中的 broadcast-period 更高的值。否则，代理可能会定期从列表中消失，即使它们仍在广播（由于时间差异）。

  5. 创建集群连接并将其配置为使用动态发现。

    默认情况下，集群连接将为对称拓扑中的所有地址负载平衡消息。 

    <configuration>
    <core>
        ...
        <cluster-connections>
            <cluster-connection name="my-cluster">
                <connector-ref>netty-connector</connector-ref>
                <discovery-group-ref discovery-group-name="my-discovery-group"/>
            </cluster-connection>
        </cluster-connections>
        ...
    </core>
</configuration>
    cluster-connection
    使用 name 属性指定集群连接的名称。
    connector-ref
    定义其他代理如何连接这个连接器的连接器。
    discovery-group-ref
    此代理应该用来定位集群其他成员的发现组。只有集群使用动态发现时，您只需要配置此属性。

  6. 为集群连接配置任何其他属性。

    这些额外的集群连接属性具有适合大多数常见用例的默认值。因此，如果您不希望默认行为，您只需要配置这些属性。更多信息请参阅 附录 C, 集群连接配置元素。

  7. 创建集群用户和密码。

    AMQ Broker 附带默认集群凭证，但您应该更改它们以防止未授权的远程客户端使用这些默认凭证来连接代理。

    重要

    在集群的每个代理中，集群密码必须相同。 

    <configuration>
    <core>
        ...
        <cluster-user>cluster_user</cluster-user>
        <cluster-password>cluster_user_password</cluster-password>
        ...
    </core>
</configuration>

  8. 在每个附加代理上重复此步骤。

    您可以将集群配置复制到每个额外代理。但是，不要复制任何其他 AMQ Broker 数据文件（如绑定、日志和大型消息目录）。这些文件在集群节点间必须是唯一的，否则集群不会被正确组成。

其他资源

Red Hat logoGithubRedditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务，以及可以信赖的内容，帮助红帽用户创新并实现他们的目标。

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情，请参阅红帽博客.

關於紅帽

我们提供强化的解决方案，使企业能够更轻松地跨平台和环境（从核心数据中心到网络边缘）工作。

© 2024 Red Hat, Inc.