场景
这里只展示核心的代码，完整的代码请参见 SpringBoot整合RabbitMQ（完整版）
// 向发布订阅模式里面发送消息
public void sendPublish() {
for (int i = 0; i < 5; i++) {
// rabbitTemplate.convertSendAndReceive("exchange_fanout", "", "测试发布订阅模型：" + i);
rabbitTemplate.convertAndSend("exchange_fanout", "", "测试发布订阅模型：" + i);
}
}
测试结果
访问 http://localhost:8080/sendPublish
使用 convertAndSend 方法时的结果：输出时没有顺序，不需要等待，直接运行
image.png
使用 convertSendAndReceive 方法时的结果：使用此方法，只有确定消费者接收到消息，才会发送下一条信息，每条消息之间会有间隔时间
image.png
总结
convertSendAndReceive(…)：可以同步消费者。使用此方法，当确认了所有的消费者都接收成功之后，才触发另一个convertSendAndReceive(…)，也就是才会接收下一条消息。RPC调用方式。
convertAndSend(…)：使用此方法，交换机会马上把所有的信息都交给所有的消费者，消费者再自行处理，不会因为消费者处理慢而阻塞线程。
————————————————
版权声明：本文为CSDN博主「孔明1号」的原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接及本声明。
原文链接：https://blog.csdn.net/fan521dan/java/article/details/104930982
