赞
踩
现在开发有这么一个需求:1个生产者生成消息需要被多个消费者同时消费到。
那么这个时候需要用广播的方式:
之前我们用的是通过绑定队列的方式
@RabbitListener(queues = "business_rrpc_queue")
这个时候你会发现,只有一个消费者消费到数据。
如果想让多个消费者消费到数据必须不指定queues,指定交换机
@RabbitListener(bindings = @QueueBinding(
value = @Queue(), //注意这里不要定义队列名称,系统会随机产生
exchange = @Exchange(value = "business_rrpc_exchange",type = ExchangeTypes.FANOUT)
))
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。