有没有一种方法可以实现基于关键字FIFO队列（如SQS消息组ID）使用RabbitMQ？我有一个具有多个使用者的系统，该系统按顺序处理来自同一组的消息，这是通过使用SQS FIFO和MessageGroupId完成的，但现在我需要转到RabbitMQ解决方案，但无法找到方法。我可以使用直接交换，它使用路由密钥入队，但我需要它是动态的，路由关键字基于内容数据。例如，我有4条消息，A1、B1、A2、C1。消息A1、B1、C1应该由使用者同时处理，但是A2应该在A1之后才处理。
5jdjgkvh1#
AMQP协议非常灵活，允许您创建队列，并在运行时使用它们自己的路由键将它们绑定到交换机。因此，您为组寻找的实际上是每个组的动态队列和特定路由键的相应绑定。请在RabbitMQ官方文档中了解更多关于此功能的信息：https://www.rabbitmq.com/tutorials/tutorial-four-java.htmlhttps://www.rabbitmq.com/tutorials/tutorial-four-spring-amqp.html
1条答案
按热度按时间5jdjgkvh1#
AMQP协议非常灵活，允许您创建队列，并在运行时使用它们自己的路由键将它们绑定到交换机。因此，您为组寻找的实际上是每个组的动态队列和特定路由键的相应绑定。
请在RabbitMQ官方文档中了解更多关于此功能的信息：
https://www.rabbitmq.com/tutorials/tutorial-four-java.html
https://www.rabbitmq.com/tutorials/tutorial-four-spring-amqp.html