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

RabbitMQ 持久化

  通过持久化可以尽量防止在RabbitMQ异常情况下(重启、关闭、宕机)的数据丢失。持久化技术是解决消息存储到队列后的丢失问题,但是通过持久化并不能完全保证消息不丢失。

持久化

  • 交换机持久化
  • 队列持久化
  • 消息持久化
  • 总结

  持久化技术可以分为交换机持久化、队列持久化以及消息持久化,它们的实现方案和实现目的均不相同。

交换机持久化

  交换机持久化是为了确保用户创建的交换机在RabbitMQ重启后依旧存在的一种手段。
  交换机持久化在声明交换机过程中通过将durable参数设置为true实现。交换机持久化会将交换机元数据也进行持久化,当然也包含队列和路由的绑定关系。但如果绑定关系存在,队列不存在则消息依旧不会发送到队列中。

队列持久化

  队列持久化可以保障队列自身的元数据不会丢失,不能保证存储在队列中的消息不会丢失。
  队列持久化在声明队列的过程中通过将durable参数设置为true实现。需要注意的是,虽然队列持久化不能保证消息持久化,但是消息的持久化实现必须依赖于队列持久化,也就是说持久化消息只有存储于持久化队列中才会真正实现持久化。

消息持久化

  消息持久化确保了消息入队后到消息被消费这一过程中的稳定性,防止由于故障异常原因导致存储在队列中尚未被消费的消息丢失。
  消息持久化可以在发送消息的过程中将消息元数据deliveryMode设置为2实现。
  消息持久化虽然可以尽量保证队列中的消息不丢失,但是并不能完全确保队列中的消息不丢失,待消息入队后,通过持久化技术会将消息写入磁盘中,但是Linux操作系统底层并不会实时的把数据写入磁盘中,它会首先将需要写入磁盘的数据放入缓存区中,如果消息入队并且将数据写入缓存区尚未写入磁盘的过程中出现服务器异常,则消息依旧面临了丢失的情况。
  该问题可以通过发布确认机制进行解决。我们了解到发布确认机制其实本质上是确保消息合法的发送到rabbitMQ中的交换机中的,但是发送确认机制的应答时间是在消息完成持久化后,因此我们可以通过发送确认机制加持久化技术进一步确保消息在队列中被持久化且避免丢失。

总结

内容交换机持久化队列持久化消息持久化
实现方式声明交换机是定义声明队列时定义发送消息时定义
作用持久化交换机的元数据,避免重启丢失持久化队列的元数据,避免重启丢失持久化消息
特点队列持久化不能代表消息持久化,但是持久化消息只能在持久化队列中进行消息持久化也可能会存储消息丢失的问题,可通过发送确认机制和RabbitMQ集群的方式进一步保障消息的安全性。

相关文章:

RabbitMQ 持久化

通过持久化可以尽量防止在RabbitMQ异常情况下(重启、关闭、宕机)的数据丢失。持久化技术是解决消息存储到队列后的丢失问题,但是通过持久化并不能完全保证消息不丢失。 持久化 交换机持久化队列持久化消息持久化总结 持久化技术可以分为交换机…...

STM32 定时器复习

12MHz晶振的机器周期是1us,因为单片机的一个机器周期由6个状态周期组成,1个机器周期6个状态周期12个时钟周期,因此机器周期为1us。 51单片机常用 for(){__nop(); //执行一个机器周期,若想循环n us,则循环n次。 }软件…...

17-工程化开发 脚手架 Vue CLI

开发Vue的两种方式: 1.核心包传统开发模式: 基于 html/css /js 文件,直接引入核心包,开发 Vue。 2.工程化开发模式: 基于构建工具 (例如: webpack)的环境中开发 Vue。 问题: 1. webpack 配置不简单 2. 雷同的基础配置 3. 缺乏统…...

golang 分布式微服务DAO层构建

构建云原生项目的dao层 配置读写分离的mysql集群 1. 编写yml配置文件 搭建一主二从的mysql集群、单机redis db.yml mysql:source: # 主数据库driverName: mysqlhost: 127.0.0.1port: 3309database: db_tiktokusername: tiktokDBpassword: tiktokDBcharset: utf8mb4replica1…...

Java 项目日志实例:LogBack

点击下方关注我,然后右上角点击...“设为星标”,就能第一时间收到更新推送啦~~~ LogBack 和 Log4j 都是开源日记工具库,LogBack 是 Log4j 的改良版本,比 Log4j 拥有更多的特性,同时也带来很大性能提升。LogBack 官方建…...

什么是条件get方法?

条件GET方法通常指的是HTTP协议中的"GET"请求,但它带有一些条件,这些条件用于控制服务器是否应该返回请求的资源。这些条件通常使用HTTP标头字段来指定,以便客户端可以告诉服务器在某些条件下是否需要新的或更新的资源。 条件GET方…...

Python爬虫——scrapy_crawlspider读书网

创建crawlspider爬虫文件: scrapy genspider -t crawl 爬虫文件名 爬取的域名scrapy genspider -t crawl read https://www.dushu.com/book/1206.htmlLinkExtractor 链接提取器通过它,Spider可以知道从爬取的页面中提取出哪些链接,提取出的链…...

Spring源码编译-for mac

超详细的spring源码编译 记:编译成功时间:2023.08.19 环境准备: 1.idea 2023.1.1 Community Edition 2.jdk1.8 3.gradlegradle-5.6.4 4.spring源码(版本:spring-framework-v5.2.25.RELEASE) 一.spring源码下载 github 加速网站&…...

视频汇聚平台EasyCVR安防监控视频汇聚平台的FLV视频流在VLC中无法播放的问题解决方案

众所周知,TSINGSEE青犀视频汇聚平台EasyCVR可支持多协议方式接入,包括主流标准协议国标GB28181、RTSP/Onvif、RTMP等,以及厂家私有协议与SDK接入,包括海康Ehome、海大宇等设备的SDK等。在视频流的处理与分发上,视频监控…...

中间件:RocketMQ安装部署

单机部署 下载 cd /opt/soft/archive wget https://archive.apache.org/dist/rocketmq/4.9.4/rocketmq-all-4.9.4-bin-release.zip unzip -d ../ rocketmq-all-4.9.4-bin-release.zip配置 broker.conf 的brokerIP1 为公网ip 启动命令: nohup sh bin/mqnamesrv &a…...

leetcode-动态规划-42-接雨水

题目 给定 n 个非负整数表示每个宽度为 1 的柱子的高度图,计算按此排列的柱子,下雨之后能接多少雨水。 示例 1: 输入:height [0,1,0,2,1,0,1,3,2,1,2,1] 输出:6 解释:上面是由数组 [0,1,0,2,1,0,1,3,2,1…...

[静态时序分析简明教程(十一)]浅议tcl语言

静态时序分析简明教程-浅议tcl语言 一、写在前面1.1 快速导航链接 二、Tcl基础知识三、Tcl的语言结构3.1 Tcl变量3.2 Tcl表达式与运算符3.3 Tcl的控制流语句3.3.1 列表遍历3.3.2 决策3.3.3 Tcl循环3.3.4 Tcl过程 3.4 其他Tcl命令3.4.1 open/close3.4.2 gets/puts3.4.3 catch3.4…...

大数据-玩转数据-Flink 网站UV统计

一、说明 在实际应用中,我们往往会关注,到底有多少不同的用户访问了网站,所以另外一个统计流量的重要指标是网站的独立访客数(Unique Visitor,UV)。 二、数据准备 package com.lyh.flink06;import lombo…...

3分钟了解下cwnd和TCP拥塞控制算法

文章首发地址 cwnd是什么? cwnd是TCP拥塞控制中的一个重要概念,全称为“congestion window”,也被称为拥塞窗口。它用于限制发送方向网络发送数据的速度,以避免网络拥塞。cwnd是一个动态的值,可以根据网络状况动态调…...

设计模式之状态模式(State)的C++实现

1、状态模式的提出 在组件功能开发过程中,某些对象的状态经常面临变化,不同的状态,其对象的操作行为不同。比如根据状态写的if else条件情况,且这种条件变化是经常变化的,这样的代码不易维护。可以使用状态模式解决这…...

无涯教程-TensorFlow - Keras

Keras易于学习的高级Python库,可在TensorFlow框架上运行,它的重点是理解深度学习技术,如为神经网络创建层,以维护形状和数学细节的概念。框架的创建可以分为以下两种类型- 顺序API功能API 无涯教程将使用Jupyter Notebook执行和…...

使用SSH隧道将Ubuntu云服务器Jupyter Notebook端口映射到本地

本文主要实现了在Ubuntu云服务器后台运行Jupyter Notebook,并使用SSH隧道将服务器端口映射到本地 1. 生成配置文件 运行以下命令生成Jupyter Notebook的配置文件: jupyter notebook --generate-config这将在用户主目录下生成一个名为.jupyter的文件夹&…...

Keepalived+LVS部署高可用集群

文章目录 KeepalivedLVS(DR)部署高可用Web集群集群环境MASTER配置BACKUP配置检查Virtual IP是否漂移IPVS检查MASTERBACKUP Real Server配置附上个人写的小脚本 测试停用Real Server某一台的Apache服务停用Master上的keepalived检测Backup是否接管资源 KeepalivedLVS(DR)部署高可…...

2023河南萌新联赛第(五)场:郑州轻工业大学

A.买爱心气球 原题链接 : 登录—专业IT笔试面试备考平台_牛客网 博弈论 : #include <iostream> using namespace std; int t,n,m; string s1 "Alice",s2 "Bob"; int main() {cin>>t;while(t--){cin>>n>>m;if (n % 3 0) {cou…...

在Orangepi5开发板3588s使用opencv获取摄像头画面

先感谢香橙派群的管理员耐心指导&#xff0c;经过不断的调试修改最后成功通过opencv调用mipi摄像头获取画面 就记录分享一下大概步骤希望大家少踩点坑&#xff01;&#xff01;&#xff01;&#xff01;&#xff01;&#xff01; 我用的固件系统是ubuntu2022.0.4 固件是&#x…...

基于Belullama框架构建可定制化本地AI模型服务:从原理到实践

1. 项目概述&#xff1a;一个本地化、可定制的AI对话模型部署方案最近在折腾本地AI部署的朋友&#xff0c;可能都绕不开一个名字&#xff1a;Ollama。它确实让拉取和运行各种开源大模型变得像docker pull一样简单。但不知道你有没有遇到过这样的困扰&#xff1a;Ollama默认的AP…...

Bash脚本AI助手:智能生成命令行,提升运维自动化效率

1. 项目概述&#xff1a;当Bash脚本遇见AI&#xff0c;自动化运维的智能进化如果你是一名运维工程师、系统管理员&#xff0c;或者任何需要与Linux命令行打交道的开发者&#xff0c;那么“Bash脚本”一定是你工具箱里的常客。从批量文件处理、定时任务调度到复杂的部署流程&…...

别再死记硬背了!用‘配对’思想图解二次剩余,5分钟理解勒让德符号

用配对游戏破解二次剩余&#xff1a;勒让德符号的视觉化理解指南 数论中那些看似晦涩的概念&#xff0c;往往只需要换个角度就能豁然开朗。想象你手里有一副特殊的扑克牌&#xff0c;每张牌代表一个数字&#xff0c;而你要玩的游戏是找到那些能完美配对的数字——这就是理解二次…...

深度解析AI模型Docker镜像:从DeepSeek部署到生产级容器化实践

1. 项目概述&#xff1a;一个AI模型镜像的深度解构最近在社区里看到不少朋友在讨论dirk1983/deepseek这个Docker镜像&#xff0c;作为一个长期在AI工程化和容器化部署一线摸爬滚打的从业者&#xff0c;我觉得有必要来聊聊这个看似简单的镜像背后&#xff0c;究竟藏着哪些门道。…...

Chatmark:Slack聊天记录自动化转Markdown文档的利器

1. 项目概述&#xff1a;从“聊天记录”到“结构化文档”的桥梁如果你和我一样&#xff0c;经常需要从各种即时通讯工具&#xff08;比如Slack、Teams&#xff0c;甚至是微信工作群&#xff09;的聊天记录里&#xff0c;整理会议纪要、提取待办事项&#xff0c;或者把一次技术讨…...

AI编码工作流:工程化实践框架与团队效能提升

1. 项目概述&#xff1a;从“AI编码工作流”说起最近在GitHub上看到一个挺有意思的项目&#xff0c;叫nicksp/ai-coding-workflow。光看这个名字&#xff0c;可能很多朋友会想&#xff0c;这不就是又一个教你怎么用ChatGPT或者Copilot写代码的教程吗&#xff1f;说实话&#xf…...

STM32的RTC掉电还能走时?深入聊聊后备域和纽扣电池那点事

STM32的RTC掉电还能走时&#xff1f;深入聊聊后备域和纽扣电池那点事 当你在深夜调试STM32的RTC功能时&#xff0c;是否曾好奇过这个小巧的实时时钟为何能在主电源断开后依然精准走时&#xff1f;这背后隐藏着STM32芯片设计中一个精妙的电源管理机制——后备域&#xff08;Back…...

3步解锁BitLocker加密盘:Linux/macOS跨平台数据恢复实战指南

3步解锁BitLocker加密盘&#xff1a;Linux/macOS跨平台数据恢复实战指南 【免费下载链接】dislocker FUSE driver to read/write Windows BitLocker-ed volumes under Linux / Mac OSX 项目地址: https://gitcode.com/gh_mirrors/di/dislocker 核心关键词&#xff1a;Bi…...

MarkFlowy桌面应用打包与发布:Tauri框架实战经验分享

MarkFlowy桌面应用打包与发布&#xff1a;Tauri框架实战经验分享 【免费下载链接】MarkFlowy The AI Markdown Editor 项目地址: https://gitcode.com/gh_mirrors/ma/MarkFlowy MarkFlowy作为一款高性能智能化跨端Markdown编辑器&#xff0c;采用Tauri框架实现了轻量级桌…...

掌握这四大趋势,让你的AI Agent真正“能干活”!CSDN收藏必备指南

本文深入探讨了企业级AI Agent的四大核心趋势&#xff1a;MCP协议实现可扩展集成、GraphRAG提升回答一致性、AgentDevOps确保行为质量与推理链路稳定性、RaaS模式实现结果计费。文章指出&#xff0c;这些趋势共同推动AI Agent从“可用”到“好用”的跨越&#xff0c;并提供了实…...