SpringBoot中整合RabbitMQ（测试+部署上线 最完整）

news/2025/1/19 19:23:29/

目录

一、RabbitMQ安装

二、启动RabbitMQ

三、编写Java代码

1、引入依赖

2、配置yml

3、配置消息转换器

4、编写接收方接收消息

5、编写发送方发送消息

6、小程序验证

三、宝塔中安装RabbitMQ

1、下载erlang

（1）查看rabbitmq的版本

（2）查找erlang兼容版本

（3）安装RPM包

2、前往宝塔面板

3、安装RabbitMQ

四、docker中安装rabbitmq

1、安装docker

2、配置docker镜像加速

3、拉取RabbitMQ镜像

4、运行RabbitMQ

5、查看镜像和容器

6、开放客户端服务

7、登录RabbitMQ客户端

8、创建虚拟主机

五、部署项目验证

六、拓展使用

一、RabbitMQ安装

由于在测试环境中，我们现在虚拟机上基于docker安装mq

docker run

-e RABBITMQ_DEFAULT_USER=quick
-e RABBITMQ_DEFAULT_PASS=123
-v mq-plugins:/plugins
–name mq
–hostname mq
-p 15672:15672
-p 5672:5672
–network your-net
-d
rabbitmq:3.8-management

在docker环境上运行改指令

前两个是登录的用户名密码

network是连接的网络，如果用默认网络的话就不需要写

最后一个是版本，这个是目前测试的版本

二、启动RabbitMQ

由于目前是测试阶段，这里我使用之前学习的时候的版本。

创建新用户后重新登陆，然后创建一个单独的 _Virtual Hosts （虚拟主机）_来进行隔离。

三、编写Java代码

1、引入依赖
        <!--rabbitmq--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId></dependency>
2、配置yml
spring:rabbitmq:host: ${quick.rabbitmq.host}port: ${quick.rabbitmq.port} # 端口virtual-host: ${quick.rabbitmq.virtual-host} # 虚拟主机username: ${quick.rabbitmq.username} # 用户名password: ${quick.rabbitmq.password} # 密码quick:rabbitmq:host: 192.168.75.101 #服务器ip地址（此处为虚拟机地址）port: 5672 # 端口virtual-host: /xxx # 虚拟主机username: xxx # 用户名password: xxx # 密码listener:simple:acknowledge-mode: auto # 自动ackretry:enabled: true # 开启消费者失败重试initial-interval: 1000ms # 初识的失败等待时长为1秒multiplier: 1 # 失败的等待时长倍数，下次等待时长 = multiplier * last-intervalmax-attempts: 3 # 最大重试次数stateless: false # true无状态；false有状态。如果业务中包含事务，这里改为falsepublisher-confirm-type: CORRELATED # 交换机的确认publisher-returns: true # 队列的确认
3、配置消息转换器
/*** 配置消息转换器*/
@Configuration
@ConditionalOnClass(RabbitTemplate.class) //有RabbitTemplate依赖才会生效，否则不生效
public class MqConfig {@Beanpublic MessageConverter messageConverter(){//使用json序列化发送消息return new Jackson2JsonMessageConverter();}
}
4、编写接收方接收消息

/*** 接收消息*/
@Component
@RequiredArgsConstructor
public class StoreListener {private final IStoreService storeService;@RabbitListener(bindings = @QueueBinding(value = @Queue(name = "store.addFavorite.success.queue", durable = "true"), // 队列 起名规则（服务名+业务名+成功+队列），durable持久化exchange = @Exchange(name = "addFavorite.direct"), // 交换机名称，交换机默认类型就行direct，所以不用配置directkey = "addFavorite.success" // 绑定的key))public void listenAddFavoriteCountsSuccess(Long storeId){storeService.updateStoreFavoriteUsersCountAdd1(storeId);}}

虽然代码里面也已经解释了，但是下面也再解释一下：

value：是队列信息。起名规则（服务名+业务名+成功+队列），durable表示持久化

exchange：是交换机名称。起名规则是（业务名+direct），和发送方一致

key：绑定的key。起名规则是（业务名+success），表示成功的key，和发送方一致

起名规则是个人而定

5、编写发送方发送消息

@Transactional@Overridepublic void add(Long storeId) {Favorite favorite = Favorite.builder().storeId(storeId).userId(BaseContext.getCurrentId()).build();Favorite one = Db.getOne(favorite);if (one!=null){throw new FavoriteException(MessageConstant.COLLECTION_BE_REPEAT);}// 更新收藏表favoriteMapper.insert(favorite);// 更新商品表,收藏数+1//storeService.updateStoreFavoriteUsersCountAdd1(storeId);// 发送消息 (交换机+绑定的key和发送的消息)try {rabbitTemplate.convertAndSend("addFavorite.direct","addFavorite.success",storeId);} catch (Exception e) {log.error("发送添加收藏消息失败，店铺id：{}",storeService,e);}}

虽然代码里面也已经解释了，但是下面也再解释一下：

“addFavorite.direct”：是交换机名称，和接收方一致

“addFavorite.success”：是绑定的key，和接收方一致

storeId：是发送的信息

6、小程序验证

点击收藏。

在RabbitMQ的界面中队列也有一条消息出现，说明mq实现异步通讯成功。

该案例是收藏商品后完成收藏表插入语句后，还要去商品表更新商品表，更新该商品的被收藏数加一，但是如果同步通讯的话，响应会有延迟，可能会对性能造成一定影响，但是通过异步通讯,不需要实时响应，就会对性能有一定的优化。

三、宝塔中安装RabbitMQ

1、下载erlang

RabbitMQ服务端是由并发式语言Erlang编写的，所以安装RabbitMQ的之前需要安装Erlang，保证所需要的环境。

安装之前注意版本兼容问题：Erlang Version Requirements | RabbitMQ

安装erlang地址：https://www.erlang-solutions.com/downloads/#

rabbitmq_249">（1）查看rabbitmq的版本

先去宝塔查看rabbitmq的版本：

（2）查找erlang兼容版本

然后去找到版本兼容的erlang版本：Erlang Version Requirements | RabbitMQ

（3）安装RPM包

去下载：https://www.erlang-solutions.com/downloads/#

下载后拿到rpm文件：

注意：这里没有下载的版本，下载需要与自己的版本一致，如果发现启动不了RabbitMQ，请看后面的启动RabbitMQ。

注意！注意！注意！

2、前往宝塔面板

进入tmp目录，将之前的rpm包放进去。

3、安装RabbitMQ

在软件商店中安装RabbitMQ

出现问题：

看到报错日志，我又去下载报错日志里面的版本。

再次去：https://www.erlang-solutions.com/downloads/#

我是centos7，所以下载该版本。那边有点不人性化，我尝试了几次才下载到自己的版本。

将之前的哪个rmp文件删掉，再将刚刚下载的rpm文件重命名再次放入tmp目录中

上面我重命名错了，只记得修改后面，下面是再次修改后的结果。

卸载rabbitmq，然后再重新安装一次。

还是出现报错：

出现了这个报错，很莫名其妙，然后我就去用docker安装，有解决办法的可以评论一下。

在其他教程到这一步已经可以了，可以参考下面两篇博客：

宝塔面板安装RabbitMQ（已解决）_宝塔安装rabbitmq-CSDN博客

宝塔安装rabbitMQ实战-CSDN博客

rabbitmq_329">四、docker中安装rabbitmq

1、安装docker
2、配置docker镜像加速
# 创建目录
mkdir -p /etc/docker# 复制内容，注意把其中的镜像加速地址改成你自己的
tee /etc/docker/daemon.json <<-'EOF'
{"registry-mirrors": ["http://hub-mirror.c.163.com","https://mirrors.tuna.tsinghua.edu.cn","http://mirrors.sohu.com","https://ustc-edu-cn.mirror.aliyuncs.com","https://ccr.ccs.tencentyun.com","https://docker.m.daocloud.io","https://docker.awsl9527.cn"]
}
EOF# 重新加载配置
systemctl daemon-reload# 重启Docker
systemctl restart docker
3、拉取RabbitMQ镜像
docker pull rabbitmq

4、运行RabbitMQ
docker run

-e RABBITMQ_DEFAULT_USER=quick
-e RABBITMQ_DEFAULT_PASS=quick
-v mq-plugins:/plugins
–name mq
–hostname mq
-p 15672:15672
-p 5672:5672
-d
rabbitmq

5、查看镜像和容器
docker images
docker ps

到这里已经是成功在docker中装好mq容器了

但是在我访问http://主机ip:15672的时候却无法访问，即使我开放了服务器的安全组。后来猜到应该是客户端服务可能是没开启，在之前宝塔软件里面好像有看过这个东西。

6、开放客户端服务

在mq容器中打开终端

列出所有可用的插件：

rabbitmq-plugins list

找到rabbitmq_management：

开启rabbitmq_management：

rabbitmq-plugins enable rabbitmq_management

然后再访问客户端，成功访问：

7、登录RabbitMQ客户端

这里显示有些特性标志未开启，我们可以去开启那些标志。

参考博客：Docker RabbitMQ安装_all stable feature flags must be enabled after com-CSDN博客

8、创建虚拟主机

创建一个单独的虚拟主机来进行隔离，这里可以参考前面在虚拟机上的操作。

9、关于图形化界面可能出现的问题

Stats in management UI are disabled on this node

可以参考这篇博客：

RabbitMQ客户端界面问题 Stats in management UI are disabled on this node-CSDN博客

五、部署项目验证

参考我之前的博客：记录部署项目《庆自提》完整流程-CSDN博客

修改yml配置文件，修改下面的消息：

  rabbitmq:host: ${quick.rabbitmq.host}port: ${quick.rabbitmq.port} # 端口virtual-host: ${quick.rabbitmq.virtual-host} # 虚拟主机username: ${quick.rabbitmq.username} # 用户名password: ${quick.rabbitmq.password} # 密码

在已经上线的小程序测试~~

目前只有一个人收藏，现在去测试一下。

收藏成功，去看一下数据库，查看是否更新。

去查看mq客户端：

成功更新，说明使用RabbitMQ实现异步通讯成功。

六、拓展使用

关于一些拓展使用可以参考以下这些博客：

RabbitMQ实现多线程处理接收消息-CSDN博客

在配置mq过程中遇到许许多多的bug和问题，改了很久很久，如果里面有哪些不足的欢迎指正和建议！！！


http://www.ppmy.cn/news/1564486.html

相关文章

【数据分析与可视化】Python绘制数据地图-GeoPandas地图可视化

【数据分析与可视化】Python绘制数据地图-GeoPandas地图可视化

本文主要介绍GeoPandas结合matplotlib实现地图的基础可视化。GeoPandas是一个Python开源项目&#xff0c;旨在提供丰富而简单的地理空间数据处理接口。GeoPandas扩展了Pandas的数据类型&#xff0c;并使用matplotlib进行绘图。GeoPandas官方仓库地址为&#xff1a;GeoPandas。G…
阅读更多...
Next.js 与 React.js 的对比分析

Next.js 与 React.js 的对比分析

核心区别的理解React.js 是一个专注于构建 UI 组件的库&#xff0c;它灵活但需要自行搭配其他工具&#xff08;如 React Router&#xff09;才能构建完整的应用。而 Next.js 则是在 React 基础上发展出来的框架&#xff0c;自带服务端渲染&#xff08;SSR&#xff09;、静态站点…
阅读更多...
Python基于matplotlib和plottable库绘制精美表格

Python基于matplotlib和plottable库绘制精美表格

在Python中&#xff0c;matplotlib 是一个强大的绘图库&#xff0c;但它本身并不直接支持创建精美的表格。然而&#xff0c;你可以使用 matplotlib 的 table 功能来在图表中嵌入表格。此外&#xff0c;plottable 并不是一个广泛认知的与 matplotlib 直接相关的库&#xff08;至…
阅读更多...
基于docker微服务日志ELK+Kafka搭建

基于docker微服务日志ELK+Kafka搭建

ELK 是 Elasticsearch 、 Logstash 、 Kibana 的简称 Elasticsearch 是实时全文搜索和分析引擎&#xff0c;提供搜集、分析、存储数据三大功能&#xff1b;是一套开放 REST 和 JAVA API 等结构提供高效搜索功能&#xff0c;可扩展的分布式系统。它构建于 Apache Lucene 搜索引…
阅读更多...
在 Windows 上，如果忘记了 MySQL 密码 重置密码

在 Windows 上，如果忘记了 MySQL 密码 重置密码

在 Windows 上&#xff0c;如果忘记了 MySQL 密码&#xff0c;可以通过以下方法重置密码&#xff1a; 方法 1&#xff1a;以跳过权限验证模式启动 MySQL 并重置密码 停止 MySQL 服务&#xff1a; 打开 命令提示符 或 PowerShell&#xff0c;输入以下命令停止 MySQL 服务&#…
阅读更多...
ChatGPT升级AI私人助理功能：新增定时播报全网热点与定制每日学习健身计划

ChatGPT升级AI私人助理功能：新增定时播报全网热点与定制每日学习健身计划

ChatGPT 可以通过 Tasks 功能&#xff0c;设置发送每周全球新闻简报、提供每日 15 分钟健身计划、设置语言学习等任务提醒、发送每日笑话、创建每日晚餐计划、提醒生日等重要事件。 1 月 15 日消息&#xff0c;OpenAI 公司今天在 X 平台发布推文&#xff0c;宣布以测试版形式&a…
阅读更多...
线上工单引发的思考：Spring Boot 中 @Autowired 与 @Resource 的区别

线上工单引发的思考：Spring Boot 中 @Autowired 与 @Resource 的区别

最近接手了离职同事负责的业务&#xff0c;在处理一个线上工单的时候&#xff0c;看了下历史逻辑&#xff0c;在阅读他们写的代码时&#xff0c;发现他们竟然把Autowired和Resource注解混用。今天就借此机会聊聊SpringBoot项目中这两者之间的区别。 1. 注解来源 Autowired&am…
阅读更多...
初步认识 Neo4j 图数据库

初步认识 Neo4j 图数据库

Neo4j 是一种高性能的图数据库管理系统&#xff0c;基于图论设计&#xff0c;能够高效地存储和查询复杂的关系数据。以下是关于 Neo4j 的详细介绍&#xff1a; 核心特性 数据模型&#xff1a; Neo4j 使用图数据模型&#xff0c;将数据以节点&#xff08;Node&#xff09;、关系…
阅读更多...
最新文章

Copyright @ 2022~2023