我是rabbitmq的新手。我正在使用spring-amqp来实现该功能。我们知道spring提供了@RabbitListener来在应用程序初始化时注册一个监听器到队列中。我想设计一个功能,当我单击某个按钮时,将创建一个新的消费者并监听指定的队列。Java基础提供channel.basicConsume()方法来消费队列。spring有提供这样的功能吗?
我想实现如下:
生产者不断向扇出交换器发送消息。当消费者想要加入时,调用 function1 -> 创建队列并绑定到交换 -> 消费消息。
当消费者想要离开时,调用 function2 -> disconnect