如何为RabbitMQ和Spring动态注册队列及其独占使用者/侦听器？

Question

我有以下问题需要解决：我正在尝试使用RabbitMQ消息实现一个简单的延迟重试机制。我有一个基础设施，可以延迟传递消息。我可以让任何数量的感兴趣的参与者在运行时利用这种延迟重试机制。

参与者只想向我提供2个细节和信息：1。他们希望消息在延迟T秒后传递到的队列名称。2、队列的使用者（例如消息的使用者）

我已尝试执行以下操作：

private void startSeparateListener(final Object messageConsumer, 
                                   final Queue queue) {
        SimpleMessageListenerContainer simpleMessageListenerContainer 
                    = myCustomeSimpleMessageListenerFactory.create();
        simpleMessageListenerContainer.setRabbitAdmin(rabbitAdmin);
        simpleMessageListenerContainer.setQueues(queue);
        simpleMessageListenerContainer.setMessageListener(new MessageListenerAdapter(messageConsumer));
        simpleMessageListenerContainer.start();

    }

请注意，队列已经创建并注册到rabbitadmin，并且对象使用者有一个名为handleMessage的方法来侦听队列。

这是在运行时向队列的消息使用者动态注册队列的正确方法吗？

注意：Spring已经提供了一个SimpleMessageListenerContainer类型的bean，但是使用bean动态添加队列和消费者会导致Q1的非预期消费者被调用为另一个队列的接收者的一部分，例如Q2，其内容类型可能与Q1相同？

我试着搜索了很多，但是没有得到任何具体的解释。如果这是一个重复的问题，对于任何天真，请事先道歉。

Answer 1

我无法以某种方式编译您的问题，但我可以告诉您，RabbitMQ中已经有交易的Exchange解决方案，Sring AMQP很好地支持它。

我建议不要使用动态添加的SimpleMessageListenerContainer：这并不像看起来那么简单。有一个类似于addQueueNames（）的选项：

/**
 * Add queue(s) to this container's list of queues. The existing consumers
 * will be cancelled after they have processed any pre-fetched messages and
 * new consumers will be created. The queue must exist to avoid problems when
 * restarting the consumers.
 * @param queueName The queue to add.
 */
@Override
public void addQueueNames(String... queueName) {

因此，您可以考虑不添加新容器，而是向现有容器添加新队列。amqp\U consumerQueue的下游路由可能有助于区分来自不同队列的消息。