【rabbitMQ】Exchanges交换机,Benjamin Ling

文件名：【rabbitMQ】Exchanges交换机,Benjamin Ling 【rabbitMQ】Exchanges交换机

上一篇：springboot整合rabbitMQ模拟简单收发消息

https://blog.csdn.net/m0_67930426/article/details/134904766

本篇代码基于上一篇继续写

目录

Fanout 交换机

1. add queue

2. add Exchange

3.绑定队列

Direct 交换机

1. add queue

 2. add Exchange

3.绑定队列，并设置Routing key 

Topic 交换机

1.add queue

2.add Exchange

3.绑定队列

---

Fanout 交换机

fanout exchange 会将接收到的消息广播到每一个跟其绑定的queue

1. add queue

2. add Exchange

3.绑定队列

 

 消费者监听队列

@RabbitListener(queues = "fanout.queue1")public void eee(String msg){System.out.println("消费者e收到了fanout.queue1的消息:【"+msg+"】");}@RabbitListener(queues = "fanout.queue2")public void fff(String msg){System.err.println("消费者f收到了fanout.queue2的消息:【"+msg+"】");}

 

 单元测试模拟业务发送消息

@Testvoid Test3Send(){String ExchangeName = "aaa.fanout";String msg = "rabbitMQ<消息队列>";rabbitTemplate.convertAndSend(ExchangeName,null, msg);}

 

Direct 交换机

Direct Exchange 会将接收的消息根据规则路由到指定的queue

1. add queue

 2. add Exchange

 

3.绑定队列，并设置Routing key 

 

  消费者监听队列

@RabbitListener(queues = "direct.queue1")public void ggg(String msg){System.out.println("消费者g收到了fanout.queue1的消息:【"+msg+"】");}@RabbitListener(queues = "direct.queue2")public void hhh(String msg){System.err.println("消费者h收到了fanout.queue2的消息:【"+msg+"】");}

 单元测试模拟业务发送消息

@Testvoid Test3Send() {String ExchangeName = "bbb.direct";String msg = "rabbitMQ<消息队列>";rabbitTemplate.convertAndSend(ExchangeName,"red" , msg);}

Routing key:  " red "

预期结果是，两个消费者都收到了消息

 

将Routing key 的值改为blue 

 

预期结果，只有消费者g接收到了消息

 

Topic 交换机 1.add queue

2.add Exchange

3.绑定队列

 

 

消费者监听队列 

@RabbitListener(queues = "topic.queue1")public void jjj(String msg){System.out.println("消费者j收到了fanout.queue1的消息:【"+msg+"】");}@RabbitListener(queues = "topic.queue2")public void kkk(String msg){System.err.println("消费者k收到了fanout.queue2的消息:【"+msg+"】");}

 单元测试模拟业务发送消息

@Testvoid Test3Send() {String ExchangeName = "ccc.topic";String msg = "rabbitMQ";rabbitTemplate.convertAndSend(ExchangeName,"zhejiang.new" , msg);}

Routing key : " zhejiang.new " 

预期结果是k收到消息

 

Routing  key: " china.new "

预期结果，两个消费者都接收到了消息