本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。
# 解决 RabbitMQ 暂停队列同步的问题
在 Amazon MQ for RabbitMQ [集群部署](rabbitmq-broker-architecture.md#rabbitmq-broker-architecture-cluster)中，发布到每个队列的消息跨三个代理节点进行复制。这种复制称为*镜像*，为 RabbitMQ 代理提供高可用性（HA）。集群部署中的队列由一个节点上的*主*副本和一个或多个*镜像*组成。应用于镜像队列的每个操作（包括入队消息）首先应用于主队列，然后在其镜像之间进行复制。
例如，假设一个跨三个节点复制的镜像队列：主节点（`main`）和两个镜像（`mirror-1` 和 `mirror-2`）。如果此镜像队列中的所有消息都成功传播到所有镜像，则队列将同步。如果某个节点（`mirror-1`）在一段时间内变得不可用，则该队列仍可运行并可继续将消息排入队列。但是，对于要同步的队列，在 `mirror-1` 不可用时发布到 `main` 的消息必须复制到 `mirror-1`。
有关镜像的更多信息，请参阅 RabbitMQ 网站上的[经典镜像队列](https://www.rabbitmq.com/ha.html)。
**维护和队列同步**
在[维护时段](amazon-mq-rabbitmq-editing-broker-preferences.md#rabbitmq-edit-current-configuration-console)，Amazon MQ 每次执行一个节点的所有维护工作，以确保代理保持正常运行。因此，在每个节点恢复正常运行时，队列可能需要同步。在同步过程中，需要复制到镜像的消息将从相应的 Amazon Elastic Block Store（Amazon EBS）卷加载到内存中，以进行批处理。批处理消息可以让队列更快地同步。
如果队列保持简短且消息较少，则队列会按预期成功同步并恢复正常运行。但是，如果批处理中的数据量接近节点的内存限制，节点会引发高内存警报，暂停队列同步。您可以通过比较中的`RabbitMemUsed`和`RabbitMqMemLimit`[代理节点指标来确认内存使用情况 CloudWatch](amazon-mq-accessing-metrics.md)。在消耗或删除消息或批处理中的消息数量减少之前，同步无法完成。
**注意**
减少队列同步批处理大小可能会导致更多的复制事务。
要解决暂停的队列同步，请按照本教程中的步骤操作，其中演示了应用 `ha-sync-batch-size` 策略和重新启动队列同步的过程。
**Topics**
+ [先决条件](#rabbitmq-queue-sync-prerequisites)
+ [步骤 1：应用 `ha-sync-batch-size` 策略](#rabbitmq-queue-sync-step-1)
+ [步骤 2：重新启动队列同步](#rabbitmq-queue-sync-step-2)
+ [后续步骤](#rabbitmq-queue-sync-next-steps)
+ [相关资源](#rabbitmq-queue-sync-related-resources)
## 先决条件
在本教程中，您必须拥有具有管理员权限的 Amazon MQ for RabbitMQ 代理用户。您可以使用第一次创建代理时创建的管理员用户，也可以使用之后可能创建的其他用户。下表提供了作为正则表达式（正则表达式）模式所需的管理员用户标签和权限。
| 标签 | 读取正则表达式 | 配置正则表达式 | 写入正则表达式 |
| --- | --- | --- | --- |
| administrator | .\$1 | .\$1 | .\$1 |
有关创建 RabbitMQ 用户和管理用户标记和权限的更多信息，请参阅[Amazon MQ for RabbitMQ 代理用户](rabbitmq-simple-auth-broker-users.md#rabbitmq-basic-elements-user)。
## 步骤 1：应用 `ha-sync-batch-size` 策略
以下过程演示了如何添加适用于代理上所创建的所有队列的策略。您可以使用 RabbitMQ Web 控制台或 RabbitMQ 管理 API。有关更多信息，请参阅 RabbitMQ 网站上的[管理插件](https://www.rabbitmq.com/management.html)。
**使用 RabbitMQ Web 控制台应用 `ha-sync-batch-size` 策略**
1. 登录 [Amazon MQ 控制台](https://console.aws.amazon.com/amazon-mq/)。
1. 在左侧导航窗格中，选择 **Brokers (代理)**。
1. 从代理列表中，选择要向其应用新策略的代理的名称。
1. 在代理页面的 **Connections (连接)** 部分，选择 **RabbitMQ web console (RabbitMQ Web 控制台)** URL。RabbitMQ Web 控制台可在新的浏览器选项卡或窗口中打开。
1. 使用您的代理程序管理员的登录凭证登录 RabbitMQ Web 控制台。
1. 在 RabbitMQ Web 控制台页面顶部选择 **Admin (管理员)**。
1. 在 **Admin (管理员)** 页面的右侧导航窗格中，选择 **Policies (策略)**。
1. 在 **Policies (策略)** 页面上，您可以看到代理现有的 **User policies (用户策略)** 列表。在 **User policies (用户策略)** 下，展开 **Add / update a policy (添加/更新策略)**。
**注意**
默认情况下，Amazon MQ for RabbitMQ 集群是使用名为 `ha-all-AWS-OWNED-DO-NOT-DELETE` 的初始代理策略创建的。Amazon MQ 管理此策略，以确保代理上的每个队列都复制到所有三个节点，并且队列自动同步。
1. 要创建新的代理策略，请在 **Add / update a policy (添加/更新策略)** 下，执行以下操作：
1. 对于 **Name (名称)**，请为您的策略输入名称，例如 **batch-size-policy**。
1. 在 **Pattern (模式)** 中，输入正则表达式模式 **.\$1**，以便策略匹配代理上的所有队列。
1. 对于 **Apply to (应用于)**，从下拉列表中选择 **Exchanges and queues (交换器和队列)**。
1. 对于 **Priority (优先级)**，输入一个大于应用于虚拟主机的所有其他策略的整数。您可以在任何给定时间将一组策略定义应用于 RabbitMQ 队列和交换器。RabbitMQ 选择具有最高优先级值的匹配策略。有关策略优先级以及如何组合策略的更多信息，请参阅 RabbitMQ 服务器文档中的[策略](https://www.rabbitmq.com/parameters.html#policies)。
1. 对于 **Definition (定义)**，添加以下键/值对：
+ **ha-sync-batch-size**= *100*。 从下拉列表中选择 “**数字**”。
**注意**
您可能需要根据队列中未同步消息的数量和大小调整和校准 `ha-sync-batch-size` 的值。
+ **ha-mode**=**all**。从下拉列表中选择 **String (字符串)**。
**重要**
`ha-mode` 定义是所有与 HA 相关的策略所必需的。忽略它会导致验证失败。
+ **ha-sync-mode**=**automatic**。从下拉列表中选择 **String (字符串)**。
**注意**
`ha-sync-mode` 定义是所有自定义策略所必需的。如果省略该定义，Amazon MQ 会自动追加定义。
1. 选择 **Add / update policy (添加/更新策略)**。
1. 确认 **User policies (用户策略)** 列表中显示新策略。
**使用 RabbitMQ 管理 API 应用 `ha-sync-batch-size` 策略**
1. 登录 [Amazon MQ 控制台](https://console.aws.amazon.com/amazon-mq/)。
1. 在左侧导航窗格中，选择 **Brokers (代理)**。
1. 从代理列表中，选择要向其应用新策略的代理的名称。
1. 在代理页面的 **Connections (连接)** 部分，记下 **RabbitMQ web console (RabbitMQ Web 控制台)** URL。这是您在 HTTP 请求中使用的代理终端节点。
1. 打开您选择的新终端或命令行窗口。
1. 要创建新的代理策略，请输入以下 `curl` 命令。此命令假定默认 `/` 虚拟主机上有一个队列，该队列编码为 `%2F`。
**注意**
用您的经纪商管理员登录凭证替换*username*和*password*。您可能需要根据队列中不同步消息的数量和大小来调整和校准 `ha-sync-batch-size` (*100*) 的值。将代理终端节点替换为您之前记下的 URL。
```
curl -i -u username:password -H "content-type:application/json" -XPUT \
-d '{"pattern":".*", "priority":1, "definition":{"ha-sync-batch-size":100, "ha-mode":"all", "ha-sync-mode":"automatic"}}' \
https://b-589c045f-f8ln-4ab0-a89c-co62e1c32ef8.mq.us-west-2.amazonaws.com/api/policies/%2F/batch-size-policy
```
1. 要确认新策略已添加到您的代理的用户策略中，请输入以下 `curl` 命令以列出所有代理策略。
```
curl -i -u username:password https://b-589c045f-f8ln-4ab0-a89c-co62e1c32ef8.mq.us-west-2.amazonaws.com/api/policies
```
## 步骤 2：重新启动队列同步
将新的 `ha-sync-batch-size` 策略应用于您的代理后，重新启动队列同步。
**使用 RabbitMQ Web 控制台重新启动队列同步**
**注意**
要打开 RabbitMQ Web 控制台，请参阅本教程第 1 步中的先前说明。
1. 在 RabbitMQ Web 控制台页面顶部选择 **Queues (队列)**。
1. 在 **Queues (队列)** 页面上的 **All queues (所有队列)** 下，找到已暂停的队列。在**策略**行中，您的队列应列出您创建的新策略的名称（例如 `batch-size-policy`）。
1. 要使用减小的批处理大小重新启动同步过程，请首先取消队列同步。然后重新启动队列同步。
**注意**
如果同步暂停并且未成功完成，请尝试减少 `ha-sync-batch-size` 值并重新启动队列同步。
## 后续步骤
+ 队列成功同步后，您可以通过查看 Amazon 指标来监控 RabbitMQ 节点使用的内存量。 CloudWatch `RabbitMQMemUsed`您还可以查看 `RabbitMQMemLimit` 指标以监控节点的内存限制。有关更多信息，请参阅[访问亚马逊 MQ 的 CloudWatch 指标](amazon-mq-accessing-metrics.md)和[适用于 RabbitMQ 经纪商的亚马逊 MQ 可用 CloudWatch 指标](rabbitmq-logging-monitoring.md)。
+ 为防止队列同步暂停，建议保持队列较短并处理消息。对于消息较大的工作负载，我们还建议您将代理实例类型升级到具有更多内存的更大实例大小。有关代理实例类型和编辑代理偏好的更多信息，请参阅 [编辑代理首选项](amazon-mq-rabbitmq-editing-broker-preferences.md)。
+ 当您创建新的 Amazon MQ for RabbitMQ 时，Amazon MQ 会应用一组默认策略和虚拟主机限制来优化代理性能。如果您的代理没有建议的默认策略和限制，建议您自己创建。有关创建默认策略和虚拟主机限制的更多信息，请参阅[https://docs.aws.amazon.com//amazon-mq/latest/developer-guide/rabbitmq-defaults.html](https://docs.aws.amazon.com//amazon-mq/latest/developer-guide/rabbitmq-defaults.html)。
## 相关资源
+ [UpdateBrokerInput](https://docs.aws.amazon.com/amazon-mq/latest/api-reference/brokers-broker-id.html#brokers-broker-id-model-updatebrokerinput)— 使用此代理属性通过 Amazon MQ API 更新代理实例类型。
+ [参数和策略](https://www.rabbitmq.com/parameters.html)（RabbitMQ 服务器文档）– 在 RabbitMQ 网站上了解有关 RabbitMQ 参数和策略的更多信息。
+ [RabbitMQ 管理 HTTP API](https://pulse.mozilla.org/api/) – 了解有关 RabbitMQ 管理 API 的更多信息。