RabbitMQ事务机制和确认机制

文章目录

    • 生产者:RabbitMQ提供transaction和confirm模式来确保生产者不丢消息
    • RabbitMQ 事务机制
    • RabbitMQ确认机制

生产者:RabbitMQ提供transaction和confirm模式来确保生产者不丢消息

● 通过事务实现
● 通过发送方确认机制(publisher confirm)实现
1.1事务机制:发送消息前,开启事务(channel.txSelect()),然后发送消息,如果发送过程中出现什么异常,事务就会回滚(channel.txRollback()),如果发送成功则提交事务(channel.txCommit())。这种方式有个缺点:吞吐量下降;
事务实现
● channel.txSelect(): 将当前信道设置成事务模式
● channel.txCommit(): 用于提交事务
● channel.txRollback(): 用于回滚事务
通过事务实现机制,只有消息成功被rabbitmq服务器接收,事务才能提交成功,否则便可在捕获异常之后进行回滚,然后进行消息重发,但是事务非常影响rabbitmq的性能。还有就是事务机制是阻塞的过程,只有等待服务器回应之后才会处理下一条消息

confirm模式用的居多
一旦channel进入confirm模式,所有在该信道上发布的消息都将会被指派一个唯一的ID(从1开始),一旦消息被投递到所有匹配的队列之后;rabbitMQ就会发送一个ACK给生产者(包含消息的唯一ID),这就使得生产者知道消息已经正确到达目的队列了;如果rabbitMQ没能处理该消息,则会发送一个Nack消息给你,你可以进行重试操作。
confirm方式有三种模式:普通confirm模式、批量confirm模式、异步confirm模式
channel.confirmSelect(): 将当前信道设置成了confirm模式
普通confirm模式
每发送一条消息,就调用waitForConfirms()方法,等待服务端返回Ack或者nack消息

RabbitMQ 事务机制

RabbitMQ 提供了事务机制来确保消息的可靠性传递。使用事务机制时,可以在发送消息之前开启一个事务,在事务内发送消息并进行确认提交,以确保消息被正确地发送到 RabbitMQ 中。
下面是使用 RabbitMQ 事务机制发送消息的一般步骤:

  1. 开启事务:通过 tx_select() 方法开启一个事务。
  2. 发送消息:在事务内使用 basic_publish() 方法发送消息到指定的 Exchange 和队列。
  3. 提交事务:通过 tx_commit() 方法提交事务,确保在事务内的操作生效。
  4. 回滚事务(可选):如果发送消息过程中出现异常或错误,可以通过 tx_rollback() 方法回滚事务,撤销事务内的操作。
    当使用 Java 编程语言与 RabbitMQ 一起使用时,您可以通过以下步骤来使用 RabbitMQ 的事务机制:
1. 创建 RabbitMQ 连接和信道:
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost");
Connection connection = factory.newConnection();
Channel channel = connection.createChannel();
2. 开启事务:
channel.txSelect();
3. 发布消息到队列:
String message = "Hello, RabbitMQ!";
channel.basicPublish("", "queue_name", null, message.getBytes());
4. 提交事务:
channel.txCommit();
System.out.println("Message sent successfully");
5. 回滚事务(可选):
channel.txRollback();
System.out.println("Failed to send message");
需要注意的是,在使用事务机制时,如果发生异常或错误,您可以选择回滚事务以撤销之前的操作,或者提交事务以确认消息的发送。
下面是一个完整的示例代码,演示了如何在 Java 中使用 RabbitMQ 的事务机制:
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.Channel;public class RabbitMqTransactionExample {private static final String QUEUE_NAME = "queue_name";public static void main(String[] args) {try {ConnectionFactory factory = new ConnectionFactory();factory.setHost("localhost");Connection connection = factory.newConnection();Channel channel = connection.createChannel();// 开启事务channel.txSelect();String message = "Hello, RabbitMQ!";// 发布消息到队列channel.basicPublish("", QUEUE_NAME, null, message.getBytes());// 提交事务channel.txCommit();System.out.println("Message sent successfully");} catch (Exception e) {// 回滚事务channel.txRollback();System.out.println("Failed to send message");e.printStackTrace();}}
}

请注意,事务机制会对性能产生一定的影响,因为它需要进行额外的操作来维护事务的一致性。在高并发场景下,使用事务可能会导致性能下降。因此,在选择使用事务机制时,请根据实际需求和性能要求进行权衡。
需要注意的是,事务机制会对性能产生一定的影响,因为它需要进行额外的操作来维护事务的一致性。在高并发场景下,使用事务可能会导致性能下降。因此,在选择使用事务机制时,请根据实际需求和性能要求进行权衡。
总的来说,事务机制提供了一种确保消息传递可靠性的方法,但在实际应用中需要慎重考虑其对性能的影响。在大部分情况下,使用确认机制(Publisher Confirm)已经能够满足消息传递的可靠性要求,并且对性能影响较小。

RabbitMQ确认机制

RabbitMQ 的确认机制(Publisher Confirm)是一种用于确保消息可靠发送的机制。通过确认机制,生产者可以在消息被成功投递到 RabbitMQ Broker 后得到确认,从而确保消息已经安全地保存在 Broker 中,而不是在传输过程中丢失。
使用确认机制时,需要将信道(channel)设置为 confirm 模式,然后在发送消息后等待确认。确认可以是单条消息的确认,也可以是批量消息的确认。
当使用 Java 编程语言与 RabbitMQ 一起使用时,您可以使用 RabbitMQ 的确认机制(Publisher Confirm)来确保消息的可靠发送。以下是使用 RabbitMQ 确认机制的一般步骤:

1. 创建 RabbitMQ 连接和信道:
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost");
Connection connection = factory.newConnection();
Channel channel = connection.createChannel();
2. 设置信道为确认模式:
channel.confirmSelect();
3. 发布消息到队列:
String message = "Hello, RabbitMQ!";
channel.basicPublish("", "queue_name", null, message.getBytes());
4. 等待确认:
if (channel.waitForConfirms()) {System.out.println("Message sent successfully");
} else {System.out.println("Failed to send message");
}在上述代码中,我们首先创建了 RabbitMQ 连接和信道。然后,通过 channel.confirmSelect() 将信道设置为确认模式。接下来,我们使用 basicPublish() 方法发布消息到指定的队列。最后,通过 channel.waitForConfirms() 等待消息的确认,如果成功确认,则输出 "Message sent successfully",否则输出 "Failed to send message"。
请注意,RabbitMQ 的确认机制支持批量确认,即可以一次确认多条消息。您可以在 basicPublish() 方法之前调用 channel.getNextPublishSeqNo() 获取当前消息的序列号,然后在 waitForConfirms() 方法中使用 channel.waitForConfirms(sequenceNumber) 来等待指定序列号之前的所有消息确认。
以下是一个完整的示例代码,演示了如何在 Java 中使用 RabbitMQ 的确认机制:
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.Channel;public class RabbitMqConfirmExample {private static final String QUEUE_NAME = "queue_name";public static void main(String[] args) {try {ConnectionFactory factory = new ConnectionFactory();factory.setHost("localhost");Connection connection = factory.newConnection();Channel channel = connection.createChannel();// 设置信道为确认模式channel.confirmSelect();String message = "Hello, RabbitMQ!";// 发布消息到队列channel.basicPublish("", QUEUE_NAME, null, message.getBytes());// 等待确认if (channel.waitForConfirms()) {System.out.println("Message sent successfully");} else {System.out.println("Failed to send message");}} catch (Exception e) {System.out.println("Failed to send message");e.printStackTrace();}}
}

确认机制是一种轻量且高效的方式来确保消息的可靠性传递。相比于事务机制,确认机制对性能的影响较小,因此在大多数情况下推荐使用确认机制。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/735331.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

N32L40x基于串口IAP实现(含升级工具)

bootloader实现要点 bootloader 设计要点 1.分配Flash空间,一部分用于bootloader 一部分用于 APP ,这里bootloader分配了7K空间,APP分配了121K空间 2.需要准备一个通讯接口,可以是串口,也可以时can等 3.准备mcu的内部flash驱动,可以实现连续读写的函数,flash擦除在写函…

数据结构-栈-表达式运算

文章目录 表达式运算实现:1.栈实现2.中缀表达式转后缀表达式计算 表达式运算实现: 1.栈实现 public class ExpressCalc {public static void main(String[] args) {/*使用栈实现一个0-9整数带括号的表达式计算处理步骤:1.创建两个栈&#x…

Yolov8-pose关键点检测:特征融合涨点篇 | 广义高效层聚合网络(GELAN) | YOLOv9

💡💡💡本文独家改进:即结合用梯度路径规划(CSPNet)和(ELAN)设计了一种广义的高效层聚合网络(GELAN),高效结合YOLOv8-pose,实现涨点。 将GELAN添加在backbone和head处,提供多个yaml改进方法 Yolov8-Pose关键点检测专栏介绍:https://blog.csdn.net/m0_6377421…

SSRF服务器请求伪造原理和pikachu靶场实验

★★免责声明★★ 文章中涉及的程序(方法)可能带有攻击性,仅供安全研究与学习之用,读者将信息做其他用途,由Ta承担全部法律及连带责任,文章作者不承担任何法律及连带责任。 1、SSRF简介 SSRF全称:Server-Side Request…

java两个实体类相同属性的复制

1、操作对象工具 MyBeanUtils package com.nrxt.nms.mon.pt.cascade.utils;import org.apache.commons.lang.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.BeanUtils; import org.springframework.beans.BeansEx…

017集——圆弧(ARC)转多段线(lwpolyline)——cad vba 中按一定精度拟合加点实现

在国土资源管理项目中,我们经常会遇到CAD转gis数据实现入库,而cad中的arc圆弧转为gis数据只能转出弧的顶点坐标,导致图形变形失真。若一个一个对弧进行手工增加点转为多段线,耗时耗力,效率极其低下。这里给出解决方案&…

C#(C Sharp)学习笔记_字符串的常用操作方法【十一】

文章目录 索引字符串( Index )遍历字符串( for )拆分字符串( Split )替代字符串( Replace )提取字符串( Substring )插入字符串( Insert )移除字符串( Remove ) 索引字符串( Index ) 当我们要查看字符串中的某个字符时,我们可以使用索引功能。 string ax "我…

继承杂谈。

内容一览 前言继承的概念及定义继承的意义继承关系及访问限定符父类和子类对象之间的转化继承后的作用域继承与有元继承与静态成员多继承继承和组合的区别:继承的总结和反思 前言 面向对象的三大特性:封装继承和多态,这三种特性优者很紧密地联…

【Prometheus】PromQL

数据类型 即时向量(instant vector) node_cpu_seconds_total{instance"ahoj-dev-ubuntu-virtualbox",mode"idle"} 区间向量(range vector) node_cpu_seconds_total{instance"ahoj-dev-ubuntu-virtu…

手拉手RocketMQ基础

消息中间件的对比 消息中间件 ActiveMQ RabbitMQ RocketMQ kafka 开发语言 java erlang java scala 单击吞吐量 万级 万级 10万级 10万级 时效性 ms us ms ms 可用性 高(主从架构) 高(主从架构) 非常高(主从架构) 非常高(主从架构) 消息中间件: activ…

MetaGPT部分源码解读

Action SerializationMixin: Pydantic在序列化一个对象时,会将其序列化为其最顶层父类的形式,而不是它实际子类的形式。这意味着,如果你有一个父类和一个继承自该父类的子类,当你将子类的实例序列化时,得到…

HTTP常见报错响应码

HTTP 响应状态代码指示特定 HTTP 请求是否已成功完成。响应分为五类: 信息响应成功响应重定向客户端错误服务器错误 1 、信息响应 100 Continue 这个临时响应表明,迄今为止的所有内容都是可行的,客户端应该继续请求,如果已经完 …

云上攻防-云产品篇堡垒机场景JumpServer绿盟SASTeleport麒麟齐治

知识点 1、云产品-堡垒机-产品介绍&攻击事件 2、云产品-堡垒机-安全漏洞&影响产品 章节点: 云场景攻防:公有云,私有云,混合云,虚拟化集群,云桌面等 云厂商攻防:阿里云,腾讯…

k8a 对外服务(ingress)详解(定义,暴露,代理,重写,)

目录 一、 对外服务 service策略的作用 外部访问方案 适用场景和限制 ingress如何实现对外服务 ingress 概念 定义 组成 工作原理 总结 二、 部署 nginx-ingress-controller 创建 ingress-controller pod及相关资源 创建目录: 下载配置文件 修改 集群…

CSS拖曳盒子案例

让我为大家带来一个小案例吧&#xff01; <!DOCTYPE html> <html><head><meta charset"utf-8"><title></title><style>* {margin: 0;padding: 0;}.box1 {width: 100px;height: 100px;background-color: black;margin-bot…

iMazing3 2024详细解析数据备份与恢复备份

iMazing 3的备份功能支持增量备份&#xff08;类似苹果电脑里的Time Machine功能&#xff09;&#xff0c;意思是第一次把移动设备的数据全部备份下来&#xff0c;之后的备份就只针对数据有变化的那部分&#xff0c;这样可以节省大量的时间和存储空间&#xff0c;不会让使用者为…

LeetCode59:螺旋矩阵Ⅱ

题目描述 给你一个正整数 n &#xff0c;生成一个包含 1 到 n2 所有元素&#xff0c;且元素按顺时针顺序螺旋排列的 n x n 正方形矩阵 matrix 。 示例 1&#xff1a; 输入&#xff1a;n 3 输出&#xff1a;[[1,2,3],[8,9,4],[7,6,5]] 代码 class Solution { public:vector…

00-ESP-IDF 环境配置指南

ESP-IDF 环境配置指南 ESP-IDF安装 1.首先我们在浏览器搜索esp-idf&#xff0c;点击第一个选项 2.点击右边栏的安装 3.我们选择手动安装选择需要的系统版本 4.点击链接 5.这里我们选择一个版本&#xff0c;建议不要选择最新的&#xff0c;安装出现问题在网上不好找到解决办…

蓝桥杯备战刷题-滑动窗口

今天给大家带来的是滑动窗口的类型题&#xff0c;都是十分经典的。 1&#xff0c;无重复字符的最长子串 看例三&#xff0c;我们顺便来说一下子串和子序列的含义 子串是从字符串里面抽出来的一部分&#xff0c;不可以有间隔&#xff0c;顺序也不能打乱。 子序列也是从字符串里…

Vue+SpringBoot打造个人健康管理系统

目录 一、摘要1.1 项目介绍1.2 项目录屏 二、功能模块2.1 健康档案模块2.2 体检档案模块2.3 健康咨询模块 三、系统展示四、核心代码4.1 查询健康档案4.2 新增健康档案4.3 查询体检档案4.4 新增体检档案4.5 新增健康咨询 五、免责说明 一、摘要 1.1 项目介绍 基于JAVAVueSpri…