Fanout模式，即广播模式，一个发送到交换机的消息会被转发到与该交换机绑定的所有队列上。

一、Provider

配置文件

11 spring.application.name=provider
22 spring.rabbitmq.host=192.168.50.30
33 spring.rabbitmq.port=5672
44 spring.rabbitmq.username=rabbit
55 spring.rabbitmq.password=rabbit
66 #设置交换器的名称
77 mq.config.exchange=order.fanout

代码

1 1 @Component
2 2 public class Sender {
3 3     @Autowired
4 4     private AmqpTemplate amqpTemplate;
5 5 
6 6     @Value("${mq.config.exchange}")
7 7     private String exchange;
8 8 
9 9     public void send(String msg){
1010         this.amqpTemplate.convertAndSend(this.exchange, "", msg);
1111     }
1212 }

二、Consumer

配置文件

1 1 spring.application.name=consumer
2 2 spring.rabbitmq.host=192.168.50.30
3 3 spring.rabbitmq.port=5672
4 4 spring.rabbitmq.username=rabbit
5 5 spring.rabbitmq.password=rabbit
6 6 #设置交换器的名称
7 7 mq.config.exchange=order.fanout
8 8 #短信服务队列名称
9 9 mq.config.queue.sms=order.sms
1010 #push 服务队列名称
1111 mq.config.queue.push=order.push

代码

SmsReceiver

1 1 /**
2 2     @RabbitListener bindings:绑定队列
3 3     @QueueBinding value:绑定队列的名称
4 4         exchange:配置交换器
5 5         key:路由键
6 6     @Queue value:配置队列名称
7 7         autoDelete:是否是一个可删除的临时队列
8 8     @Exchange value:为交换器起个名称
9 9         type:指定具体的交换器类型
1010 */
1111 @Component
1212 @RabbitListener(
1313     bindings=@QueueBinding(
1414         value=@Queue(
1515             value="${mq.config.queue.sms}",
1616             autoDelete="true"
1717         ),
1818         exchange=@Exchange(
1919             value="${mq.config.exchange}",
2020             type=ExchangeTypes.FANOUT
2121         )
2222     )
2323 )
2424 public class SmsReceiver {
2525     @RabbitHandler
2626     public void process(String msg) {
2727         System.out.println(msg);
2828     }
2929 }

PushReceiver

1 1 /**
2 2     @RabbitListener bindings:绑定队列
3 3     @QueueBinding value:绑定队列的名称
4 4             exchange:配置交换器
5 5     @Queue value:配置队列名称
6 6             autoDelete:是否是一个可删除的临时队列
7 7     @Exchange value:为交换器起个名称
8 8         type:指定具体的交换器类型
9 9 */
1010 @Component
1111 @RabbitListener(
1212     bindings=@QueueBinding(
1313         value=@Queue(
1414             value="${mq.config.queue.push}",
1515             autoDelete="true"),
1616         exchange=@Exchange(
1717             value="${mq.config.exchange}",
1818             type=ExchangeTypes.FANOUT
1919         )
2020     )
2121 )
2222 public class PushReceiver {
2323     @RabbitHandler
2424     public void process(String msg){
2525         System.out.println("Push receiver: " + msg);
2626     }
2727 }