rabbitmq的三个交换机及简单使用

devtools/2025/1/24 1:55:03/

提前说一下,创建队列,交换机,绑定交换机和队列都是在生产者。消费者只负责监听就行了,不用配其他的。

完成这个场景需要两个服务哦。

1直连交换机-生产者的代码。

在配置类中创建队列,交换机,绑定交换机和队列

@Configuration
public class DirectRabbitConfigTest {//队列@Beanpublic Queue TestDirectQueue(){return new Queue("TestDirectQueue",true);}//交换机@BeanDirectExchange TestDirectExchange(){return new DirectExchange("TestDirectExchange",true,false);}//绑定@BeanBinding bindingDirect(){return BindingBuilder.bind(TestDirectQueue()).to(TestDirectExchange()).with("TestDirectRouting");//TestDirectRouting为路由键}
}

发送消息,访问这个接口就行。

@Controller
public class test001 {@Autowiredprivate RabbitTemplate rabbitTemplate;@ResponseBody@GetMapping("/sendDirectMessage")public String sendDirectMessage() {String messageId = String.valueOf(UUID.randomUUID());String messageData = "test message, hello!";String createTime = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));Map<String,Object> map=new HashMap<>();map.put("messageId",messageId);map.put("messageData",messageData);map.put("createTime",createTime);//将消息携带绑定键值:TestDirectRouting 发送到交换机TestDirectExchangerabbitTemplate.convertAndSend("TestDirectExchange", "TestDirectRouting", map);return "ok";}
}

2直连交换机-消费者的代码

@Component
@RabbitListener(queues = "TestDirectQueue")//监听的队列
public class DirectReceiver {@RabbitHandlerpublic void process(Map testMessage){System.out.println("消息one:"+testMessage.toString());//这个map就是发送的消息}
}

直连交换机总结:你可以自己加几个消费者,发送消息你会发现消息被轮询了。

访问@GetMapping("/sendDirectMessage")消息就发出并被接收。

3topic交换机-生产者的代码

注意:需要自己去控制台添加firstQueue和secondQueue队列,不然消费者启动不起来。原因未知,在直连交换机的时候机器自己创建队列了,topic不知道为啥不行。

@Configuration
public class TopicRabbitConfigTest {//绑定键public final static String man = "topic.man";public final static String woman = "topic.woman";@Beanpublic Queue firstQueue() {//return new Queue(TopicRabbitConfigTest.man);return new Queue("firstQueue");}@Beanpublic Queue secondQueue() {//return new Queue(TopicRabbitConfigTest.woman);return new Queue("secondQueue");}@BeanTopicExchange exchange() {return new TopicExchange("topicExchange");}//将firstQueue和topicExchange绑定,而且绑定的键值为topic.man//这样只要是消息携带的路由键是topic.man,才会分发到该队列@BeanBinding bindingExchangeMessage() {return BindingBuilder.bind(firstQueue()).to(exchange()).with(man);}//将secondQueue和topicExchange绑定,而且绑定的键值为用上通配路由键规则topic.#// 这样只要是消息携带的路由键是以topic.开头,都会分发到该队列@BeanBinding bindingExchangeMessage2() {return BindingBuilder.bind(secondQueue()).to(exchange()).with("topic.#");}}

发送消息,访问这两个接口就行。

@Controller
public class TopicTest002 {@Autowiredprivate RabbitTemplate rabbitTemplate;@GetMapping("/sendTopicMessage1")public String sendTopicMessage1() {String messageId = String.valueOf(UUID.randomUUID());String messageData = "message: M A N ";String createTime = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));Map<String, Object> manMap = new HashMap<>();manMap.put("messageId", messageId);manMap.put("messageData", messageData);manMap.put("createTime", createTime);rabbitTemplate.convertAndSend("topicExchange", "topic.man", manMap);return "ok";}@GetMapping("/sendTopicMessage2")public String sendTopicMessage2() {String messageId = String.valueOf(UUID.randomUUID());String messageData = "message: woman is all ";String createTime = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));Map<String, Object> womanMap = new HashMap<>();womanMap.put("messageId", messageId);womanMap.put("messageData", messageData);womanMap.put("createTime", createTime);rabbitTemplate.convertAndSend("topicExchange", "topic.woman", womanMap);return "ok";}
}

4topic交换机-消费者的代码

需要监听两个队列

@Component
@RabbitListener(queues = "firstQueue")//监听的队列
public class TopicManReceiver {@RabbitHandlerpublic void process(Map testMessage) {System.out.println("TopicManReceiver消费者收到消息  : " + testMessage.toString());}}
@Component
@RabbitListener(queues = "secondQueue")//监听的队列
public class TopicWoManReceiver {@RabbitHandlerpublic void process(Map testMessage) {System.out.println("TopicTotalReceiver消费者收到消息  : " + testMessage.toString());}}

先访问@GetMapping("/sendTopicMessage1")接口,再访@GetMapping("/sendTopicMessage2")接口,结果如下:

总结:绑定和发送的时候都要设置路由键。

5fanout交换机-生产者

注意:这种交换机也需要自己去控制台创建队列。fanout交换机不需要设置路由key

@Configuration
public class FanoutRabbitConfigTest {/***  创建三个队列 :fanout.A   fanout.B  fanout.C*  将三个队列都绑定在交换机 fanoutExchange 上*  因为是扇型交换机, 路由键无需配置,配置也不起作用*/@Beanpublic Queue queueA() {return new Queue("fanout.A");}@Beanpublic Queue queueB() {return new Queue("fanout.B");}@Beanpublic Queue queueC() {return new Queue("fanout.C");}@BeanFanoutExchange fanoutExchange() {return new FanoutExchange("fanoutExchange");}@BeanBinding bindingExchangeA() {return BindingBuilder.bind(queueA()).to(fanoutExchange());}@BeanBinding bindingExchangeB() {return BindingBuilder.bind(queueB()).to(fanoutExchange());}@BeanBinding bindingExchangeC() {return BindingBuilder.bind(queueC()).to(fanoutExchange());}}

发送消息,访问这个接口就行。

@Controller
public class FanoutTest003 {@Autowiredprivate RabbitTemplate rabbitTemplate;@GetMapping("/sendFanoutMessage")public String sendFanoutMessage() {String messageId = String.valueOf(UUID.randomUUID());String messageData = "message: testFanoutMessage ";String createTime = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));Map<String, Object> map = new HashMap<>();map.put("messageId", messageId);map.put("messageData", messageData);map.put("createTime", createTime);rabbitTemplate.convertAndSend("fanoutExchange", null, map);return "ok";}}

6fanout交换机-消费者

@Component
@RabbitListener(queues = "fanout.A")//监听的队列
public class FanoutA {@RabbitHandlerpublic void process(Map testMessage) {System.out.println("FanoutReceiverA消费者收到消息  : " +testMessage.toString());}
}
@Component
@RabbitListener(queues = "fanout.B")//监听的队列
public class FanoutB {@RabbitHandlerpublic void process(Map testMessage) {System.out.println("FanoutReceiverB消费者收到消息  : " +testMessage.toString());}}
@Component
@RabbitListener(queues = "fanout.C")//监听的队列
public class FanoutC {@RabbitHandlerpublic void process(Map testMessage) {System.out.println("FanoutReceiverC消费者收到消息  : " +testMessage.toString());}}

总结:三个消费者都收到了消息

重点:直连交换机不管绑定多少个队列,消息会到达所有队列,然后去消费者方进行轮询。


http://www.ppmy.cn/devtools/150571.html

相关文章

自动连接校园网wifi脚本实践(自动网页认证)

目录 起因执行步骤分析校园网登录逻辑如何判断当前是否处于未登录状态&#xff1f; 书写代码打包设置开机自动启动 起因 我们一般通过远程控制的方式访问实验室电脑&#xff0c;但是最近实验室老是断电&#xff0c;但重启后也不会自动连接校园网账户认证&#xff0c;远程工具&…

基于单片机的公交车报站系统设计

摘 要 目前&#xff0c;我国经济快速发展&#xff0c;城市化进程不断加快。公交车作为居民日常出行的重要交通工具&#xff0c;公交车的服务质量直接影响到乘客的乘车体验&#xff0c;关系到城市智能交通的发展。为了解决传统公交车上车载终端信息闭塞的问题&#xff0c;提高公…

Linux服务器网络丢包场景及解决办法

一、Linux网络丢包概述 在数字化浪潮席卷的当下&#xff0c;网络已然成为我们生活、工作与娱乐不可或缺的基础设施&#xff0c;如同空气般&#xff0c;无孔不入地渗透到各个角落。对于 Linux 系统的用户而言&#xff0c;网络丢包问题却宛如挥之不去的 “噩梦”&#xff0c;频繁…

MySQL innodb中一条sql的执行流程

在 MySQL InnoDB 存储引擎中&#xff0c;执行一条 SQL 语句的流程涉及多个模块的协作。下面是一个详细的讲解&#xff0c;包括 SQL 查询从接收、解析、优化、执行到结果返回的完整过程。 1. SQL 的执行流程概述 一条 SQL 的执行流程可以分为以下几个主要阶段&#xff1a; 客户…

网络安全:守护数字世界的防线

在信息化时代&#xff0c;网络已成为人们生活和工作的基础设施&#xff0c;从在线购物、社交互动到企业运营、政府服务&#xff0c;无处不在的网络连接着全球各地的人们和组织。然而&#xff0c;网络的便捷性也带来了诸多安全风险&#xff0c;网络安全问题日益凸显&#xff0c;…

【广西乡镇界】arcgis格式shp数据乡镇名称和编码2020年内容测评

【广西乡镇界】arcgis格式shp数据乡镇名称和编码2020年内容测评

Springcloudgateway 请求无响应,要怎么处理

当遇到Spring Cloud Gateway请求无响应的问题时&#xff0c;可能的原因和解决方案包括以下几个方面&#xff1a; 一、可能的原因 服务端负载过高&#xff1a; 当服务端处理请求的能力不足&#xff0c;导致无法及时响应请求时&#xff0c;可能会出现无响应的情况。 服务端资…

【Uniapp-Vue3】@import导入css样式及scss变量用法与static目录

一、import导入css样式 在项目文件中创建一个common文件夹&#xff0c;下面创建一个css文件夹&#xff0c;里面放上style.css文件&#xff0c;编写的是公共样式&#xff0c;我们现在要在App.vue中引入该样式。 在App.vue中引入该样式&#xff0c;这样就会使样式全局生效&#…