大致流程，有一个队列绑定到一个直连交换机上，同时赋予一个路由键 routing key 。这个交换机在接收到消息后，会直接转发到绑定到它上面的所有队列。本次实例教程需要创建2个springboot项目，一个 rabbitmq-provider （生产者），一个rabbitmq-consumer（消费者）。可以看到是实现了轮询的方式对消息进行消费，而且不存在重复消费。接下来调用接口/sendTopicMessage2:然后看消费者rabbitmq-consumer的控制台输出情况：所以可以看到两个监听消费者只有TopicTotalReceiver成功消费到了消息。接下来是使用Fanout Exchang 扇型交换机。
暂无评论