首页 > 其他分享 >rabbitMQ消息可靠性

rabbitMQ消息可靠性

时间:2023-07-14 14:00:45浏览次数:37  
标签:可靠性 持久 Exchange rabbitMQ 保证 消息

rabbitMQ消息可靠性

 

rabbitMQ交换机不负责消息持久化

消息存储到队列中才可以手动开启持久化

 

生产者端:

如何保证消息一定可以送达Exchange

消费者端:

  自动ACK

  手动ACK

 

RabbitMQ保证消息可靠性:

  1.保证消息一定可以送达Exchange

    confirm机制

      可以通过Confirm效果保证消息一定可以送达Exchange,官方提供三种实现方式 

  2.保证消息可以路由到Queue

    return机制

  3.保证Queue可以持久化消息

    DelivryMode设置消息持久化:

      DeliveryMode设置为2则为持久化,1为非持久化

  4.保证消费者可以正常消费信息

 

标签:可靠性,持久,Exchange,rabbitMQ,保证,消息
From: https://www.cnblogs.com/HelloWorldKivsenTrprio/p/17553442.html

相关文章

  • java代码向stream消息队列发送消息失败
    如何实现Java代码向Stream消息队列发送消息失败作为一名经验丰富的开发者,您可以教会刚入行的小白如何实现Java代码向Stream消息队列发送消息失败。本文将按照以下流程展示步骤,并提供相应的代码和注释。流程图以下是实现该功能的整体流程图:步骤动作1.创建Stream连接......
  • rabbitMQ安装
    rabbitMQ安装安装依赖yum-yinstallgccgcc-c++ncurses-developenssl-develunixODBC-develperlvim安装Erlangtar-xvfotp_src_26.0-rc1.tar.gzcdotp_src_26.0-rc1./configure--prefix=/usr/local/erlang--enable-shared-zlib--with-ssl--enable-threads--e......
  • 九、顺序消息
    顺序消息是ApacheRocketMQ提供的一种高级消息类型,支持消费者按照发送消息的先后顺序获取消息,从而实现业务场景中的顺序处理。相比其他类型消息,顺序消息在发送、存储和投递的处理过程中,更多强调多条消息间的先后顺序关系。应用场景在有序事件处理、撮合交易、数据实时增量同......
  • 【跨平台通信消息格式包】
    【跨平台通信消息格式包】【跨平台通信消息格式包】[JSON]介绍:JSON(JavaScriptObjectNotation)是一种轻量级的数据交换格式。易于人阅读和编写,同时也易于机器解析和生成。它基于JavaScript(StandardECMA-2623rdEdition-December1999)的一个子......
  • rabbitmq 修改端口
    在C:\Users\Administrator\AppData\Roaming\RabbitMQ新建rabbitmq.config修改为:45672[{rabbit,[{tcp_listeners,[{"0.0.0.0",45672}]}]},{rabbitmq_management,[{listener,[{port,35672},{ip,"......
  • STM32:rtthread_消息队列
    1消息队列  消息队列是一种常用的线程间异步通讯方式;   消息队列能够接收来自线程或中断中不固定长度的消息,并把消息缓存在自己的内存空间中,供线程间进行异步通讯;  1.1结构体定义//rtconfig.h源码默认注释掉未开启,用到消息队列的时候需要自己开启;#defineRT_USI......
  • 【Netty】「优化进阶」(二)浅谈 LengthFieldBasedFrameDecoder:如何实现可靠的消息分割?
    前言本篇博文是《从0到1学习Netty》中进阶系列的第二篇博文,主要内容是通过不同的应用案例来了解LengthFieldBasedFrameDecoder是如何处理不同的消息,实现自动分割,往期系列文章请访问博主的Netty专栏,博文中的所有代码全部收集在博主的GitHub仓库中;介绍LengthFieldBasedFrameDe......
  • 【事务型消息】
    参考: https://developer.aliyun.com/article/712456 可以梳理一下完美解决“账单变更Case”需要解决的关键点:必须满足“一致性”要求,即账单服务数据库变更事务提交成功,风险控制服务和短信通知服务收到“账单变更”消息;账单服务数据库变更事务回滚,风险控制服务和短信通知......
  • rabbitmq php 代码示例
    交换机类型direct:直连交换机,根据路由键投递到与绑定键匹配的队列。fanout:扇形交换机,采用广播模式,投递到所有与之绑定的队列。topic :主题交换机,对路由键与绑定键进行模式匹配后再投递到相应的队列。headers:头交换机,不处理路由键,而是根据发送的消息内容中的heade......
  • 2023-07-12:RocketMQ如何做到消息不丢失?
    2023-07-12:RocketMQ如何做到消息不丢失?答案2023-07-12:RocketMQ通过刷盘机制、消息拉取机制和ACK机制等多种方式来确保消息投递的可靠性,防止消息丢失。1.刷盘机制RocketMQ中的消息分为内存消息和磁盘消息,内存消息在Broker内存中进行读写,磁盘消息则保存在磁盘上。RocketMQ支持同......