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

版权声明:本文为weixin_37624195原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。