RabbitMQ（四种使用模式）

文章目录

    • 1.Fanout（广播模式）
        • 1.基本介绍
        • 2.需求分析
        • 3.具体实现
          • 1.编写配置类 RabbitMQConfig.java
          • 2.编写生产者，发送消息到交换机 MQSender.java
          • 3.编写消费者，接受消息 MQReceiver.java
          • 4.控制层调用方法，发送信息到交换机
        • 4.启动测试
          • 1.访问查看IDEA控制台输出
            • 1.访问 http://localhost:9092/seckill/mq/exchange
            • 2.查看控制台输出，两个队列同时接受到了消息
          • 2.访问RabbitMQ控制台 http://ip:15672
            • 1.查看交换机是否绑定了两个队列
            • 2.再查看Queues，新增了两个队列
    • 2.Direct（路由模式）
        • 1.基本介绍
        • 2.需求分析
        • 3.具体实现
          • 1.配置类 RabbitMQConfig.java
          • 2.编写生产者，发送消息到交换机并指定路由 MQSender.java
          • 3.编写消费者，接受消息 MQReceiver.java
          • 4.控制层调用方法，发送信息到交换机
        • 4.启动测试
          • 1.访问查看IDEA控制台输出
            • 1.访问 http://localhost:9092/seckill/mq/direct/green
            • 2.访问 http://localhost:9092/seckill/mq/direct/red
          • 2.访问RabbitMQ控制台 http://140.143.164.206:15672
            • 1.交换机绑定了两个队列
            • 2.再查看Queues，新增了两个队列
    • 3.Topic（主题模式）
        • 1.基本介绍
          • 1.介绍
          • 2.关于匹配模式的说明
        • 2.需求分析
        • 3.具体实现
          • 1.配置类 RabbitMQConfig.java
          • 2.编写生产者，发送消息到交换机并指定路由 MQSender.java
          • 3.编写消费者，接受消息 MQReceiver.java
          • 4.控制层调用方法，发送信息到交换机
        • 4.启动测试
          • 1.示意图
          • 2.访问查看IDEA控制台输出
            • 1.访问 http://localhost:9092/seckill/mq/topic/one.orange.one 匹配Q1
            • 2.访问 http://localhost:9092/seckill/mq/topic/one.one.rabbit 匹配Q2
            • 3.访问 http://localhost:9092/seckill/mq/topic/lazy.orange.one 匹配Q1和Q2
            • 4.访问 http://localhost:9092/seckill/mq/topic/lazy.any.any.any.any 匹配Q2
    • 4.Headers（头路由模式，使用较少）
        • 1.基本介绍
        • 2.示意图
        • 3.需求分析
        • 4.具体实现
          • 1.配置类 RabbitMQConfig.java
          • 2.编写生产者，发送消息到交换机并指定路由 MQSender.java
          • 3.编写消费者，接受消息 MQReceiver.java
          • 4.控制层调用方法，发送信息到交换机
        • 5.启动测试
          • 1.访问查看IDEA控制台输出
            • 1.访问 http://localhost:9092/seckill/mq/headers 匹配队列一
            • 2.访问 http://localhost:9092/seckill/mq/headers2 匹配队列二
    • 5.RabbitMQ使用模式总结
        • 1.整体架构图
        • 2.通用使用方式
          • 1.编写RabbitMQ的配置类
          • 2.编写消息发送者
          • 3.编写消息接受者
          • 4.编写控制层

1.Fanout（广播模式）

1.基本介绍

image-20240511143401624

2.需求分析

image-20240511143533335

3.具体实现
1.编写配置类 RabbitMQConfig.java
    // 定义一个交换机，两个队列的名称private static final String EXCHANGE = "exchange";private static final String QUEUE1 = "queue1";private static final String QUEUE2 = "queue2";// 创建两个队列和一个交换机// 创建队列1@Beanpublic Queue queue1() {return new Queue(QUEUE1, true);}// 创建队列2@Beanpublic Queue queue2() {return new Queue(QUEUE2, true);}// 创建交换机@Beanpublic FanoutExchange exchange() {return new FanoutExchange(EXCHANGE);}// 将队列一和交换机绑定@Beanpublic Binding binding1() {return BindingBuilder.bind(queue1()).to(exchange());}// 将队列二和交换机绑定@Beanpublic Binding binding2() {return BindingBuilder.bind(queue2()).to(exchange());}
2.编写生产者，发送消息到交换机 MQSender.java
    // 发送消息到交换机public void sendExchange(Object message) {log.info("发送消息到交换机： " + message);// 发送消息到交换机，需要指定在配置类中配置的交换机名，这里的空字符串表示忽略路由键rabbitTemplate.convertAndSend("exchange", "", message);}
3.编写消费者，接受消息 MQReceiver.java
    // 两个队列从交换机接受消息@RabbitListener(queues = "queue1")public void receive1(Object message) {log.info("queue1接收消息: " + message);}// 两个队列从交换机接受消息@RabbitListener(queues = "queue2")public void receive2(Object message) {log.info("queue2接收消息: " + message);}
4.控制层调用方法，发送信息到交换机
    // 发送信息到交换机@RequestMapping("/mq/exchange")@ResponseBodypublic void mqExchange() {mqSender.sendExchange("hello rabbitmq exchange");}
4.启动测试
1.访问查看IDEA控制台输出
1.访问 http://localhost:9092/seckill/mq/exchange

image-20240511145506791

2.查看控制台输出，两个队列同时接受到了消息

image-20240511145523594

2.访问RabbitMQ控制台 http://ip:15672
1.查看交换机是否绑定了两个队列

image-20240511145927045

image-20240511145938023

2.再查看Queues，新增了两个队列

image-20240511145956152

2.Direct（路由模式）

1.基本介绍

image-20240511150759660

2.需求分析

image-20240511151501711

3.具体实现
1.配置类 RabbitMQConfig.java
    // ----------------- Direct模式 -----------------// 定义一个交换机，两个队列的名称private static final String DIRECT_EXCHANGE = "directExchange";private static final String DIRECT_QUEUE1 = "directQueue1";private static final String DIRECT_QUEUE2 = "directQueue2";// 定义两个路由分别为red和greenpublic static final String RED = "red";public static final String GREEN = "green";// 创建两个队列和一个交换机// 创建队列1@Beanpublic Queue directQueue1() {return new Queue(DIRECT_QUEUE1, true);}// 创建队列2@Beanpublic Queue directQueue2() {return new Queue(DIRECT_QUEUE2, true);}// 创建Direct交换机@Beanpublic DirectExchange directExchange() {return new DirectExchange(DIRECT_EXCHANGE);}// 将队列一和交换机绑定，并指定路由为red@Beanpublic Binding directBinding1() {return BindingBuilder.bind(directQueue1()).to(directExchange()).with(RED);}// 将队列二和交换机绑定，并指定路由为green@Beanpublic Binding directBinding2() {return BindingBuilder.bind(directQueue2()).to(directExchange()).with(GREEN);}// ----------------- Direct模式 -----------------
2.编写生产者，发送消息到交换机并指定路由 MQSender.java
    // ----------------- Direct模式 -----------------// 发送消息到Direct交换机，指定路由键public void sendDirect(Object message, String routingKey) {log.info("发送消息到Direct交换机： " + message);// 发送消息到交换机，需要指定在配置类中配置的交换机名，这里的路由键为 routingKeyrabbitTemplate.convertAndSend("directExchange", routingKey, message);}// ----------------- Direct模式 -----------------
3.编写消费者，接受消息 MQReceiver.java
    // ----------------- Direct模式 -----------------// directQueue1接收消息@RabbitListener(queues = "directQueue1")public void receiveDirect(Object message) {log.info("directQueue1接收消息: " + message);}// directQueue2接收消息@RabbitListener(queues = "directQueue2")public void receiveDirect2(Object message) {log.info("directQueue2接收消息: " + message);}// ----------------- Direct模式 -----------------
4.控制层调用方法，发送信息到交换机
    // ----------------- Direct模式 -----------------// 发送消息到Direct交换机，指定路由键@RequestMapping("/mq/direct/{routingKey}")@ResponseBodypublic void mqDirect(@PathVariable String routingKey) {mqSender.sendDirect("hello rabbitmq direct", routingKey);}// ----------------- Direct模式 -----------------
4.启动测试
1.访问查看IDEA控制台输出
1.访问 http://localhost:9092/seckill/mq/direct/green

image-20240511155350571

2.访问 http://localhost:9092/seckill/mq/direct/red

image-20240511155417490

2.访问RabbitMQ控制台 http://140.143.164.206:15672
1.交换机绑定了两个队列

image-20240511155827225

image-20240511155911603

2.再查看Queues，新增了两个队列

image-20240511155943495

3.Topic（主题模式）

1.基本介绍
1.介绍

image-20240511161221729

2.关于匹配模式的说明
  • 星号：可以匹配一个单词
  • 井号：可以匹配零个或多个单词
2.需求分析

image-20240511161528268

3.具体实现
1.配置类 RabbitMQConfig.java
    // ----------------- Topic模式 -----------------// 定义一个交换机，两个队列的名称private static final String TOPIC_EXCHANGE = "topicExchange";private static final String TOPIC_QUEUE1 = "topicQueue1";private static final String TOPIC_QUEUE2 = "topicQueue2";// 定义三个路由public static final String ROUTING_KEY1 = "*.orange.*";public static final String ROUTING_KEY2 = "*.*.rabbit";public static final String ROUTING_KEY3 = "lazy.#";// 创建两个队列和一个交换机// 创建队列1@Beanpublic Queue topicQueue1() {return new Queue(TOPIC_QUEUE1, true);}// 创建队列2@Beanpublic Queue topicQueue2() {return new Queue(TOPIC_QUEUE2, true);}// 创建Topic交换机@Beanpublic TopicExchange topicExchange() {return new TopicExchange(TOPIC_EXCHANGE);}// 将队列一和交换机绑定，并指定路由为*.orange.*@Beanpublic Binding topicBinding1() {return BindingBuilder.bind(topicQueue1()).to(topicExchange()).with(ROUTING_KEY1);}// 将队列二和交换机绑定，并指定路由为*.*.rabbit和lazy.#@Beanpublic Binding topicBinding2() {return BindingBuilder.bind(topicQueue2()).to(topicExchange()).with(ROUTING_KEY2);}@Beanpublic Binding topicBinding3() {return BindingBuilder.bind(topicQueue2()).to(topicExchange()).with(ROUTING_KEY3);}// ----------------- Topic模式 -----------------
2.编写生产者，发送消息到交换机并指定路由 MQSender.java
    // ----------------- Topic模式 -----------------// 发送消息到Topic交换机，指定路由键public void sendTopic(Object message, String routingKey) {log.info("发送消息到Topic交换机： " + message);// 发送消息到交换机，需要指定在配置类中配置的交换机名，这里的路由键为 routingKeyrabbitTemplate.convertAndSend("topicExchange", routingKey, message);}// ----------------- Topic模式 -----------------
3.编写消费者，接受消息 MQReceiver.java
    // ----------------- Topic模式 -----------------// topicQueue1接收消息@RabbitListener(queues = "topicQueue1")public void receiveTopic1(Object message) {log.info("topicQueue1接收消息: " + message);}// topicQueue2接收消息@RabbitListener(queues = "topicQueue2")public void receiveTopic2(Object message) {log.info("topicQueue2接收消息: " + message);}// ----------------- Topic模式 -----------------
4.控制层调用方法，发送信息到交换机
    // ----------------- Topic模式 -----------------// 发送消息到Topic交换机，指定路由键@RequestMapping("/mq/topic/{routingKey}")@ResponseBodypublic void mqTopic(@PathVariable String routingKey) {mqSender.sendTopic("hello rabbitmq topic", routingKey);}// ----------------- Topic模式 -----------------
4.启动测试
1.示意图

image-20240511161528268

2.访问查看IDEA控制台输出
1.访问 http://localhost:9092/seckill/mq/topic/one.orange.one 匹配Q1

image-20240511163348473

2.访问 http://localhost:9092/seckill/mq/topic/one.one.rabbit 匹配Q2

image-20240511163438210

3.访问 http://localhost:9092/seckill/mq/topic/lazy.orange.one 匹配Q1和Q2

image-20240511163527113

4.访问 http://localhost:9092/seckill/mq/topic/lazy.any.any.any.any 匹配Q2

image-20240511163618877

4.Headers（头路由模式，使用较少）

1.基本介绍

image-20240511164450490

2.示意图

image-20240511165737435

3.需求分析

image-20240511170148293

4.具体实现
1.配置类 RabbitMQConfig.java
    // ----------------- Headers模式 -----------------// 定义一个交换机，两个队列的名称private static final String HEADERS_EXCHANGE = "headersExchange";private static final String HEADERS_QUEUE1 = "headersQueue1";private static final String HEADERS_QUEUE2 = "headersQueue2";// 创建两个队列和一个交换机// 创建队列1@Beanpublic Queue headersQueue1() {return new Queue(HEADERS_QUEUE1, true);}// 创建队列2@Beanpublic Queue headersQueue2() {return new Queue(HEADERS_QUEUE2, true);}// 创建Headers交换机@Beanpublic HeadersExchange headersExchange() {return new HeadersExchange(HEADERS_EXCHANGE);}// 将队列一和交换机绑定，并指定key-value，使用any表示只要有一个匹配就可以@Beanpublic Binding headersBinding1() {Map<String, Object> map = new HashMap<>();map.put("key1", "value1");map.put("key2", "value2");return BindingBuilder.bind(headersQueue1()).to(headersExchange()).whereAny(map).match();}// 将队列二和交换机绑定，并指定key-value，使用all表示所有的key-value都要匹配@Beanpublic Binding headersBinding2() {Map<String, Object> map = new HashMap<>();map.put("key3", "value3");map.put("key4", "value4");return BindingBuilder.bind(headersQueue2()).to(headersExchange()).whereAll(map).match();}// ----------------- Headers模式 -----------------
2.编写生产者，发送消息到交换机并指定路由 MQSender.java
    // ----------------- Headers模式 -----------------// 发送消息到Headers交换机，匹配队列一public void sendHeaders(Object message) {log.info("发送消息到Headers交换机： " + message);// 发送消息到交换机，需要指定在配置类中配置的交换机名，这里的空字符串表示忽略路由键rabbitTemplate.convertAndSend("headersExchange", "", message, message1 -> {message1.getMessageProperties().getHeaders().put("key1", "value1");return message1;});}// 发送消息到Headers交换机，匹配队列二public void sendHeaders2(Object message) {log.info("发送消息到Headers交换机： " + message);// 发送消息到交换机，需要指定在配置类中配置的交换机名，这里的空字符串表示忽略路由键rabbitTemplate.convertAndSend("headersExchange", "", message, message1 -> {message1.getMessageProperties().getHeaders().put("key3", "value3");message1.getMessageProperties().getHeaders().put("key4", "value4");return message1;});}// ----------------- Headers模式 -----------------
3.编写消费者，接受消息 MQReceiver.java
    // ----------------- Headers模式 -----------------// headersQueue1接收消息@RabbitListener(queues = "headersQueue1")public void receiveHeaders1(Object message) {log.info("headersQueue1接收消息: " + message);}// headersQueue2接收消息@RabbitListener(queues = "headersQueue2")public void receiveHeaders2(Object message) {log.info("headersQueue2接收消息: " + message);}// ----------------- Headers模式 -----------------
4.控制层调用方法，发送信息到交换机
    // ----------------- Headers模式 -----------------// 发送消息到Headers交换机，匹配队列一@RequestMapping("/mq/headers")@ResponseBodypublic void mqHeaders() {mqSender.sendHeaders("hello rabbitmq headers");}// 发送消息到Headers交换机，匹配队列二@RequestMapping("/mq/headers2")@ResponseBodypublic void mqHeaders2() {mqSender.sendHeaders2("hello rabbitmq headers2");}// ----------------- Headers模式 -----------------
5.启动测试
1.访问查看IDEA控制台输出
1.访问 http://localhost:9092/seckill/mq/headers 匹配队列一

image-20240511173539342

2.访问 http://localhost:9092/seckill/mq/headers2 匹配队列二

image-20240511173600832

5.RabbitMQ使用模式总结

1.整体架构图

image-20240511173928100

2.通用使用方式
1.编写RabbitMQ的配置类
  • 创建交换机和队列
  • 将队列分别与交换机按照具体标识绑定
2.编写消息发送者
  • 指定交换机
  • 携带消息和具体队列标识
3.编写消息接受者
  • 只需要监听队列，接收消息即可
4.编写控制层
  • 调用消息发送者，向交换机发送请求

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.hqwc.cn/news/696617.html

如若内容造成侵权/违法违规/事实不符，请联系编程知识网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

RAG应用中的路由模式

RAG应用中的路由模式

依据的用户查询意图在 RAG 应用程序使用“路由控制模式”可以帮助我们创建更强大的 RAG 应用程序。我们通常希望用户能够访问的数据可以来自各种来源，如报告、文档、图片、数据库和第三方系统。 对于基于业务的 RAG 应用程序，我们可能还希望用户能够与其它业务系统进行交互，…
阅读更多...
卷积通用模型的剪枝、蒸馏---蒸馏篇--RKD关系蒸馏（以deeplabv3+为例）

卷积通用模型的剪枝、蒸馏---蒸馏篇--RKD关系蒸馏（以deeplabv3+为例）

本文使用RKD实现对deeplabv3+模型的蒸馏；与上一篇KD蒸馏的方法有所不同，RKD是对展平层的特征做蒸馏，蒸馏的loss分为二阶的距离损失Distance-wise Loss和三阶的角度损失Angle-wise Loss。 完整代码放在文末。 一、RKD简介 RKD算法的核心是以教师模型的多个输出为结构单元，取…
阅读更多...
Infuse for Mac激活版：高清影音播放软件

Infuse for Mac激活版：高清影音播放软件

对于热爱影音娱乐的Mac用户来说&#xff0c;Infuse for Mac是一个不容错过的选择。它以其简洁的操作界面和强大的播放功能&#xff0c;为用户带来了全新的影音播放体验。 Infuse for Mac支持广泛的音视频格式&#xff0c;无需额外转换&#xff0c;即可轻松播放您喜爱的影片。无…
阅读更多...
图的概念、性质和存储与简单遍历

图的概念、性质和存储与简单遍历

前置知识&#xff1a;树的基本概念及性质 为了保证学习效果&#xff0c;请保证已经掌握前置知识之后&#xff0c;再来学习本章节&#xff01;如果在阅读中遇到困难&#xff0c;也可以回到前面章节查阅。 学习目标 掌握图的基本概念掌握图的一些性质 图的概念 基本概念 图 (…
阅读更多...
算法设计与分析（超详解！） 第三节 贪婪算法

算法设计与分析（超详解！） 第三节 贪婪算法

1.贪心算法基础 1.贪心算法的基本思想 贪心算法是从问题的某一个初始解出发&#xff0c;向给定的目标推进。但它与普通递推求解过程不同的是&#xff0c;其推动的每一步不是依据某一固定的递推式&#xff0c;而是做一个当时看似最佳的贪心选择&#xff0c;不断地将问题实例归…
阅读更多...
MySQL 大量数据插入优化

MySQL 大量数据插入优化

效率最好的方式是&#xff1a;批量插入 开启事务。 1、数据批量插入相比数据逐条插入的运行效率得到极大提升&#xff1b; ## 批量插入 INSERT INTO table (field1, field12,...) VALUES (valuea1, valuea2,...), (valueb1, valueb2,...),...;当数据逐条插入时&#xff0c;每…
阅读更多...
OpenAI 或将推出多模态人工智能数字助理；研究发现部分 AI 系统已学会「说谎」丨 RTE 开发者日报 Vol.203

OpenAI 或将推出多模态人工智能数字助理；研究发现部分 AI 系统已学会「说谎」丨 RTE 开发者日报 Vol.203

开发者朋友们大家好&#xff1a; 这里是 「RTE 开发者日报」 &#xff0c;每天和大家一起看新闻、聊八卦。我们的社区编辑团队会整理分享 RTE&#xff08;Real Time Engagement&#xff09; 领域内「有话题的 新闻 」、「有态度的 观点 」、「有意思的 数据 」、「有思考的 文…
阅读更多...
LeetCode 700.二叉搜索树中的搜索

LeetCode 700.二叉搜索树中的搜索

LeetCode 700.二叉搜索树中的搜索 1、题目 题目链接&#xff1a;700. 二叉搜索树中的搜索 给定二叉搜索树&#xff08;BST&#xff09;的根节点 root 和一个整数值 val。 你需要在 BST 中找到节点值等于 val 的节点。 返回以该节点为根的子树。 如果节点不存在&#xff0c;则…
阅读更多...
【C语言/数据结构】栈：从概念到两种存储结构的实现

【C语言/数据结构】栈：从概念到两种存储结构的实现

目录 一、栈的概念 二、栈的两种实现方式 1.顺序表实现栈 2.链表实现栈 三、栈的顺序存储结构及其实现 1.栈的声明 2.栈的初始化 3.栈的销毁 4.栈的压栈 5.栈的弹栈 6.栈的判空 7.返回栈顶元素 8.返回栈的长度 四、栈的链式存储结构及其实现 1.栈的声明 2.栈的…
阅读更多...
设计模式Java实现-迭代器模式

设计模式Java实现-迭代器模式

✨这里是第七人格的博客✨小七&#xff0c;欢迎您的到来~✨ &#x1f345;系列专栏&#xff1a;设计模式&#x1f345; ✈️本篇内容: 迭代器模式✈️ &#x1f371; 本篇收录完整代码地址&#xff1a;https://gitee.com/diqirenge/design-pattern &#x1f371; 楔子 很久…
阅读更多...
JavaScript数字(Number)个数学(Math)对象

JavaScript数字(Number)个数学(Math)对象

目录 前言&#xff1a; Number&#xff08;数字&#xff09;对象 前言&#xff1a; nfinity(正负无穷大)&#xff1a; NaN&#xff08;非数字&#xff09;&#xff1a; Number的属性 Number的方法 构造函数 静态方法 实例方法 Math&#xff08;数学&#xff09;对象…
阅读更多...
C#之partial关键字

C#之partial关键字

在C#中&#xff0c;partial关键字用于声明一个类、结构体、接口或方法的分部定义。这意味着可以将一个类或其他类型的定义分成多个部分&#xff0c;这些部分可以在同一个命名空间或程序集中的多个源文件中进行定义。当编译器编译这些部分时&#xff0c;会将它们合并成一个单独的…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023