RabbitMQ 持久化

这篇具有很好参考价值的文章主要介绍了RabbitMQ 持久化。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

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

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

交换机持久化

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

队列持久化

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

消息持久化

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

总结

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

到了这里,关于RabbitMQ 持久化的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • RabbitMQ---持久化

    • 如何避免消息丢失? 1) 消费者的ACK机制。可以防止消费者丢失消息。 2) 但是,如果在消费者消费之前,MQ就宕机了,消息就没了。 • 如何将消息进行持久化呢? 要将消息持久化,前提是:队列、Exchange都持久化

    2024年02月11日
    浏览(43)
  • RabbitMQ-数据持久化

    1、交换机持久化(SpringAMQP默认) 2、队列持久化(SpringAMQP默认) 3、消息持久化         如果采用纯内存操作,那么消息存储达到队列的上限之后,会有一个page out操作,这个操作是将队列中已经有的一部分MQ消息转移到磁盘,给队列腾出空间,使得队列能够继续接收MQ消息

    2024年01月21日
    浏览(42)
  • 【RabbitMQ】之持久化机制

    一、RabbitMQ 持久化机制 1、RabbitMQ 持久化概述 2、队列持久化 3、消息持久化 4、交换器持久化 二、RabbitMQ 知识扩展 1、内存告警与内存换页 2、磁盘告警与配置 3、数据写入磁盘时机 4、磁盘消息格式 5、磁盘文件删除机制 持久化 ,即将原本存在于内存中的数据写入到磁盘上永

    2024年02月14日
    浏览(38)
  • 【初始RabbitMQ】持久化的实现

    如何保障当 RabbitMQ 服务停掉以后消 息生产者发送过来的消息不丢失。默认情况下 RabbitMQ 退出或由于某种原因崩溃时,它忽视队列 和消息,除非告知它不要这样做。确保消息不会丢失需要做两件事: 我们需要将队列和消息都标记为持久化 之前我们创建的队列都是非持久化的

    2024年02月19日
    浏览(34)
  • 【RabbitMQ 实战】10 消息持久化和存储原理

    rabbitmq的持久化分为三个部分: 交换器的持久化。 队列的持久化。 消息的持久化。 1.1.1 交换器持久化 交换器的持久化是通过在声明交换器时, 指定Durability参数为durable实现的。 若交换器不设置持久化,在rabbitmq服务重启之后,相关的交换器元数据会丢失,但消息不会丢失,

    2024年02月07日
    浏览(40)
  • RabbitMQ队列持久化的重要性与意义

    持久化队列的一个主要目的是确保数据的安全性。在RabbitMQ中,消息通常存储在内存中,以提高消息传递的速度。然而,如果队列没有持久化,一旦RabbitMQ服务器发生故障或者重启,所有未被处理的消息都会丢失。这可能导致数据丢失,对于关键业务应用程序来说是不可接受的

    2024年02月07日
    浏览(34)
  • RabbitMQ消息中间件

    RabbitMQ消息中间件 RabbitMQ简介 windows下安装RabbitMQ RabbitMQ基本概念 RabbitMQ简单模式 RabbitMQ工作队列模式 RabbitMQ发布订阅模式 RabbitMQ路由模式 RabbitMQ主题模式 RabbitMQ RPC模式 RabbitMQ发布确认模式

    2024年02月10日
    浏览(57)
  • 消息中间件RabbitMQ

    1.1.1. 什么是MQ MQ(message queue) ,从字面意思上看,本质是个队列,FIFO 先入先出,只不过队列中存放的内容是message 而已,还是一种跨进程的通信机制,用于上下游传递消息。在互联网架构中,MQ 是一种非常常见的上下游“逻辑解耦+物理解耦”的消息通信服务。使用了 MQ 之后,

    2024年01月17日
    浏览(80)
  • RabbitMQ (HelloWord 消息应答 持久化 不公平分发 预取值)

    在下图中,“P”是我们的生产者,“C”是我们的消费者。中间的框是一个队列-RabbitMO.代表使用者保留的消息缓冲区 第一步:导入依赖 第二步:创建生产者 第三步:创建消费者 因为你为了确保同一条消息被其中一个工作线程接收到了之后,其它工作就不能消费的到了 三者

    2023年04月14日
    浏览(41)
  • 消息中间件RabbitMQ详解

    消息中间件利用高效可靠的消息传递机制进行平台无关的数据交流,并基于数据通信来进行分布式系统的集成。通过提供消息传递和消息排队模型,它可以在分布式环境下扩展进程间的通信。 消息中间件适用于需要可靠的数据传送的分布式环境。采用消息中间件机制的系统中

    2024年02月16日
    浏览(76)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包