【RabbitMQ】RabbitMQ持久化
一、简介
- RabbitMQ的持久化机制是一种确保数据在RabbitMQ服务重启或异常情况下不会丢失的重要特性。
- RabbitMQ的持久化主要包括三个方面的内容:交换器的持久化、队列的持久化、消息的持久化。
二、交换器的持久化
1、实现方式
在RabbitMQ中,实现交换器持久化的主要方式是在声明交换器时,将durable
参数设置为true
。这个参数告诉RabbitMQ,这个交换器应该被持久化到磁盘上,以便在系统重启后能够恢复。
2、操作步骤
- 连接RabbitMQ服务器:首先,需要建立与RabbitMQ服务器的连接。
- 声明交换器:在连接建立后,使用
exchangeDeclare
方法声明一个交换器,并在声明过程中将durable
参数设置为true
。
3、代码示例
以下是一个使用RabbitMQ Java客户端库声明持久化交换器的示例代码:
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost"); // 设置RabbitMQ服务器地址
try (Connection connection = factory.newConnection(); Channel channel = connection.createChannel()) { // 声明持久化交换器 channel.exchangeDeclare("myExchange", BuiltinExchangeType.DIRECT, true); // "myExchange" 是交换器的名称 // BuiltinExchangeType.DIRECT 是交换器的类型 // true 表示交换器是持久化的
} catch (IOException e) { e.printStackTrace();
}
三、队列的持久化
1、实现方式
在声明队列时,将durable
参数设置为true
,这样RabbitMQ就会将队列的元数据写入磁盘,并且在RabbitMQ服务重启后能够恢复这些队列。然而,仅仅将队列设置为持久化并不足以确保队列中的消息不会丢失,因为消息的持久化还需要在发送消息时进行额外的设置。
2、注意事项
-
消息的持久化:要确保队列中的消息在RabbitMQ服务重启后不会丢失,除了将队列设置为持久化之外,还需要在发送消息时将消息的
deliveryMode
属性设置为2
(表示消息是持久化的)。 -
交换器的持久化:虽然队列的持久化是确保消息不丢失的关键步骤之一,但还需要注意与队列关联的交换器也应该是持久化的。如果交换器不是持久的,那么即使队列和消息都是持久的,消息也可能无法被正确路由到队列中。
-
性能影响:持久化操作会涉及到磁盘I/O,这可能会对RabbitMQ的性能产生一定的影响。因此,在生产环境中,需要根据实际的业务需求和性能要求来权衡是否需要持久化以及持久化的程度。
3、代码示例
以下是一个使用RabbitMQ Java客户端库声明持久化队列的示例代码:
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost"); // 设置RabbitMQ服务器地址
try (Connection connection = factory.newConnection(); Channel channel = connection.createChannel()) { // 声明持久化队列 boolean durable = true; // 队列持久化 channel.queueDeclare("myQueue", durable, false, false, null); // "myQueue" 是队列的名称 // durable = true 表示队列是持久化的 // 第三个参数为false表示队列不排他(即可以被多个连接共享) // 第四个参数为false表示队列不会自动删除(当没有任何消费者连接到该队列,并且也没有消息在其中时) // 第五个参数是队列的其他参数,这里传入null表示使用默认参数 // 发送持久化消息(需要在发送消息时设置) // 这里只是声明了队列的持久化,发送持久化消息的代码需要在发送消息时设置BasicProperties的deliveryMode为2
} catch (IOException e) { e.printStackTrace();
}
四、消息的持久化
1、实现方式
在RabbitMQ中,消息持久化通常通过以下步骤实现:
-
声明持久化队列:首先,需要确保队列被声明为持久化的。这可以通过在声明队列时将
durable
参数设置为true
来实现。 -
发送持久化消息:其次,在发送消息时,需要将消息的
deliveryMode
属性设置为2
(在AMQP协议中,2
代表持久化消息)。这通常通过设置消息的属性(例如,在Java客户端中通过BasicProperties.Builder
或MessageProperties
类)来完成。 -
使用持久化交换器(可选但推荐):虽然交换器本身的持久化不直接影响消息的持久化,但使用持久化交换器可以确保即使RabbitMQ服务重启,交换器的定义仍然存在,从而允许消息被正确地路由到队列中。
2、注意事项
-
性能影响:消息持久化会增加磁盘I/O操作,从而可能对RabbitMQ的性能产生一定影响。因此,在生产环境中,需要根据实际的业务需求和性能要求来权衡是否需要持久化以及持久化的程度。
-
内存和磁盘空间:持久化消息会占用更多的内存和磁盘空间,因为RabbitMQ需要将这些消息存储在内存中以便快速访问,并同时将它们写入磁盘以确保持久性。因此,需要确保RabbitMQ服务器有足够的内存和磁盘空间来支持消息持久化。
-
消息的确认:即使消息被标记为持久化,也不能保证它们一定不会被丢失。例如,如果消费者在处理消息时发生错误并导致RabbitMQ无法将消息重新放回队列中,或者RabbitMQ在将消息写入磁盘之前崩溃,那么这些消息仍然可能会丢失。因此,建议使用RabbitMQ的事务机制或发布者确认机制来确保消息的正确发送和存储。
3、代码示例(Java)
以下是一个使用RabbitMQ Java客户端库发送持久化消息的示例代码:
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost"); // 设置RabbitMQ服务器地址
try (Connection connection = factory.newConnection(); Channel channel = connection.createChannel()) { // 声明持久化队列(如果队列已经存在且配置相同,则此声明是幂等的) channel.queueDeclare("myQueue", true, false, false, null); // 创建持久化消息的属性 AMQP.BasicProperties.Builder propsBuilder = new AMQP.BasicProperties.Builder(); propsBuilder.deliveryMode(2); // 设置消息的deliveryMode为2,表示消息是持久化的 AMQP.BasicProperties props = propsBuilder.build(); // 发送持久化消息 String message = "Hello, RabbitMQ!"; channel.basicPublish("", "myQueue", props, message.getBytes()); System.out.println(" [x] Sent '" + message + "'");
} catch (IOException e) { e.printStackTrace();
}
相关文章:
【RabbitMQ】RabbitMQ持久化
一、简介 RabbitMQ的持久化机制是一种确保数据在RabbitMQ服务重启或异常情况下不会丢失的重要特性。RabbitMQ的持久化主要包括三个方面的内容:交换器的持久化、队列的持久化、消息的持久化。 二、交换器的持久化 1、实现方式 在RabbitMQ中,实现交换器…...
算法刷题笔记 Kruskal算法求最小生成树(详细算法介绍,详细注释C++代码实现)
文章目录 题目描述基本思路实现代码 题目描述 给定一个n个点m条边的无向图,图中可能存在重边和自环,边权可能为负数。求最小生成树的树边权重之和,如果最小生成树不存在则输出impossible。 最小生成树的概念:给定一张边带权的无向…...

5年经验的软件测试人员,碰到这样的面试题居然会心虚......
我们这边最近的面试机会比较多,但是根据他们的反馈,结束后大部分都没音信了,因为现在企业面试问的非常多,范围非常广,而且开放性的问题很多,很多人即便面试前刷了成百上千道面试题,也很难碰到一…...

C#进阶-轻量级ORM框架Dapper的使用教程与原理详解
本文详细介绍了Dapper在C#中的使用方法,包括Dapper的基本概念、与其他持久层框架的比较、基本语法和高级语法的使用,并通过实例讲解了如何在项目中集成和使用Dapper。Dapper以其高效的性能和简洁的API受到开发者的青睐,适用于各种数据库操作需…...
Windows图形界面(GUI)-MFC-C/C++ - 编辑框(Edit Control) - CEdit
公开视频 -> 链接点击跳转公开课程博客首页 -> 链接点击跳转博客主页 目录 编辑框(Edit Control) - CEdit 基本概念 成员函数 示例代码 编辑框(Edit Control) - CEdit 基本概念 编辑框(Edit Control)是一个允许用户输入和编辑文本的窗…...

网络安全防御【IPsec VPN搭建】
目录 一、实验拓扑图 二、实验要求 三、实验思路 四、实验步骤: 修改双机热备的为主备模式: 2、配置交换机LSW6新增的配置: 3、防火墙(FW4)做相关的基础配置: 4、搭建IPsec VPN通道 (1…...
java环境配置与tomcat的配置
1、java环境配置 一、JDK下载 访问Oracle官网: 前往Oracle官网(Oracle | Cloud Applications and Cloud Platform),在首页的顶部菜单中选择“Resources” > “Downloads” > “Java” > “JDK”。注意:Orac…...
OD C卷 - 来自异国的客人/幸运数字
来自异国的客人/幸运数字(100) 输入描述: 输入k,n,m k表示物品价值(十进制) k>0 n表示幸运数字, n > 0 m表示异国采用的进制;m > 1 n < m 输出描述: 输出幸运数字的个数࿰…...

C++ | 动态内存管理 new、delete (用法、底层)详解
目录 简单回顾C语言动态内存管理 new、delete的用法 内置类型 new delete 自定义类型 new、delete底层讲解(重要) operator new 与 operator delete 定位 new 结语 简单回顾C语言动态内存管理 在C语言的学习阶段 我们接触到了三个能在堆上开辟…...

【C语言】结构体内存布局解析——字节对齐
🦄个人主页:小米里的大麦-CSDN博客 🎏所属专栏:https://blog.csdn.net/huangcancan666/category_12718530.html 🎁代码托管:黄灿灿 (huang-cancan-xbc) - Gitee.com ⚙️操作环境:Visual Studio 2022 目录 一、引言 二、什么是字节对齐&…...
模型表达方式
目录 一、模型表达概述 二、模型精确表达 2.1 几何表示 (Geometrical Representation) 三、模型非精确表达 3.1 网格表示 (Mesh Representation) 3.2 体素表示 (Voxel Representation) 一、模型表达概述 模型的表达方式多种多样,选择适合的表达方式取决于具体应用场景和…...

校园课程助手【4】-使用Elasticsearch实现课程检索
本节将介绍本项目的查询模块,使用Elasticsearch又不是查询接口,具体流程如图所示(如果不了解Elasticsearch可以使用sql语句进行查询): 这里是两种方法的异同点: Mysql:擅长事务类型操作&#…...
经典运维面试题
1、Linux常见的日志文件都有哪些,各自的用途?日志轮询配置文件在哪里?欢迎界面配置文件在哪里? /var/log/messages #内核及公共消息日志/var/log/cron #计划任务日志/var/log/dmesg #系统引导日志/var/log/malilog #邮件系…...

别再盲目推广了!Xinstall助你开启App线下推广新篇章
在这个数字化飞速发展的时代,App已经成为我们生活中不可或缺的一部分。然而,App市场的竞争也日益激烈,如何让你的App在众多竞争者中脱颖而出,成为每个推广者必须面对的问题。今天,就让我们一起探讨一下App线下推广的痛…...

大厂linux面试题攻略五之数据库管理
一、数据库管理-MySQL语句 0.MySQL基本语句: 1.SQL语句-增 创建xxx用户: mysql>create user xxx % indentified by 123456; xxx表示用户名 %b表示该用户用来连接数据库的方式(远程或本地连接) indentified by 123456设置密码…...
【pytorch】模型集成
在集成学习中,我们会训练多个模型(通常称为「弱学习器」)解决相同的问题,并将它们结合起来以获得更好的结果。最重要的假设是:当弱模型被正确组合时,我们可以得到更精确和/或更鲁棒的模型。 常用的模型集成…...

初识集合和数据结构
目录 初识集合框架数据结构基本概念和术语数据数据元素数据项数据对象前四者的关系数据结构逻辑结构和物理结构逻辑结构物理结构 算法算法设计要求 初识集合框架 Java的集合框架也可被称为容器,是定义在Java.util包下的一些接口和实现类。其就是将多个元素存储到一…...

cocos creator 3.x中动态加载 resources 文件夹下的图片时提示找不到
文件目录如下 类型为spriteFrame 代码案例 图片设置为 sprite-frame、texture 或其他图片类型后,将会在 资源管理器 中生成一个对应类型的资源。但如果直接加载 equipments/testea,得到的类型将会是 ImageAsset,必须指定路径到具体的子资源…...
第九十八周周报
学习时间: 2024.7.27-204.8.3 学习产出: 这周主要在按照审稿人的意见修改论文,由于有个模型保存的文件找不到了,所以重新训练花了点时间,目前已经把修改后的论文和cover letter发给杨老师了。...
程序员找工作之数据结构面试题总结分析
文章目录 1. 数据结构的基本概念与分类2. 数据结构的存储与表示3. 数据元素的存储与关系4. 存储结构的选择与考量5. 特定数据结构的定义与特性6. 数据结构操作与应用7. 数组与存储8. 特定数据结构的存储与访问 程序员在找工作面试中,数据结构方面可能会被问到的问题…...

【入坑系列】TiDB 强制索引在不同库下不生效问题
文章目录 背景SQL 优化情况线上SQL运行情况分析怀疑1:执行计划绑定问题?尝试:SHOW WARNINGS 查看警告探索 TiDB 的 USE_INDEX 写法Hint 不生效问题排查解决参考背景 项目中使用 TiDB 数据库,并对 SQL 进行优化了,添加了强制索引。 UAT 环境已经生效,但 PROD 环境强制索…...

vscode(仍待补充)
写于2025 6.9 主包将加入vscode这个更权威的圈子 vscode的基本使用 侧边栏 vscode还能连接ssh? debug时使用的launch文件 1.task.json {"tasks": [{"type": "cppbuild","label": "C/C: gcc.exe 生成活动文件"…...
【磁盘】每天掌握一个Linux命令 - iostat
目录 【磁盘】每天掌握一个Linux命令 - iostat工具概述安装方式核心功能基础用法进阶操作实战案例面试题场景生产场景 注意事项 【磁盘】每天掌握一个Linux命令 - iostat 工具概述 iostat(I/O Statistics)是Linux系统下用于监视系统输入输出设备和CPU使…...
在四层代理中还原真实客户端ngx_stream_realip_module
一、模块原理与价值 PROXY Protocol 回溯 第三方负载均衡(如 HAProxy、AWS NLB、阿里 SLB)发起上游连接时,将真实客户端 IP/Port 写入 PROXY Protocol v1/v2 头。Stream 层接收到头部后,ngx_stream_realip_module 从中提取原始信息…...

Python实现prophet 理论及参数优化
文章目录 Prophet理论及模型参数介绍Python代码完整实现prophet 添加外部数据进行模型优化 之前初步学习prophet的时候,写过一篇简单实现,后期随着对该模型的深入研究,本次记录涉及到prophet 的公式以及参数调优,从公式可以更直观…...
Java入门学习详细版(一)
大家好,Java 学习是一个系统学习的过程,核心原则就是“理论 实践 坚持”,并且需循序渐进,不可过于着急,本篇文章推出的这份详细入门学习资料将带大家从零基础开始,逐步掌握 Java 的核心概念和编程技能。 …...

成都鼎讯硬核科技!雷达目标与干扰模拟器,以卓越性能制胜电磁频谱战
在现代战争中,电磁频谱已成为继陆、海、空、天之后的 “第五维战场”,雷达作为电磁频谱领域的关键装备,其干扰与抗干扰能力的较量,直接影响着战争的胜负走向。由成都鼎讯科技匠心打造的雷达目标与干扰模拟器,凭借数字射…...

mysql已经安装,但是通过rpm -q 没有找mysql相关的已安装包
文章目录 现象:mysql已经安装,但是通过rpm -q 没有找mysql相关的已安装包遇到 rpm 命令找不到已经安装的 MySQL 包时,可能是因为以下几个原因:1.MySQL 不是通过 RPM 包安装的2.RPM 数据库损坏3.使用了不同的包名或路径4.使用其他包…...
Rapidio门铃消息FIFO溢出机制
关于RapidIO门铃消息FIFO的溢出机制及其与中断抖动的关系,以下是深入解析: 门铃FIFO溢出的本质 在RapidIO系统中,门铃消息FIFO是硬件控制器内部的缓冲区,用于临时存储接收到的门铃消息(Doorbell Message)。…...
服务器--宝塔命令
一、宝塔面板安装命令 ⚠️ 必须使用 root 用户 或 sudo 权限执行! sudo su - 1. CentOS 系统: yum install -y wget && wget -O install.sh http://download.bt.cn/install/install_6.0.sh && sh install.sh2. Ubuntu / Debian 系统…...