第 10 章 检测重复消息
您可以将代理配置为自动检测和过滤重复的消息。这意味着您不必实施自己的重复检测逻辑。
如果没有重复检测，当意外连接失败时，客户端无法确定它发送到代理的消息是否收到。在这种情况下，客户端可能会假设代理没有收到消息，并重新发送它。这会生成重复的消息。
例如，假设客户端向代理发送消息。如果在代理接收和 由代理处理消息前 代理或连接失败，则消息永远不会到达其地址。由于失败，客户端不会从代理接收响应。如果在代理接收和处理消息 后 代理或连接失败，则消息会正确路由，但客户端仍然不会收到响应。
此外，使用事务来确定成功并不一定帮助。如果在处理事务提交时代理或连接失败，客户端仍然无法确定它是否已成功发送消息。
在这些情况下，为了更正假定的失败，客户端会重新发送最新的消息。结果可能是对您的系统有负面影响的重复消息。例如，如果您在一个订购系统中使用代理，则重复消息可能意味着处理购买顺序两次。
以下流程演示了如何配置重复消息检测以防止这些类型的情况。
10.1. 配置重复的 ID 缓存
要让代理检测重复消息，生成者必须在发送每个消息时为消息属性 _AMQ_DUPL_ID 提供唯一值。代理维护 _AMQ_DUPL_ID 属性收到的值的缓存。当代理在地址上收到新消息时，它会检查该地址的缓存，以确保之前没有为此属性处理具有相同值的消息。
每个地址都有自己的缓存。每个缓存都是循环并固定大小。这意味着新条目将最旧的条目替换为缓存空间需求。
以下流程演示了如何全局配置代理上每个地址使用的 ID 缓存。
流程
-
打开 &
lt;broker_instance_dir> /etc/broker.xml配置文件。 在
core元素中，添加id-cache-size和persist-id-cache属性并指定值。例如：<configuration> <core> ... <id-cache-size>5000</id-cache-size> <persist-id-cache>false</persist-id-cache> </core> </configuration>id-cache-sizeID 缓存的最大大小，指定为缓存中单个条目的数量。默认值为 20,000 个条目。在本例中，缓存大小被设置为 5,000 个条目。
注意当达到最大缓存大小时，代理可以开始处理重复消息。例如，假设您将缓存的大小设置为
3000。如果以前的消息在与_AMQ_DUPL_ID的值相同的新消息之前到达 3,000 条消息，则代理无法检测到重复的消息。这会导致代理处理这两个消息。persist-id-cache-
当此属性的值设为
true时，代理会在接收时将 ID 保留为磁盘。默认值为true。在上例中，您可以通过将值设为false来禁用持久性。
其他资源
- 要了解如何使用 AMQ Core Protocol JMS 客户端设置重复的 ID 消息属性，请参阅 AMQ Core Protocol JMS 客户端 文档中的使用重复消息检测。
