我有一个聊天应用程序,它使用RabbitMQ进行服务器之间的通信。我使用ConsistentHashExchange来确保某个特定用户的一条消息将进入同一个队列。对于一个队列,该队列最多有一个使用者,这意味着每个使用者将创建自己的唯一队列(自动删除)并将新创建的队列绑定到一致性散列交换。问题是当没有使用者时,将没有绑定到交换的队列,这意味着消息丢失。我的第一个想法是创建一个队列,在发送到其他队列之前充当“缓冲区”。这可能吗?或者有更好的方法来处理这个问题吗?
3yhwsihp1#
请参阅此文档,其中解释了RabbitMQ如何处理不可路由的消息:https://www.rabbitmq.com/publishers.html#unroutable听起来Alternate Exchange对您来说是个不错的选择。
**注意:**RabbitMQ团队监控rabbitmq-users邮件列表,仅在某些时候回答StackOverflow上的问题。
rabbitmq-users
1条答案
按热度按时间3yhwsihp1#
请参阅此文档,其中解释了RabbitMQ如何处理不可路由的消息:
https://www.rabbitmq.com/publishers.html#unroutable
听起来Alternate Exchange对您来说是个不错的选择。
**注意:**RabbitMQ团队监控
rabbitmq-users
邮件列表,仅在某些时候回答StackOverflow上的问题。