当前位置：首页 > news >正文

Spring Boot集成RabbitMQ高级篇：可靠性与性能提升

news 来源：原创 2025/7/21 6:13:59

一、环境准备

安装 RabbitMQ
- 在官网上下载对应操作系统的安装包（如 Windows、Linux 等），按照安装向导完成安装。
- 安装完成后，启动 RabbitMQ 服务。在 Windows 系统下，可以在服务列表中找到 RabbitMQ Server 并启动；在 Linux 系统下，可以通过命令行启动，例如使用 systemctl start rabbitmq-server（具体命令可能因 Linux 发行版而异）。
- 默认情况下，RabbitMQ 使用 5672 端口进行通信。可以通过浏览器访问 http://localhost:15672（默认用户名和密码是 guest/guest）来访问 RabbitMQ 的管理界面，查看队列、交换机等信息。
添加 Spring Boot 依赖
- 在 Spring Boot 项目的 pom.xml 文件中添加 RabbitMQ 相关依赖。例如：
```
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
```
  这个依赖会自动引入 RabbitMQ 的客户端库以及 Spring AMQP（高级消息队列协议）相关的模块，方便我们在 Spring Boot 中操作 RabbitMQ。

二、配置 RabbitMQ

在 application.properties 或 application.yml 文件中配置
- application.properties 示
```
spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest
```
  这里配置了 RabbitMQ 服务器的地址、端口以及登录的用户名和密码。如果 RabbitMQ 服务器部署在其他机器上，需要将 localhost 替换为对应的 IP 地址。
- application.yml 示例
```
spring:rabbitmq:host: localhostport: 5672username: guestpassword: guest
```
高级配置（可选）
- 连接池配置 如果应用需要频繁地与 RabbitMQ 交互，可以通过配置连接池来提高性能。例如
```
spring.rabbitmq.listener.simple.concurrency=3
spring.rabbitmq.listener.simple.max-concurrency=10
```
  这里设置了消费者线程池的最小线程数为 3，最大线程数为 10，可以根据实际业务需求调整这些参数。
- 消息确认机制配置 为了确保消息可靠地发送到 RabbitMQ 服务器，可以开启消息确认机制
```
spring.rabbitmq.publisher-confirms=true
```
  当消息成功发送到 RabbitMQ 服务器后，服务器会发送确认消息给生产者。

三、生产者代码实现

创建 RabbitMQ 配置类（可选）

如果需要自定义一些 RabbitMQ 的配置，如交换机、队列等，可以创建一个配置类。例如

import org.springframework.amqp.core.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;@Configuration
public class RabbitMQConfig {// 定义队列@Beanpublic Queue myQueue() {return new Queue("myQueue", true); // 第二个参数表示是否持久化}// 定义交换机@Beanpublic DirectExchange myExchange() {return new DirectExchange("myExchange", true, false);}// 绑定队列和交换机@Beanpublic Binding myBinding() {return BindingBuilder.bind(myQueue()).to(myExchange()).with("myRoutingKey");}
}

在这个例子中，定义了一个名为 myQueue 的队列、一个名为 myExchange 的直连交换机（DirectExchange），并通过路由键 myRoutingKey 将队列绑定到交换机。

创建生产者类

使用 RabbitTemplate 来发送消息。例如：

import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;@Component
public class RabbitMQProducer {@Autowiredprivate RabbitTemplate rabbitTemplate;public void sendMessage(String message) {rabbitTemplate.convertAndSend("myExchange", "myRoutingKey", message);}
}

在这个例子中，通过调用 sendMessage 方法，将消息发送到名为 myExchange 的交换机，并指定路由键为 myRoutingKey。RabbitMQ 会根据路由键将消息路由到对应的队列。

四、消费者代码实现

创建消费者类

使用 @RabbitListener 注解来监听队列中的消息。例如：

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;@Component
public class RabbitMQConsumer {@RabbitListener(queues = "myQueue")public void receiveMessage(String message) {System.out.println("Received message: " + message);}
}

在这个例子中，RabbitListener 注解指定了要监听的队列名为 myQueue。当有消息到达该队列时，receiveMessage 方法会被调用，并打印接收到的消息。

手动确认消息（可选）

默认情况下，Spring Boot 使用自动确认模式，即消费者接收到消息后，RabbitMQ 会自动认为消息已被成功处理。如果需要手动确认消息，可以在配置类中设置：

spring.rabbitmq.listener.simple.acknowledge-mode=manual

然后在消费者代码中，通过 Channel 手动确认消息：

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.stereotype.Component;
import com.rabbitmq.client.Channel;@Component
public class RabbitMQConsumer {@RabbitListener(queues = "myQueue")public void receiveMessage(String message, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long tag) throws Exception {System.out.println("Received message: " + message);// 手动确认消息channel.basicAck(tag, false);}
}

在这个例子中，通过 Channel 的 basicAck 方法手动确认消息。如果消息处理失败，可以调用 basicNack 方法拒绝消息。

五、测试

启动项目
- 启动 Spring Boot 项目，确保 RabbitMQ 服务也在运行。

发送消息

在代码中调用生产者类的 sendMessage 方法，发送一条消息。例如：

@SpringBootApplication
public class RabbitMQApplication {public static void main(String[] args) {ConfigurableApplicationContext context = SpringApplication.run(RabbitMQApplication.class, args);RabbitMQProducer producer = context.getBean(RabbitMQProducer.class);producer.sendMessage("Hello, RabbitMQ!");}
}

查看消费者输出
- 观察消费者类的控制台输出，确认是否成功接收到消息。如果一切正常，应该能看到类似以下的输出：
  Received message: Hello, RabbitMQ!

通过以上步骤，就可以完成 Spring Boot 整合 RabbitMQ 的基本操作，实现消息的发送和接收。

Spring Boot集成RabbitMQ高级篇：可靠性与性能提升

一、环境准备安装 RabbitMQ 在官网上下载对应操作系统的安装包（如 Windows、Linux 等），按照安装向导完成安装。安装完成后，启动 RabbitMQ 服务。在 Windows 系统下，可以在服务列表中找到 RabbitMQ Server 并启动&am…...

编程日记 2025/7/21 6:13:59

Shell脚本编程3（函数+正则表达式）

1.函数 1.1 定义简单来讲，所谓函数就是把完成特定功能，并且多次使用的一组命令或者语句封装在一个固定的结构中，这个结构我们就叫做函数。从本质上讲，函数是将一个函数名与某个代码块进行映射。也就是说，用户在定义了…...

编程日记 2025/7/21 1:30:40

【C++】语言深处的“精灵”：探索内存的奥妙

这里我们要知道，我们编写一个程序，这个程序中的变量是存储在哪个区域的栈一般是用于静态的分配内存的，但也可以动态的分配内存， 堆是用于动态的分配内存的，不能静态的分配内存栈： 通常是向低地址方向…...

编程日记 2025/7/21 0:02:40

c语言第一个小游戏：贪吃蛇小游戏03

我们为贪吃蛇的节点设置为一个结构体，构成贪吃蛇的身子的话我们使用链表，链表的每一个节点是一个结构体显示贪吃蛇身子的一个节点我们这边node就表示一个蛇的身体就是一小节输出结果如下显示贪吃蛇完整身子效果如下代码实现这个hasSnakeNode(…...

编程日记 2025/7/21 0:05:56

51 单片机头文件 reg51.h 和 reg52.h 详解

51 单片机头文件详解 51 单片机的头文件reg51.h和reg52.h是开发中非常重要的文件，它们定义了单片机的特殊功能寄存器 (SFR) 和位地址。以下是对这两个头文件的详细解析： 1. 头文件概述 reg51.h：针对标准 8051 单片机（4KB ROM, 128B RAM） reg52.h：针对增强型 8052 单片…...

编程日记 2025/7/20 15:03:51

让 - 艾里克・德布尔与斯普林格出版公司：科技变革下的出版业探索

在数字化浪潮席卷全球的当下，传统出版行业面临着前所未有的挑战与机遇。《对话 CTO，驾驭高科技浪潮》的第 10 章聚焦于让 - 艾里克・德布尔（Jean - Eric Debeure）及其所在的斯普林格出版公司（Springer Publishing Comp…...

编程日记 2025/7/19 9:31:02

[python] 面向对象的三大特性-封装及新式类

一继承继承是指一个类（子类）可以继承另一个类（父类）的属性和方法，并可以在其基础上进行扩展或修改。子类可以继承父类的属性和方法,包括私有属性和隐藏属性 💡 核心思想： 避免重复代码&…...

编程日记 2025/7/15 23:44:15

winreg查询Windows注册表的一些基本用法

注册表是Windows操作系统中用于存储配置信息的数据库。它包含了关于系统硬件、已安装的应用程序、用户账户设置以及系统设置的信息。特别地，当我们需要某些软件的配置配息时，主要在HKEY_CURRENT_USER和HKEY_LOCAL_MACHINE下的SoftWare内进行查询操作。 …...

编程日记 2025/7/15 14:09:25

DHCP自动分配IP 练习1 路由器 Router>en Router#conf t Router(config)#ip dhcp pool ip10 //创建DHCP地址池 Router(dhcp-config)#network 192.168.20.0 255.255.255.0 // 配置网络地址和子网掩码 Router(dhcp-config)#default-router 192.168.20.254 //配置默认网关 Rou…...

编程日记 2025/7/18 12:50:33

互联网大厂Java求职面试实战：Spring Boot与微服务场景深度解析

💪🏻 1. Python基础专栏，基础知识一网打尽，9.9元买不了吃亏，买不了上当。 Python从入门到精通 😁 2. 毕业设计专栏，毕业季咱们不慌忙，几百款毕业设计等你选。 ❤️ 3. Python爬虫专栏…...

编程日记 2025/7/14 14:08:36

TDengine 在金融领域的应用

简介金融行业正处于数据处理能力革新的关键时期。随着市场数据量的爆炸式增长和复杂性的日益加深，金融机构面临着寻找能够高效处理大规模、高频次以及多样化时序数据的大数据处理系统的迫切需求。这一选择将成为金融机构提高数据处理效率、优化交易响应时间、提高…...

编程日记 2025/7/15 9:39:15

十三、动态对象创建（Dynamic Object Creation）

十三、动态对象创建（Dynamic Object Creation） 目录 13.1 对象创建（Object creation）13.2 new / delete 操作符13.3 数组的 new 与 delete13.4 总结背景说明有时候我们需要知道程序中对象的数量、类型和声明周期，…...

编程日记 2025/7/19 23:49:53

cursor Too many报错显示锁机器码怎么办？也就是Cursor的

22. Too many报错显示锁机器码怎么办？也就是Cursor的文档出自：https://www.kdocs.cn/l/cp5GpLHAWc0p...

编程日记 2025/7/16 4:56:46

window 显示驱动开发-将虚拟地址映射到内存段（二）

在将虚拟地址映射到段的一部分之前，视频内存管理器调用显示微型端口驱动程序的 DxgkDdiAcquireSwizzlingRange 函数，以便驱动程序可以设置用于访问可能重排的分配位的光圈。驱动程序既不能将偏移量更改为访问分配的 PCI 光圈，也不能更改分配…...

编程日记 2025/7/18 20:15:11

Linux 软硬连接详解

目录一、软链接（Symbolic Link） ‌定义与特性 ‌实现方法‌使用 ln -s 命令： 二、硬链接（Hard Link） 1、是什么 2、工作机制 3、实现方式一、软链接（Symbolic Link） ‌定义与特性定义…...

编程日记 2025/7/20 23:58:20

虚拟主机与独立服务器：哪个更好？

在选择网站主机提供商时，你可以选择独立服务器或者与其他用户共同使用的虚拟主机。这个决定不仅仅是基于价格，还有很多其他因素需要考虑。接下来，我们就来详细了解一下虚拟主机和独立服务器的区别。虚拟主机和独立服务器的区别独立服务器是…...

编程日记 2025/7/17 4:11:00

MiMo-7B-RL调研

结论 MiMo 在数学推理和代码竞赛的评测中表现出色，但是相较于 OpenAI 的 o1-mini 和阿里的 QwQ-32B-Preview 等更大规模的模型，推理耗时更长（4 到 10 倍），花费 Token 更多。链接开源地址: https://huggingface.co/…...

编程日记 2025/7/21 0:18:22

vue-i18n 优化

语言包管理优化： 当前语言包文件（en.json 和 zh.json）过大，建议按模块拆分建议的目录结构： src/assets/i18n/ ├── modules/ │ ├── common/ │ ├── dashboard/ │ ├── report/ │ └── system/ …...

编程日记 2025/7/21 3:55:37

全栈工程师实战手册：LuatOS日志系统开发指南！

本文聚焦LuatOS-log库的实战应用场景，通过完整案例演示日志模块集成、格式定制及远程同步方案，帮助全栈开发者构建灵活可靠的日志管理框架。下面，我们一起来认识LuatOS的log库！ 一、 log.info() log info()主要打印一些正常的…...

编程日记 2025/7/20 17:59:58

Java知识库网站整理

本文主要推荐一些高质量的Java知识库和学习网站，涵盖了从基础到高级的Java技术，包括JVM底层原理、框架源码分析、面试题集、全栈知识体系等。如果你有其他优秀的Java学习网站推荐，欢迎在评论区分享！ 如遇到以下网站不能打开请检查…...

编程日记 2025/7/18 15:39:15

详解 IRC协议及客户端工具 WeeChat 的使用

本文将详细介绍 Internet Relay Chat（IRC）协议及其历史、基本概念、核心功能，以及流行的 IRC 客户端 WeeChat 的安装、配置和使用方法。内容力求准确、详尽，涵盖 IRC 的技术背景、使用场景，以及 WeeChat 的高级功能和实…...

编程日记 2025/7/17 12:47:56

数据出境的安全合规思考

数据已成为新型国家战略性资产，其经济和战略价值在全球数字经济发展中愈加凸显。跨境数据流动既是重要的经济纽带，又是新兴的经济秩序博弈焦点，对于推动经济全球化发展意义重大。然而，跨境数据流动也面临诸多问题与挑战&#xff0…...

编程日记 2025/7/20 23:58:04

【技巧】使用frpc点对点安全地内网穿透访问ollama服务

回到目录【技巧】使用frpc点对点安全地内网穿透访问ollama服务 0. 为什么需要部署内网穿透点对点服务在家里想访问单位强劲机器，但是单位机器只能单向访问互联网，互联网无法直接访问到这台机器。通过在云服务器、单位内网服务器、源端访问机器上&am…...

编程日记 2025/7/18 1:05:56

Go语言即时通讯系统开发日志day1

Go语言即时通讯系统开发日志day1，主要模拟实现的一个简单的发送消息和接受消息的小demo，因为也才刚学习go语言的语法，对go的json、net/http库了解不多，所以了解了一下go语言的encoding/json库和net/http库，以及websock…...

编程日记 2025/7/20 21:28:57

多线程访问Servlet如何谨慎处理共享资源

1. 避免共享状态（最佳实践） 核心思想：Servlet 本身应设计为无状态（Stateless），不依赖实例变量存储请求相关数据。实现方式： 将变量声明在方法内部（局部变量）&#xff0…...

编程日记 2025/7/20 10:34:27

OpenMCU(六)：STM32F103开发板功能介绍

概述距上一篇关于STM32F103的FreeRTOS博客的发布已经过去很长时间没有更新了。在这段时间内，大家可以看到博主发表了一系列的关于使用qemu 模拟实现STM32F103的博客，博主本来想借助qemu开发stm32F103相关的一些软件功能，博主开发出来并成功运…...

编程日记 2025/7/20 4:04:45

运用数组和矩阵对数据进行存取和运算——NumPy模块之五

目录 NumPy模块介绍 3.5.1 NumPy 操纵数组元素的逻辑 3.5.2 添加数组元素操作 1. append() 函数 2. insert() 函数 3.5.3 删除数组元素的操作 delete() 函数 3.5.4 数组元素缺失情况的处理 isnan() 函数 3.5.5 处理数组中元素重复情况 unique() 函数 3.5.6 拼接数组操作 1. con…...

编程日记 2025/7/15 15:59:30

AI Agent开发第64课-DIFY和企业现有系统结合实现高可配置的智能零售AI Agent

开篇我们之前花了将近10个篇章讲Dify的一些基础应用，包括在讲Dify之前我们讲到了几十个AI Agent的开发例子，我不知道大家发觉了没有，在AI Agent开发过程中我们经常会伴随着这样的一些问题：需要经常改猫娘；需要经常改调用LLM的参数，甚至在一个流程中有3个节点，每个节点…...

编程日记 2025/7/19 14:43:51

日志 Slf4j , Java 中使用

// 示例代码package biz.baijing.controller;import biz.baijing.pojo.Result; import lombok.extern.slf4j.Slf4j; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.w…...

编程日记 2025/7/21 5:25:11

一、环境准备

二、配置 RabbitMQ

三、生产者代码实现

四、消费者代码实现

五、测试

相关文章：