RabbitMQ设计建议：将DLX消息路由回原始发布服务器

Question

Edit：基础要求是，我有多个Web服务服务器进程接收来自Web服务客户端的请求，执行一些处理（我希望使用工作队列进行的处理），然后将结果返回给相应的客户端。但是，我希望能够等待这个队列的使用者在超时内获取已发布的请求。如果此超时过期，那么我希望原始webservice进程接收到此通知，以便它能够反馈给客户机。

• 我有多个发布服务器将邮件发布到同一Exchange
• 此交换机上有多个使用者从同一队列（即'task-queues'
使用

我正在尝试实现一种“发布TTL”，如果消息是死字的，则（仅）通知原始发布者。（我希望发布者知道消息是否在某个超时内未被使用）。

• 发布消息时，每个发布服务器使用包含唯一（每个发布服务器）进程ID的路由密钥，例如发布服务器3的“thekey.pid3”
• 使用者都从同一个队列中使用，该队列使用路由密钥“thekey.#”绑定到交换机
• 在发布者声明队列时，我没有为DLX显式指定任何路由密钥--只指定'x-dead-letter-exchange'。这意味着，如果消息是死字的，那么原始路由密钥（即'thekey.pid3')将传递到DLX。
• 每个发布服务器使用其特定的路由密钥（例如'thekey.pid3'
将其自己的新使用者队列绑定到DLX

这就解决了我的需求，因为只有发布消息的发布服务器才会将DLX消息路由到它。

然而，这似乎有点复杂--而且效率很低，因为通配符路由会对所有消息进行（除了那些没有字母的消息--这通常不应该发生）。

下面是我的设计图：

谢谢！

Answer 1

对，结果证明这个解决方案是有效的。当使用通配符绑定键和主题交换时，可能会有一个很小的延迟，但可能没有什么需要自己真正关心的。

邮件列表中的一个评论是，由于这是一个基于RPC的系统，每个发布者都已经定义了一个唯一的响应队列，因此可以将该队列绑定到DLX（而不是为每个发布者创建一个新的唯一队列），从而获得“有效”响应和被丢弃的消息。

在我的例子中，我想在一个通用的发布服务器中包装这个“发布TTL”功能，所以引用响应队列没有意义--尽管我的解决方案的效率可能略低，因为在出现死信的情况下会多一次往返。

如果您对Rabbit的人用于主题路由的机制感兴趣，可以访问：http://www.rabbitmq.com/blog/2010/09/14/very-fast-and-scalable-topic-routing-part-1/http://www.rabbitmq.com/blog/2011/03/28/very-fast-and-scalable-topic-routing-part-2//