14.2. 创建代理集群
您可以通过在应参与集群的每个代理上配置集群连接来创建代理集群。集群连接定义代理应如何连接到其他代理。
您可以创建一个使用静态发现或动态发现的代理集群(UDP 多播或 JGroups)。
先决条件
您应该已确定代理集群的大小。
更多信息请参阅 第 14.1.7 节 “集群大小注意事项”。
14.2.1. 使用静态发现创建代理集群
您可以通过指定静态代理列表来创建代理集群。如果您无法对网络使用 UDP 多播或 JGroups,请使用此静态发现方法。
流程
-
打开 &
lt;broker_instance_dir> /etc/broker.xml
配置文件。 在 <
;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>
有关连接器的更多信息,请参阅 第 2.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
- 此代理可以使用的一个或多个连接器来与集群中的另一个代理进行初始连接。进行此初始连接后,代理将发现集群中的其他代理。只有集群使用静态发现时,您只需要配置此属性。
配置集群连接的任何其他属性。
这些额外集群连接属性具有适合大多数常见用例的默认值。因此,如果您不希望默认行为,您只需要配置这些属性。更多信息请参阅 附录 C, 集群连接配置元素。
创建集群用户和密码。
AMQ Broker 附带默认集群凭证,但您应该更改它们,以防止未经授权的远程客户端使用这些默认凭证来连接到代理。
重要集群密码在集群的每个代理中必须相同。
<configuration> <core> ... <cluster-user>cluster_user</cluster-user> <cluster-password>cluster_user_password</cluster-password> ... </core> </configuration>
在每个额外代理中重复此步骤。
您可以将集群配置复制到每个额外代理中。但是,不要复制任何其他 AMQ Broker 数据文件(如绑定、日志和大型消息目录)。这些文件在集群中的节点之间必须是唯一的,或者集群无法正确组成。
其他资源
-
有关使用静态发现的代理集群示例,请参阅
clustered-static-discovery
示例。
14.2.2. 使用基于 UDP 的动态发现创建代理集群
您可以创建一个代理集群,代理通过 UDP 多播相互动态发现。
流程
-
打开 &
lt;broker_instance_dir> /etc/broker.xml
配置文件。 在 <
;core>
; 元素中,添加连接器。这个连接器定义了其他代理可以用来连接这个连接的连接信息。此信息将在发现过程中发送到集群中的其他代理。
<configuration> <core> ... <connectors> <connector name="netty-connector">tcp://localhost:61617</connector> </connectors> ... </core> </configuration>
添加 UDP 广播组。
broadcast 组可让代理将集群连接的信息推送到集群中的其他代理。这个广播组使用 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
- 以前配置应该广播的集群连接器。
添加 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
属性为发现组指定唯一名称。 local-bind-address
(可选)- 如果运行代理的机器使用多个网络接口,您可以指定发现组应侦听的网络接口。这是特定于 UDP 的属性。
group-address
-
要侦听的组的多播地址。它应该与您要从中侦听的广播组中的
group-address
匹配。这是特定于 UDP 的属性。 group-port
-
多播组的 UDP 端口号。它应该与您要从中侦听的广播组中的
group-port
匹配。这是特定于 UDP 的属性。 refresh-timeout
(可选)从特定代理中删除该代理的连接器对条目前,发现组从特定代理接收最后一次广播后等待的时间(以毫秒为单位)。默认值为 10000 毫秒(10 秒)。
把它设置为高于广播组上的
broadcast-period
的值。否则,代理可能会定期从列表中消失,即使它们仍然被广播(因为时间略有差异)。
创建集群连接并将其配置为使用动态发现。
默认情况下,集群连接将对对称拓扑中所有地址加载平衡消息。
<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
- 此代理应使用的发现组来定位集群的其他成员。只有集群使用动态发现功能时,您只需要配置此属性。
配置集群连接的任何其他属性。
这些额外集群连接属性具有适合大多数常见用例的默认值。因此,如果您不希望默认行为,您只需要配置这些属性。更多信息请参阅 附录 C, 集群连接配置元素。
创建集群用户和密码。
AMQ Broker 附带默认集群凭证,但您应该更改它们,以防止未经授权的远程客户端使用这些默认凭证来连接到代理。
重要集群密码在集群的每个代理中必须相同。
<configuration> <core> ... <cluster-user>cluster_user</cluster-user> <cluster-password>cluster_user_password</cluster-password> ... </core> </configuration>
在每个额外代理中重复此步骤。
您可以将集群配置复制到每个额外代理中。但是,不要复制任何其他 AMQ Broker 数据文件(如绑定、日志和大型消息目录)。这些文件在集群中的节点之间必须是唯一的,或者集群无法正确组成。
其他资源
-
有关使用 UDP 动态发现的代理集群配置示例,请查看
clustered-queue
示例。
14.2.3. 使用基于 JGroups 的动态发现创建代理集群
如果您已在您的环境中使用 JGroups,您可以使用它创建一个代理集群,代理器可以动态发现其他代理集群。
先决条件
必须安装并配置 JGroups。
有关 JGroups 配置文件的示例,请参阅
clustered-jgroups
示例。
流程
-
打开 &
lt;broker_instance_dir> /etc/broker.xml
配置文件。 在 <
;core>
; 元素中,添加连接器。这个连接器定义了其他代理可以用来连接这个连接的连接信息。此信息将在发现过程中发送到集群中的其他代理。
<configuration> <core> ... <connectors> <connector name="netty-connector">tcp://localhost:61617</connector> </connectors> ... </core> </configuration>
在 <
;core>
; 元素内,添加 JGroups 广播组。broadcast 组可让代理将集群连接的信息推送到集群中的其他代理。这个广播组使用 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
- 以前配置应该广播的集群连接器。
添加 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
属性为发现组指定唯一名称。 JGroups-file
- 用于初始化 JGroups 通道的 JGroups 配置文件的名称。该文件必须位于 Java 资源路径中,以便代理可以加载它。
jgroups-channel
- 用于接收广播的 JGroups 通道的名称。
refresh-timeout
(可选)从特定代理中删除该代理的连接器对条目前,发现组从特定代理接收最后一次广播后等待的时间(以毫秒为单位)。默认值为 10000 毫秒(10 秒)。
把它设置为高于广播组上的
broadcast-period
的值。否则,代理可能会定期从列表中消失,即使它们仍然被广播(因为时间略有差异)。
创建集群连接并将其配置为使用动态发现。
默认情况下,集群连接将对对称拓扑中所有地址加载平衡消息。
<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
- 此代理应使用的发现组来定位集群的其他成员。只有集群使用动态发现功能时,您只需要配置此属性。
配置集群连接的任何其他属性。
这些额外集群连接属性具有适合大多数常见用例的默认值。因此,如果您不希望默认行为,您只需要配置这些属性。更多信息请参阅 附录 C, 集群连接配置元素。
创建集群用户和密码。
AMQ Broker 附带默认集群凭证,但您应该更改它们,以防止未经授权的远程客户端使用这些默认凭证来连接到代理。
重要集群密码在集群的每个代理中必须相同。
<configuration> <core> ... <cluster-user>cluster_user</cluster-user> <cluster-password>cluster_user_password</cluster-password> ... </core> </configuration>
在每个额外代理中重复此步骤。
您可以将集群配置复制到每个额外代理中。但是,不要复制任何其他 AMQ Broker 数据文件(如绑定、日志和大型消息目录)。这些文件在集群中的节点之间必须是唯一的,或者集群无法正确组成。
其他资源
- 有关通过 JGroups 使用动态发现的代理集群示例,请参阅 clustered-jgroups 示例。