我是 rabbitmq 的新手。我正在使用 spring-amqp 来实现该功能。 正如我们所知，spring 提供@RabbitListener 来在应用程序初始化时注册一个监听器到队列中。 我想设计一个功能，当我单击某个按钮时，将创建一个新的消费者并监听指定的队列。 Java base 提供了 channel.basicConsume() 方法来消费一个队列。 spring有提供这样的功能吗？
我想像这样实现：
生产者不断向扇出交换发送消息。
当一个消费者想要加入时，调用function1 -> 创建队列并绑定到exchange -> 消费消息。
当消费者想要离开时，调用function2 -> 断开连接
【问题讨论】：
标签： rabbitmq spring-amqp
有几个选项。
使用RabbitTemplate.receive() 或convertAndReceive() 方法之一一次获取一条消息，您可以设置receiveTimeout 以防没有消息。
RabbitTemplate.execute() 带有一个回调，该回调获取一个您可以调用 basicConsume() 的频道。这是一个较低级别的选项，不会为您进行任何转换。
动态创建SimpleMessageListenerContainer（或DirectMessageListenerContainer）并根据需要启动/停止它。
...
在所有情况下，您都可以使用RabbitAdmin 创建/绑定队列，对于除选项 1 之外的所有情况，它可能会是一个自动删除队列，当消费者被取消时将被删除。使用选项 1，您必须使用非自动删除队列并使用 RabbitAdmin 将其删除。
我建议#3 是使用纯 Spring AMQP 最有效的方法。
您还可以将 Spring Integration 与入站通道适配器和发布-订阅通道一起使用；这样，您只需要一个队列（每个应用程序实例），然后为每个用户订阅一个新的MessageHandler 到频道。
【讨论】：