第 12 章 分离消息和分割消息流
在 AMQ Broker 中,您可以配置名为 diverts 的对象,可让您透明地将消息从一个地址分离到另一个地址,而无需更改任何客户端应用程序逻辑。您还可以配置一个 divert,将消息 的副本 转发到指定的转发地址,从而有效地分割消息流。
12.1. message diverts 如何工作
通过 diverts,您可以透明地将路由到一个地址的消息重定向到其他地址,而无需更改任何客户端应用程序逻辑。将代理服务器上的一组 diverts 视为消息的路由表类型。
The divert can is exclusive, 表示将消息定向到指定的转发地址,而无需转至其原始地址。
探测器也可以是 非独占 的,这意味着消息将继续进入其原始地址,而代理会将消息副本发送到指定的转发地址。因此,您可以使用非独占分离来分割消息流。例如,如果要单独监控发送到一个订购队列的每个顺序,您可以分割消息流。
可以为单个地址配置多个 diverts。当地址同时配置了 exclusive 和 non-exclusive diverts 时,代理会首先处理 exclusive diverts。如果特定消息已被一个 exclusive divert 处理,则代理不会处理该消息的任何非排除分离器。在这种情况下,消息永远不会进入原始地址。
当代理过滤消息时,代理会分配一个新的消息 ID,并将消息地址设置为新的转发地址。您可以通过 _AMQ_ORIG_ADDRESS
(字符串类型)和 _AMQ_ORIG_MESSAGE_ID
(长类型)消息属性来检索原始消息 ID 和地址值。如果您使用 Core API,请使用 Message.HDR_ORIGINAL_ADDRESS
和 Message.HDR_ORIG_MESSAGE_ID
属性。
您只能将消息定向到同一代理服务器上的地址。如果您要将一个不同服务器上的地址分解到不同服务器上的地址,则常见的解决方案是首先将消息分解为本地 store-and-forward 队列。然后,设置从那个队列消耗的网桥,并将消息转发到不同代理上的地址。通过将分离与网桥相结合,您可以在地理分布的代理服务器之间创建分布式路由连接网络。这样,您可以创建一个全局消息传递网格。