创建SpringBoot和RabbitMQ的整合项目

文章目录

  • 创建SpringBoot和RabbitMQ的整合项目
    • 首先快速创建一个maven项目
    • 引入SpringBoot整合rabbitMQ的依赖
    • 在src/main目录下创建resources目录并引入配置文件
    • 写消息发送者MessageSender
    • 写消息接收者MessageReceiver
    • 写RabbitMQConfig配置类
    • 写SpringBoot启动主类
    • CommandLineRunner接口的作用
    • 启动程序 查看效果
    • 注意要点
      • 15672和5672的区别
      • 消息发送的队列怎么找
    • 我们的消息发送者和消息接收者可以只开启一个
      • 只开启消息发送者先存一些消息到消息队列
      • 只开启消息接收者从消息队列里面读取消息
    • 接下来我们来看一下RabbitMQ中怎么控制一个线程一次消费的消息数,主要是看下concurrency关键属性

创建SpringBoot和RabbitMQ的整合项目

首先快速创建一个maven项目

如下图:
在这里插入图片描述

引入SpringBoot整合rabbitMQ的依赖

如下图:
在这里插入图片描述
这里要SpringBoot和RabbitMQ整合的依赖对应的就是spring-boot-starter-amqp,那么amqp是什么意思呢?是Advanced Message Queuing Protocol,高级消息队列协议,是应用层协议的一个开放标准,是面向消息的中间件设计。比如RabbitMQ消息中间件使用的就是这个协议。
因为我们要启动服务,因此需要有tomcat服务器,因此这里还要引入spring-boot-starter-web模块依赖,因为SpringBoot自带的tomcat服务器在web模块里面。

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>org.example</groupId><artifactId>rabbitMQ</artifactId><version>1.0-SNAPSHOT</version><packaging>jar</packaging><name>rabbitMQ</name><url>http://maven.apache.org</url><properties><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding></properties><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.6.7</version></parent><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>3.8.1</version><scope>test</scope></dependency></dependencies>
</project>

在src/main目录下创建resources目录并引入配置文件

如下图:
在这里插入图片描述

写消息发送者MessageSender

如下图:
在这里插入图片描述

/*** @author xuan* @create 2024/4/25*/
@Component
public class MessageSender {@Autowiredprivate AmqpTemplate rabbitTemplate;public void sendMessage(String exchange, String routingKey, Object message) {rabbitTemplate.convertAndSend(exchange, routingKey, message);}
}

写消息接收者MessageReceiver

如下图:
在这里插入图片描述

/*** @author xuan* @create 2024/4/25*/
@Component
public class MessageReceiver {@RabbitListener(queues = "test.queue")public void handleMessage(Object message) {System.out.println("Received message: " + message);}
}

写RabbitMQConfig配置类

如下图:
在这里插入图片描述

/*** @author xuan* @create 2024/4/25*/
@Configuration
public class RabbitMQConfig {@Beanpublic DirectExchange testExchange() {return new DirectExchange("test.exchange");}@Beanpublic Queue testQueue() {return new Queue("test.queue");}@Beanpublic Binding testBinding() {return BindingBuilder.bind(testQueue()).to(testExchange()).with("test.routingKey");}
}

写SpringBoot启动主类

如下图:
在这里插入图片描述

/*** @author xuan* @create 2024/4/25*/
@SpringBootApplication
public class Application implements CommandLineRunner {@Autowiredprivate MessageSender messageSender;public static void main(String[] args) {SpringApplication.run(Application.class, args);}@Overridepublic void run(String... args) throws Exception {messageSender.sendMessage("test.exchange", "test.routingKey", "Hello, RabbitMQ!");}
}

CommandLineRunner接口的作用

从上面的SpringBoot启动类可以看到,它实现了CommandLineRunner接口,实现了这个接口中的抽象方法run,那么CommandLineRunner接口又什么作用呢?它主要是用在SpringBoot的启动主类上的,主要作用是在SpringBoot应用程序启动之后执行一些任务,比如:

  • 数据初始化:加载初始数据到数据库或其他存储系统中。
  • 发送通知:向用户或系统发送启动通知,例如通过邮件或消息队列。
  • 执行检查:进行应用程序启动前的检查,如数据库连接检查、文件系统检查等。

比如我们上面的主类在成功启动SpringBoot的应用程序之后 就会给RabbitMQ消息队列发送一个消息。

启动程序 查看效果

启动主类之后 控制台输出如下图:
在这里插入图片描述
这里我们主要看消息体Body的内容,可以发现是Hello RabbitMQ。后面是消息的一些属性 类似如我们的http协议中的request请求头的信息,包括消息的内容类型了,消息的内容编码了,消息的长度了等信息。

可以发现我们这里测试成功了。

注意要点

15672和5672的区别

RabbitMQ前端管理界面使用的端口号是15672,比如我们启动rabbitmq之后,在浏览器中输入127.0.0.1:15672可以进入rabbitmq的前端页面管理器中进行相关操作,如下图:
在这里插入图片描述
但是后端服务器的rabbitmq在电脑上启动的端口号是5672,如下图:
在这里插入图片描述
这两个端口号特别容易搞错,千万要注意,如果配置文件里的端口号写15672,那么我们的idea里面的java程序就连接不上我们本地已经启动的rabbitmq服务器了。

消息发送的队列怎么找

通过RabbitMQ中的交换机Exchange,和路由RouteingKey可以唯一的定位到一个消息队列Queue,如下图:
在这里插入图片描述
在这里插入图片描述

因此我们代码里面发送者发送消息的时候,一定要指定使用的交换机和使用的路由,但不用指定使用的队列,因为有交换机和路由之后就会自动的映射到使用的队列了,看下代码如下图:
在这里插入图片描述
但是我们需要通过一个配置类配置一下 需要告诉java程序,如下图:
在这里插入图片描述
然后接收者接收消息的时候 可以直接指定test.queue队列,就可以自动的去这个队列中取出消息了。不用写交换机和路由的具体信息。下面看下接收者的处理 如下图:
在这里插入图片描述

但是我觉得RabbitMQ应该是会有线程安全问题的,比如说因为目前看来同一个队列 两个不同的线程都是可以访问的,那这样的话有共享资源问题 就肯定会出现线程安全问题。

我们的消息发送者和消息接收者可以只开启一个

只开启消息发送者先存一些消息到消息队列

比如我们可以先用消息发送者往RabbitMQ的消息队列test.queue里面发送三条消息,此时注意关闭消息接收者,以免接收者直接读取队列里面的消息,我们在页面上就看不到效果了,如下图:
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

只开启消息接收者从消息队列里面读取消息

接下来我们把消息发送者关了,把消息接收者打开,去消费队列里面的消息,如下图:
在这里插入图片描述
在这里插入图片描述
看下启动应用程序之后的效果 如下图:
在这里插入图片描述

接下来我们来看一下RabbitMQ中怎么控制一个线程一次消费的消息数,主要是看下concurrency关键属性

通过concurrency属性来控制线程从队列中一次性读取的消息个数。如果我们把属性concurrency的值设置为1 那么就表示一个线程一次性会从队列里面读取一条消息;如果把这个值设置成3 那么就表示一个线程一次性会从队列里面读取3条消息;concurrency的书写位置如下图:
在这里插入图片描述
据我的观察,RabbitMQ内部应该有线程安全机制,就是在当前线程读取消费队列消息没有完成的时候,另外的线程是不能消费队列消息的。

现在我们模拟两个线程,而我们具体的模拟方式其实是重新复制一个项目,然后改下端口号为8081,接着我们把给队列发送消息的代码注释掉 只开启接收者从消息队列里面读取消息 过程如下图:
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

上面是我们模拟的第一个线程,其实也就是copy一个相同的项目 改下端口号 启动的时候就是不同的线程了。

然后启动第二个线程,发送6条消息到消息队列中,如下图:
在这里插入图片描述
那么这个时候呢?线程一就会先读取消息队列的第一条消息,线程二此时会在线程一后面排队,当线程一处理完消息之后,线程二会去读取消息队列里面的消息,然后线程一读取…。因此正常情况的输出是 其中一个应用程序中 输出的是编号1,3,5的消息,另外一个应用程序中输出的是编号2,4,6的消息。如下图:
在这里插入图片描述
在这里插入图片描述
确实是正常的。

现在我们把concurrency线程一次性最多读取的消息个数改成4,看下控制台输出结果,如下图:
在这里插入图片描述
在这里插入图片描述
可以看到第一个线程一次性会读取消息队列的前四条消息,而第二个线程本来也会读取四条 但是队列中只剩两条消息,因此第二个线程就一次性的读取两条消息了。
但是有个线程安全问题。就是你会发现第一个线程虽然读取的确实是队列里面的前四条消息,但是呢?消费消息的时候却不是按队列里面添加消息的顺序,这可能就会出现问题了。比如假如说队列里面按照先后顺序添加了两条消息,1穿装,2脱装。但是线程读取消息之后 先消费处理的可能是2脱装,那是不是就会出现问题了?因为你玩家身上现在根本就没有装备 你要怎么脱呢?因此当concurrency设置的值超过1的时候都可能会出现消息消费顺序有误的问题。

因此我们如果想要保证消费的消息严格的按照队列里面添加的消息顺序来执行,那么必须要把concurrency设置成1

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

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

相关文章

小剧场短剧影视小程序源码_后端PHP

项目运行截图 源码贡献 https://githubs.xyz/boot?app42 部署说明 linux/win任选 PHP版本&#xff1a;7.3/7.2&#xff08;测试时我用的7.2要安装sg扩展 &#xff09; 批量替换域名http://video.owoii.com更换为你的 批量替换域名http://120.79.77.163:1更换为你的 这两个…

代码随想录算法训练营第60天|84.柱状图中最大的矩形

84. 柱状图中最大的矩形 题目链接&#xff1a;柱状图中最大的矩形 题目描述&#xff1a;给定 n 个非负整数&#xff0c;用来表示柱状图中各个柱子的高度。每个柱子彼此相邻&#xff0c;且宽度为 1 。 求在该柱状图中&#xff0c;能够勾勒出来的矩形的最大面积。 解题思路&#…

24 JavaScript学习:this

this在对象方法中 在 JavaScript 中&#xff0c;this 的值取决于函数被调用的方式。在对象方法中&#xff0c;this 引用的是调用该方法的对象。 让我们看一个简单的例子&#xff1a; const person {firstName: John,lastName: Doe,fullName: function() {return this.firstN…

【webrtc】MessageHandler 3: 基于线程的消息处理:以sctp测试为例

消息处理可以用于模拟发包处理G:\CDN\rtcCli\m98\src\net\dcsctp\socket\dcsctp_socket_network_test.cc 这个实现中,onMessage还是仅对了一种消息进行处理,就是接收则模式下,打印带宽。当然,可能程序有多个消息,分别在不同的onmessage中执行?SctpActor:以一个恒定的速率…

C语言贪吃蛇项目

今天给大家带来一款简单的贪吃蛇游戏&#xff0c;一起随我来看看吧 游戏效果&#xff1a; 实现基本的功能&#xff1a; • 贪吃蛇地图绘制 • 蛇吃⻝物的功能&#xff1a;&#xff08;上、下、左、右⽅向键控制蛇的动作&#xff09; • 蛇撞墙死亡 • 蛇撞⾃⾝死亡 • 计算得分…

Flink 实时数仓(一)【实时数仓离线数仓对比】

前言 昨天技术面的时候&#xff0c;面试官说人家公司现在用的都是最新的技术&#xff0c;比如 Doris 等一些最新的工具&#xff0c;确实这些课是学校永远不会开设的&#xff0c;好在他说去了会带着我做一做。可是 ...... 学院这边确实不允许放人&#xff0c;唉&#xff0c;可惜…

Kubernetes 弃用Docker后 Kubelet切换到Containerd

containerd 是一个高级容器运行时&#xff0c;又名 容器管理器。简单来说&#xff0c;它是一个守护进程&#xff0c;在单个主机上管理完整的容器生命周期&#xff1a;创建、启动、停止容器、拉取和存储镜像、配置挂载、网络等。 containerd 旨在轻松嵌入到更大的系统中。Docke…

python项目入门新手攻略

最近工作需要接手了代码量比较大的python开发的项目&#xff0c;平时写python不多&#xff0c;记录一下如何熟悉项目。 分析调用流程-pycallgraph 因为代码量比较大&#xff0c;所以希望通过工具生成代码调用流程&#xff0c;因此用到了pycallgraph。 pycallgraph&#xff0…

windows Jenkins运行python+selenium打开浏览器一直无响应,运行中,还没有打开浏览器

一开始解决办法是把打开服务把Jenkins给禁用了 但是没有用&#xff0c;然后找到安装目录 C:\Program Files\Jenkins 在这个路径下&#xff0c;在地址栏输入cmd打开命令窗口运行Jenkins启动命令 java -jar jenkins.war --httpPort8080 打开浏览器进入链接 http://localhost:…

【Unity学习笔记】第十四 Prefab 概念解惑

目录 1 prefab、prefab变体、prefab覆盖和prefab 嵌套2 connect 与unpack3 prefab到底是什么&#xff0c;它和gameobject又有什么区别&#xff1f;4 为什么要用prefab&#xff1f;5 代码动态加载prefab6 为什么我unity PrefabUtility.InstantiatePrefab() 得到的是null7 Prefab…

Redis基本命令

目录 一、包含String、Set数据类型的基本命令 1、添加一个键值对 2、获取key所关联的字符串值 3、同时设置多个key-value 4、获取多个key对应的值 运行结果 5、将给定的value追加到原值的末尾 追加后效果 6、删除单个key 7、同时删除多个key 8、查询包含某个字符的k…

ubuntu入门

基础命令 cd 切换命令 ls 查看当前目录下所有的文件 cp a.c b.c 拷贝a.c 到 b.c touch a.c 创建a.c文件 mkdir file 创建文件夹file rm file 删除文件 rmdir 删除test文件夹 rmdir test/ mv 移动文件 mv a.c b.c 把a.c 替换成b.c ifconfig 查看电脑网络信息 rm xx 删…

Mybatis进阶(动态SQL)

文章目录 1.动态SQL1.基本介绍1.为什么需要动态SQL2.基本说明3.动态SQL常用标签 2.环境搭建1.新建子模块2.删除不必要的两个文件夹3.创建基本结构4.父模块的pom.xml5.jdbc.properties6.mybatis-config.xml7.MyBatisUtils.java8.MonsterMapper.java9.MonsterMapper.xml10.测试Mo…

工业互联网通讯协议—欧姆龙(Fins tcp)

一、场景 近期公司要对欧姆龙CP系列设备的数据采集&#xff0c;于是就研究了下欧姆龙的Fins Tcp协议。 二、Fins Tcp 组成字节说明固定头446494E53 FINS对应的ASCII码的十六进制长度4后面剩余指令的长度命令4 握手固定为&#xff1a;00000000 读写固定为&#xff1a;0000000…

Unity 实现新手引导遮罩

Unity 复写OnPopulateMesh 实现新手引导遮罩、包含点击事件触发区域判断 https://download.csdn.net/download/shenliang34/89247117

【第3节】“茴香豆“:搭建你的 RAG 智能助理

目录 1 基础知识1.1.RAG技术的概述1.2 RAG的基本结构有哪些呢&#xff1f;1.3 RAG 工作原理&#xff1a;1.4 向量数据库(Vector-DB )&#xff1a;1.5 RAG常见优化方法1.6RAG技术vs微调技术 2、茴香豆介绍2.1应用场景2.2 场景难点2.3 茴香豆的构建&#xff1a; 3 论文快读4 实践…

15(第十四章,大数据和数据科学)

目录 概述 基本概念 数据仓库/传统商务智能与数据科学的比较 数据科学的过程 大数据 大数据来源 数据湖 机器学习 监督学习 无监督学习 强化学习 扩展 1、数据仓库&#xff08;Data Warehouse&#xff09; 2、数据湖(Data Lake) 3、大数据平台1.0 4、数据中台 …

外贸企业邮箱是什么?Zoho Mail——你的专业外贸邮局

外贸企业邮箱是什么&#xff1f;做外贸行业必须要有企业邮箱吗&#xff1f;这是一些外贸企业的困惑。外贸企业邮箱和我们平时使用的个人邮箱有着几方面的不同。一是安全稳定&#xff1b;二是功能丰富性&#xff1b;三是存储空间更大。Zoho Mail企业邮箱在这些方面都能满足外贸企…

OpenCV如何实现背投(58)

返回:OpenCV系列文章目录&#xff08;持续更新中......&#xff09; 上一篇&#xff1a;OpenCV直方图比较(57) 下一篇&#xff1a;OpenCV如何模板匹配(59) 目标 在本教程中&#xff0c;您将学习&#xff1a; 什么是背投以及它为什么有用如何使用 OpenCV 函数 cv::calcBackP…

Java 获取 Outlook 邮箱的日历事件

Java 获取 Outlook 邮箱的日历事件 1.需求描述2.实现方案3.运行结果 IDE&#xff1a;IntelliJ IDEA 2022.3.3 JDK&#xff1a;1.8.0_351 Outlook&#xff1a;Microsoft Office 2016 1.需求描述 比如现在需要获取 Outlook 邮箱中四月的全部的会议安排&#xff0c;如下图所示 …