创建和配置 Amazon MQ 代理网络

在 Amazon MQ 控制台上，在 MyBroker2 页面的 Details (详细信息) 部分中的 Security and network (安全与网络) 下，选择您的安全组名称或 。

此时将显示 EC2 Dashboard 的 Security Groups (安全组) 页面。

从安全组列表中，选择您的安全组。

在页面底部，选择 Inbound (入站)，然后选择 Edit (编辑)。

在 Edit inbound rules (编辑入站规则) 对话框中，为 OpenWire 终端节点添加规则。

1. 选择 Add Rule（添加规则）。

2. 对于 Type (类型)，选择 Custom TCP (自定义 TCP)。

3. 对于 Port Range (端口范围)，键入 OpenWire 端口 (61617)。

4. 请执行下列操作之一：

   • 如果您想要限制访问特定 IP 地址，对于 Source (源)，请将 Custom (自定义) 选定，然后输入主机的 IP 地址 MyBroker1，然后输入 /32。（这会将 IP 地址转换为有效的 CIDR 记录）。有关更多信息，请参阅弹性网络接口。

     提示

     要检索 MyBroker1 的 IP 地址，请在 Amazon MQ 控制台上，选择代理的名称并导航到 Details (详细信息) 部分。

   • 如果所有代理都是私有的，并且属于相同的 VPC，则对于 Source (源)，请将 Custom (自定义) 选定，然后键入要编辑的安全组的 ID。

     注意

     对于公有代理，您必须使用 IP 地址限制访问。

5. 选择 Save（保存）。

   您的代理现在可以接受入站连接。

编辑代理 MyBroker1 的配置修订。

1. 在 MyBroker1 页面上，选择 Edit (编辑)。

2. 在 Edit MyBroker1 (编辑 MyBroker1) 页面上的 Configuration (配置) 部分中，选择 View (视图)。

   将会显示配置所使用的代理引擎类型和版本（例如，Apache ActiveMQ 5.15.0）。

3. 在 Configuration details 选项卡上，会显示配置修订号、描述和 XML 格式的代理配置。

4. 选择 Edit configuration (编辑配置)。

5. 在配置文件的底部，取消注释 <networkConnectors> 部分并包含以下信息：

   • 网络连接器的 name。

   • 两个代理共有的 ActiveMQ Web 控制台username。

   • 启用 duplex 连接。

   • 请执行下列操作之一：

     • 如果要将代理连接到单实例代理，请对 MyBroker2 使用 static: 前缀和 OpenWire 终端节点 uri。例如：

       <networkConnectors>
         <networkConnector name="connector_1_to_2" userName="myCommonUser" duplex="true"
           uri="static:(ssl://b-1234a5b6-78cd-901e-2fgh-3i45j6k178l9-1.mq.us-east-2.amazonaws.com:61617)"/>
       </networkConnectors>

     • 如果要将代理连接到主动/备用代理，请通过以下查询参数 ?randomize=false&maxReconnectAttempts=0 对这两个代理使用 static+failover 传输和 OpenWire 终端节点 uri。例如：

       <networkConnectors>
         <networkConnector name="connector_1_to_2" userName="myCommonUser" duplex="true"
           uri="static:(failover:(ssl://b-1234a5b6-78cd-901e-2fgh-3i45j6k178l9-1.mq.us-east-2.amazonaws.com:61617,
           ssl://b-9876l5k4-32ji-109h-8gfe-7d65c4b132a1-2.mq.us-east-2.amazonaws.com:61617)?randomize=false&amp;maxReconnectAttempts=0)"/>
       </networkConnectors>

     注意

     不要包含 ActiveMQ 用户的登录凭证。

6. 选择 Save（保存）。

7. 在 Save revision (保存修订) 对话框中，键入 Add network of brokers connector for MyBroker2。

8. 选择 Save (保存) 以保存配置的新修订。

编辑 MyBroker1 以将最新的配置修订设置为立即应用。

1. 在 MyBroker1 页面上，选择 Edit (编辑)。

2. 在 Edit MyBroker1 (编辑 MyBroker1) 页面上的 Configuration (配置) 部分中，选择 Schedule Modifications (计划修改)。

3. 在 Schedule broker modifications (计划代理修改) 部分中，选择 Immediately (立即) 应用修改。

4. 选择 Apply（应用）。

   MyBroker1 会重新启动，而且会应用您的配置修订。

将会创建代理网络。

在 Amazon MQ 控制台上，导航到 Connections (连接) 部分，记下代理 MyBroker1 的 ActiveMQ Web 控制台终端节点。

导航到代理 MyBroker1 的 ActiveMQ Web 控制台。

要验证网桥是否已连接，请选择 Network (网络)。

在 Network Bridges（网桥）部分中，MyBroker2 的名称和地址列在 Remote Broker（远程代理）和 Remote Address（远程地址）列中。

从任何可以访问代理 MyBroker2 的计算机上，创建一个使用者。例如：

activemq consumer --brokerUrl "ssl://b-1234a5b6-78cd-901e-2fgh-3i45j6k178l9-1.mq.us-east-2.amazonaws.com:61617" \
	--user commonUser \
	--password myPassword456 \
	--destination queue://MyQueue

该使用者连接到 MyBroker2 的 OpenWire 终端节点，并开始从队列 MyQueue 中使用消息。

从任何可以访问代理 MyBroker1 的计算机上，创建一个创建者并发送一些消息。例如：

activemq producer --brokerUrl "ssl://b-9876l5k4-32ji-109h-8gfe-7d65c4b132a1-1.mq.us-east-2.amazonaws.com:61617" \
	--user commonUser \
	--password myPassword456 \
	--destination queue://MyQueue \
	--persistent true \
	--messageSize 1000 \
	--messageCount 10000

该创建者连接到 MyBroker1 的 OpenWire 终端节点，并开始向队列 MyQueue 中生成持久消息。