RabbitMQ学习之广播模式(一对多)

发布时间 2023-08-21 16:47:08作者: Zzzz/

步骤分三步

第一步:声明交换机,队列,将两者绑定

创建配置类,引入configuration注解表示为配置类

使用bean将创建的构造方法注入容器,返回值为交换机名称,和队列名称

 然后将队列绑定到交换机使用binding方法

 第二步:消息发送

在publisher的test测试类中编辑发送内容仍然使用rabbitcomplete调用方法来调用交换机和massage

 第三步:接收消息

在consumer项目的SpringAmqpConsumer类中使用@Rabbitrun注解引入需要接收的消息队列将消息引入创建的字段中然后输出即可