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

Spring Boot 消息队列（以RabbitMQ为例）

news 来源：原创 2025/9/11 18:01:58

文章目录

- - RabbitMQ 简介与安装
  - - 1. RabbitMQ 简介
    - 2. RabbitMQ 安装
  - Spring Boot 集成 RabbitMQ
  - - 1. 创建 Spring Boot 项目
    - 2. 配置 RabbitMQ
    - 3. 定义消息队列和交换机
    - 4. 发送消息
    - 5. 接收消息
    - 6. 测试消息发送和接收

RabbitMQ 简介与安装

1. RabbitMQ 简介

RabbitMQ 是一个开源的消息代理和队列服务器，基于 AMQP（高级消息队列协议）实现。它具有以下特点：

可靠性：支持持久化、传输确认、发布确认等机制，确保消息不丢失。
灵活性：支持多种消息模型，如点对点、发布 - 订阅等。
分布式：可以通过集群和镜像队列来实现高可用性和扩展性。
多语言支持：支持多种编程语言，如 Java、Python、C# 等。

2. RabbitMQ 安装

以下以在 Linux（Ubuntu）系统上安装 RabbitMQ 为例：

步骤 1：安装 Erlang
RabbitMQ 是用 Erlang 语言编写的，因此需要先安装 Erlang。

# 添加 Erlang 仓库
wget https://packages.erlang-solutions.com/erlang-solutions_2.0_all.deb
sudo dpkg -i erlang-solutions_2.0_all.deb
sudo apt-get update# 安装 Erlang
sudo apt-get install esl-erlang

步骤 2：安装 RabbitMQ

# 添加 RabbitMQ 仓库
echo "deb https://dl.bintray.com/rabbitmq/debian $(lsb_release -sc) main" | sudo tee /etc/apt/sources.list.d/bintray.rabbitmq.list
wget -O- https://dl.bintray.com/rabbitmq/Keys/rabbitmq-release-signing-key.asc | sudo apt-key add -
wget -O- https://www.rabbitmq.com/rabbitmq-release-signing-key.asc | sudo apt-key add -
sudo apt-get update# 安装 RabbitMQ
sudo apt-get install rabbitmq-server

步骤 3：启动 RabbitMQ 服务

sudo systemctl start rabbitmq-server

步骤 4：设置开机自启

sudo systemctl enable rabbitmq-server

步骤 5：启用管理界面

sudo rabbitmq-plugins enable rabbitmq_management

访问 http://localhost:15672，使用默认用户名 guest 和密码 guest 登录管理界面。

Spring Boot 集成 RabbitMQ

1. 创建 Spring Boot 项目

可以使用 Spring Initializr（https://start.spring.io/）创建一个新的 Spring Boot 项目，添加以下依赖：

Spring Web
Spring AMQP

2. 配置 RabbitMQ

在 application.properties 或 application.yml 中配置 RabbitMQ 连接信息：

application.properties

spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

application.yml

spring:rabbitmq:host: localhostport: 5672username: guestpassword: guest

3. 定义消息队列和交换机

创建一个配置类来定义队列、交换机和绑定关系：

import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.DirectExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;@Configuration
public class RabbitMQConfig {public static final String QUEUE_NAME = "myQueue";public static final String EXCHANGE_NAME = "myExchange";public static final String ROUTING_KEY = "myRoutingKey";@Beanpublic Queue queue() {return new Queue(QUEUE_NAME, true);}@Beanpublic DirectExchange exchange() {return new DirectExchange(EXCHANGE_NAME);}@Beanpublic Binding binding(Queue queue, DirectExchange exchange) {return BindingBuilder.bind(queue).to(exchange).with(ROUTING_KEY);}
}

4. 发送消息

创建一个消息发送者类：

import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;@Service
public class MessageSender {@Autowiredprivate RabbitTemplate rabbitTemplate;public void sendMessage(String message) {rabbitTemplate.convertAndSend(RabbitMQConfig.EXCHANGE_NAME, RabbitMQConfig.ROUTING_KEY, message);}
}

5. 接收消息

创建一个消息接收者类：

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

6. 测试消息发送和接收

创建一个控制器来测试消息发送：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;@RestController
public class MessageController {@Autowiredprivate MessageSender messageSender;@GetMapping("/send")public String sendMessage(@RequestParam String message) {messageSender.sendMessage(message);return "Message sent: " + message;}
}

启动 Spring Boot 应用程序，访问 http://localhost:8080/send?message=Hello,RabbitMQ，在控制台可以看到消息接收的输出。

通过以上步骤，就完成了 Spring Boot 与 RabbitMQ 的集成，实现了消息的发送和接收。4

Spring Boot 消息队列（以RabbitMQ为例）

文章目录 RabbitMQ 简介与安装1. RabbitMQ 简介2. RabbitMQ 安装 Spring Boot 集成 RabbitMQ1. 创建 Spring Boot 项目2. 配置 RabbitMQ3. 定义消息队列和交换机4. 发送消息5. 接收消息6. 测试消息发送和接收 RabbitMQ 简介与安装 1. RabbitMQ 简介 RabbitMQ 是一个开源的消息…...

编程日记 2025/9/11 18:01:58

深度学习原理与Pytorch实战

深度学习原理与Pytorch实战第2版强化学习人工智能神经网络书籍 python动手学深度学习框架书 TransformerBERT图神经网络： 技术讲解编辑推荐 1.基于PyTorch新版本，涵盖深度学习基础知识和前沿技术，由浅入深，通俗易懂&#xf…...

编程日记 2025/9/11 20:16:46

WPF-ReactiveUi

文章目录依赖属性和命令的绑定弱绑定强绑定界面后台的cs文件强捆绑方式定义属性和命令第一种方法第二种方法第三种方法动态数据集合whenAny监听单个监听单个对象的多个属性监听多个对象对各属性whenAnyValue例程一例程二WhenAnyValue属性WhenAnyValue(x => x.SearchTerm)Th…...

编程日记 2025/9/11 3:21:00

和鲸科技携手四川气象，以 AI 的力量赋能四川气象一体化平台建设

气象领域与农业、能源、交通、环境科学等国计民生关键领域紧密相连，发挥着不可替代的重要作用。人工智能技术的迅猛发展，为气象领域突破困境带来了新的契机。AI 技术能够深度挖掘气象大数据中蕴含的复杂信息，助力人类更精准地把握自然规律&am…...

编程日记 2025/9/4 14:11:11

把GB型材库放入solidwork中点击库无法应

1、文件夹的位置要选择对，如下图： 2、文件夹一定要嵌套三层，如下图...

编程日记 2025/8/24 7:41:07

论文写作指南

一、论文的核心结构 1. 标题（Title） 要求： 简洁明确，体现核心研究内容（一般不超过20字）。避免模糊词汇（如“研究”“探讨”），可包含关键词。示例： 《关…...

编程日记 2025/9/10 22:35:22

构建安全的Docker基础镜像：从最佳实践到自动化加固

引言容器化技术的普及使得Docker镜像成为软件交付的核心载体，但镜像中的安全漏洞、敏感信息泄露和权限配置不当等问题可能引发严重风险。本文结合OWASP容器安全指南与一线运维经验，系统化讲解如何构建安全的Docker基础镜像，覆盖镜像构建、依赖管理、运行时防护全链路，并提…...

编程日记 2025/9/11 10:34:54

(动态规划最大（连续）子数组和）leetcode 53

这道题和上个文章(动态规划最长连续递增子序列）leetcode 674有异曲同工之妙，本质是一样的，只是这个题更基础一点递推公式中dp[i]max(dp[i],dp[i]dp[i-1])，可以发现，这里如果是背包问题，不取应该是max(dp…...

编程日记 2025/9/9 3:12:38

Python Cookbook-2.20 在 Python 的搜索路径中寻找文件

任务一个大的 Python 应用程序包括了资源文件(比如 Glade 项目文件、SQL 模板和图片)以及 Python 包(Python package)。你想把所有这些相关文件和用到它们的 Python 包储存起来。解决方案可以在 Python 的 sys.path 中寻找文件或目录: import sys，os class E…...

编程日记 2025/9/9 15:45:07

3.对象生活的地方—Java环境搭建

1、你要养鱼，总得先有一个鱼塘吧。挖一个鱼塘来养鱼，你需要去做下面这些事情： 规划和设计：确定鱼塘的位置、大小和形状，绘制设计图。标记和测量：使用测量工具标记鱼塘的边界和深度。挖掘：使用挖…...

编程日记 2025/9/10 0:36:27

精品整理-2025 DeepSeek核心技术解析与实践资料合集（24份）

2025 DeepSeek核心技术解析与实践资料合集，共24份。 2025 DeepSeek 火爆背后的核心技术：知识蒸馏技术.pdf 2025 DeepSeek-R1详细解读：DeepSeek-R1-Zero和DeepSeek-R1分析.pdf 2025 DeepSeek-V3三个关键模块详细解读：MLAMoEMTP.pd…...

编程日记 2025/9/9 10:00:22

16.2 LangChain 表达式语言设计哲学：重新定义大模型应用开发范式

LangChain 表达式语言设计哲学：重新定义大模型应用开发范式关键词：LCEL 设计哲学、声明式编程范式、生产级应用架构、流式处理优化、模块化组合 1. 核心设计目标全景图 mindmap root((LCEL设计目标)) 开发效率声明式编程类型提示系统自动补全支持工程可靠性错…...

编程日记 2025/9/10 8:03:49

Spring Boot 3.x 基于 Redis 实现邮箱验证码认证

文章目录依赖配置开启 QQ 邮箱 SMTP 服务配置文件代码实现验证码服务邮件服务接口实现执行流程依赖配置 <dependencies>  <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spr…...

编程日记 2025/8/16 10:49:23

微服务学习（2）：实现SpringAMQP对RabbitMQ的消息收发

目录 SpringAMQP是什么为什么采用SpringAMQP SpringAMQP应用准备springBoot工程实现消息发送 SpringAMQP是什么 Spring AMQP是Spring框架下用于简化AMQP（高级消息队列协议）应用开发的一套工具集，主要针对RabbitMQ等消息中间件的集成…...

编程日记 2025/9/11 5:49:34

c++中深拷贝和浅拷贝的联系和区别

在 C 编程里，深拷贝和浅拷贝是两种不同的对象复制方式，它们在实现方式、资源管理和适用场景等方面存在显著差异。下面为你详细介绍它们的区别。 1. 基本概念浅拷贝：浅拷贝仅仅复制对象的成员变量值。对于基本数据类型（如 int、d…...

编程日记 2025/9/10 6:37:05

mysql中事务的基本概念

事务的基本概念一、事务的基本要素（ACID） 1. 原子性（Atomicity） 定义：事务中的所有操作要么全部成功，要么全部失败回滚，不允许部分完成。举例：A 向 B 转账，A 扣款和 …...

编程日记 2025/9/6 9:02:15

【密码学实战】Java 实现 SM2 国密算法（签名带id、验签及 C1C3C2 加密解密）

前言 SM2是中国国家密码管理局发布的椭圆曲线公钥密码算法标准（GB/T 32918），属于国密算法体系。与RSA和ECDSA相比，SM2在相同安全强度下密钥更短、计算效率更高。本文将介绍如何在Java中实现SM2的密钥生成、数字签名、验签、加密及…...

编程日记 2025/9/10 14:13:03

如何修改安全帽/反光衣检测AI边缘计算智能分析网关V4的IP地址？

TSINGSEE青犀推出的智能分析网关V4，是一款集成了BM1684芯片的高性能AI边缘计算智能硬件。其内置的高性能8核ARM A53处理器，主频可高达2.3GHz，INT8峰值算力更是达到了惊人的17.6Tops。此外，该硬件还预装了近40种AI算法模型&#xf…...

编程日记 2025/9/6 0:49:57

LLM的演进趋势与未来展望：Toformer的革新之路

文章出处题目：Restoring Images in Adverse Weather Conditions via Histogram Transformer 论文地址: https://arxiv.org/pdf/2407.10172 代码地址: https://github.com/sunshangquan/Histoformer 年份：2024 期刊：ECCV 背景这篇文章…...

编程日记 2025/9/5 23:46:22

LabVIEW 无法播放 AVI 视频的编解码器解决方案

用户在 LabVIEW 中使用示例程序 Read AVI File.vi（路径： 📌 C:\Program Files (x86)\National Instruments\LabVIEW 2019\examples\Vision\Files\Read AVI File.vi）时发现： ✅ LabVIEW 自带的 AVI 视频可正常播放这是…...

编程日记 2025/9/4 9:56:50

Svelte vs Vue：前端框架的深度对比与应用场景分析

Svelte vs Vue：前端框架的深度对比与应用场景分析 1. 引言前端开发领域的框架选择一直是开发者关注的重点。在现代 Web 开发中，Vue 和 Svelte 都是备受瞩目的框架，各自拥有不同的架构设计和适用场景。本文将从核心架构、性能对比、开发体…...

编程日记 2025/9/11 17:35:35

如何在一台服务器上搭建 mongodb副本集1主2从节点

在一台服务器上搭建 MongoDB 副本集（1 主节点 2 从节点）可以通过运行多个 MongoDB 实例并使用不同端口和数据目录来实现。以下是详细步骤： 1. 准备工作确保已安装 MongoDB。为每个实例创建独立的数据目录和日志文件。 2. 创建数据目录和…...

编程日记 2025/9/10 22:06:49

【湖北省计算机信息系统集成协会主办，多高校支持 | ACM出版，EI检索，往届已见刊检索】第二届边缘计算与并行、分布式计算国际学术会议（ECPDC 2025)

第二届边缘计算与并行、分布式计算国际学术会议（ECPDC 2025）将于2025年4月11日至13日在中国武汉盛大召开。本次会议旨在为边缘计算、并行计算及分布式计算领域的研究人员、学者和行业专家提供一个高水平的学术交流平台。随着物联网、云计算和大数据技术…...

编程日记 2025/9/10 1:41:14

谈谈 ES 6.8 到 7.10 的功能变迁（6）- 其他

这是 ES 7.10 相较于 ES 6.8 新增内容的最后一篇，主要涉及算分方法和同义词加载的部分。自定义算分：script_score 2.0 Elasticsearch 7.0 引入了新一代的函数分数功能，称为 script_score 查询。这一新功能提供了一种更简单、更灵活的方式来…...

编程日记 2025/9/9 9:52:29

大数据与金融科技：革新金融行业的动力引擎

大数据与金融科技：革新金融行业的动力引擎在今天的金融行业，大数据与金融科技的结合正在以惊人的速度推动着金融服务的创新与变革。通过精准的数据分析与智能化决策，金融机构能够更高效地进行风险管理、客户服务、资产管理等一系列关键操作…...

编程日记 2025/9/5 13:15:34

企业jsapi_ticket，java举例

在企业微信开发中，使用 Java 获取 jsapi_ticket 并生成签名的步骤如下。以下是完整的 Java 示例代码。 1. 获取 jsapi_ticket 的流程获取 access_token。使用 access_token 获取 jsapi_ticket。使用 jsapi_ticket 生成签名（signature）。…...

编程日记 2025/9/10 5:24:23

【Python】基础语法三

> 作者：დ旧言~ > 座右铭：松树千年终是朽，槿花一日自为荣。 > 目标：了解Python的函数、列表和数组。 > 毒鸡汤：有些事情，总是不明白，所以我不会坚持。早安! > 专栏选自&#xff…...

编程日记 2025/9/9 14:34:23

leetcode_字典树 139. 单词拆分

139. 单词拆分给你一个字符串 s 和一个字符串列表 wordDict 作为字典。如果可以利用字典中出现的一个或多个单词拼接出 s 则返回 true。注意：不要求字典中出现的单词全部都使用，并且字典中的单词可以重复使用。思路: 定义状态： 设dp[i]表…...

编程日记 2025/9/10 22:58:40

Easy Trans Spring Boot Starter ---Spring系列的字段翻译库

Easy Trans Spring Boot Starter 使用文档 1. 简介 easy-trans-spring-boot-starter 是一个基于 Spring Boot 的库，用于简化数据翻译和转换操作。它可以帮助你将数据库中的枚举值、状态码等转换为用户友好的文本，或者将一种数据格式转换为另一种格式。…...

编程日记 2025/9/8 21:18:18

算法-数据结构（图）-迪杰斯特拉最短逻辑算法（ Dijkstra）

迪杰斯特拉算法（Dijkstras Algorithm） 是一种用于计算单源最短路径的经典算法，由荷兰计算机科学家艾兹赫尔迪杰斯特拉（Edsger W. Dijkstra） 于1956年提出。它的主要目标是找到从图中的某个源节点到所有其他节点的最短…...

编程日记 2025/9/11 20:01:47

抖音生活服务加强探店内容治理，2024年达人违规率下降30%

发布 | 大力财经 2月27日，抖音生活服务发布《2024抖音生活服务消费者权益保护年度报告》（以下简称“报告”）。报告显示，过去一年，抖音生活服务针对消费者反感的虚假、夸张探店内容，开展了专项治理。通过一…...

编程日记 2025/9/8 8:19:22

跟着源码实现LevelDB（二）util/status.cc

概述本小节实现了leveld的Status类，Status看起来是个简单的类，但是其中也包含了leveldb对极致的性能实现的巧妙设计 Status的内存管理 Status 只有一个成员变量 const char* state_; state[0…3] 表示长度，state[4] 1个字节表示状态的枚…...

编程日记 2025/9/8 10:57:17

51c自动驾驶~合集52

我自己的原文哦~ https://blog.51cto.com/whaosoft/13383340 #世界模型如何推演未来的千万种可能驾驶世界模型（DWM），专注于预测驾驶过程中的场景演变，已经成为追求自动驾驶的一种有前景的范式。这些方法使自动驾驶系统能够更…...

编程日记 2025/9/8 20:09:09

Rust 是什么

Rust 是什么 Rust 是一种由 Mozilla 开发的系统级编程语言，它于 2010 年首次亮相，在 2015 年发布 1.0 版本，此后迅速发展并受到广泛关注。内存安全：Rust 最大的亮点之一是它在编译阶段就能够避免常见的内存错误，如空指针引用、数据竞争和内存泄漏等。它通过所有权（Owne…...

编程日记 2025/9/11 13:54:05

文章目录创建自定义网络创建NameServer容器创建Broker容器正式开始启动 Nameserver 容器启动 Broker 容器并关联 Nameserverdocker exec -it rmqbroker vi /etc/rocketmq/broker.conf检查 namesrv 解析检查 Broker 注册状态Nameserver 日志Broker 日志检查容器日志手动指定 Br…...

编程日记 2025/9/10 3:32:44

ASP.NET MVC项目部署到IIS后，w3wp.exe程序报错重启

一、错误信息 windows的事件查看器》windows日志》应用程序，按时间找到错误信息如下： 错误应用程序名称: w3wp.exe，版本: 10.0.14393.0，时间戳: 0x57899b8a 错误模块名称: KERNELBASE.dll，版本: 10.0.14393.5850&…...

编程日记 2025/9/12 4:31:59

Java多线程与高并发专题——深入ReentrantReadWriteLock

深入ReentrantReadWriteLock 读写锁出现原因 synchronized和ReentrantLock都是互斥锁。如果说有一个操作是读多写少的，还要保证线程安全的话。如果采用上述的两种互斥锁，效率方面很定是很低的。在这种情况下，咱们就可以使用ReentrantReadWr…...

编程日记 2025/9/6 12:18:51

支付宝 IoT 设备入门宝典（下）设备经营篇

上篇介绍了支付宝 IoT 设备管理，但除了这些基础功能外，商户还可以利用设备进行一些运营动作，让设备更好的帮助自己，本篇就会以设备经营为中心，介绍常见的设备相关能力和问题解决方案。如果对上篇感兴趣，可以…...

编程日记 2025/9/11 10:13:33

极简本地体验deepseek大模型教程

一题外随感：时代之问就像狄更斯在双城记中所述，“这是最好的时代，这是最坏的时代”。每一代人都有其所处的时代，每一个时代都有其所谓好的一面和不那么好的一面。很多时候随口的一句大环境不好，就似乎给了自己一个最…...

编程日记 2025/9/9 6:41:18

最短路问题--Floyd

Floyd算法一、介绍二、补充知识：邻接矩阵三、原理四、实现提示：以下是本篇文章正文内容，下面案例可供参考一、介绍 Floyd算法是一种用来计算图中所有点之间最短距离的算法。它的核心思想是：通过逐步尝试每个点作为中间点&…...

编程日记 2025/9/8 1:43:19

深入理解Java网络编程：从基础到高级应用

一、网络编程概述 1.什么是网络编程？ 网络编程是指利用计算机网络实现程序之间通信的一种编程方式。在网络编程中，程序需要通过网络协议（如 TCP/IP）来进行通信，以实现不同计算机之间的数据传输和共享。 2.在网络编程…...

编程日记 2025/9/10 14:04:39

浅谈deepseek环境搭建

在探索人工智能的浩瀚宇宙中，DeepSeek如同一颗璀璨的星辰，以其独特的魅力引领着我们在逻辑推理与数据分析的海洋中遨游。想要在这片未知的领域里扬帆起航，首先必须精心搭建起我们的“星际飞船”——DeepSeek环境。无论你是渴望在本地实例上运…...

编程日记 2025/9/6 17:35:56

AI绘画软件Stable Diffusion详解教程（2）：Windows系统本地化部署操作方法（专业版）

一、事前准备 1、一台配置不错的电脑，英伟达显卡，20系列起步，建议显存6G起步，安装win10或以上版本，我的显卡是40系列，16G显存，所以跑大部分的模型都比较快； 2、科学上网&#xff0…...

编程日记 2025/9/6 19:44:06

kali liux的下载

Kali Linux | Penetration Testing and Ethical Hacking Linux Distributionhttps://www.kali.org/ VMware虚拟机https://pan.quark.cn/s/aa869ffbf184 【补充一个今天学到的知识昂和内容无关:（遥感）指非接触的远距离探测技术，使用传感器探…...

编程日记 2025/9/1 18:08:43

DeepSeek 助力 Vue3 开发：打造丝滑的悬浮按钮（Floating Action Button）

前言：哈喽，大家好，今天给大家分享一篇文章！并提供具体代码帮助大家深入理解，彻底掌握！创作不易，如果能帮助到大家或者给大家一些灵感和启发，欢迎收藏关注哦 💕 目录 Deep…...

编程日记 2025/9/9 3:42:18

ES from size聚合查询10000聚合查询，是每个分片先聚合，再统计。还是所有节点查询1万条后，再聚合

在 Elasticsearch 中，聚合查询的执行过程是分布式的，Elasticsearch 会先在每个分片（shard）上执行本地聚合，然后再在协调节点（coordinating node）上对所有分片的聚合结果进行全局汇总。具体过…...

编程日记 2025/9/8 16:09:08

fluent-ffmpeg 依赖详解

fluent-ffmpeg 是一个用于在 Node.js 环境中与 FFmpeg 进行交互的强大库，它提供了流畅的 API 来执行各种音视频处理任务，如转码、剪辑、合并等。一、安装 npm install fluent-ffmpeg二、基本使用要使用 fluent-ffmpeg，首先需要确保系统中…...

编程日记 2025/9/8 17:11:27