rabbitmq生产者基于事务实现发送确认

【README】业务场景：业务处理伴随消息的发送，业务处理失败（事务回滚）后要求消息不发送。

补充1：ACK与CONFIRM的区别

ACK-消费者消费成功后确认；（消费者确认已收到）

CONFIRM-事务生产者异常事务回滚，不发送到mq服务器代理;（生产者确认发送成功）

补充2：参考了这篇文章，写的非常棒； https://blog.csdn.net/u013256816/article/details/55515234/

【1】交换机，队列声明与绑定

/*** 交换机，队列声明与绑定 */
public class ConfirmDeclarer {/** 确认交换机 */public static final String CONFIRM_EXCHANGE2 = "CONFIRM_EXCHNAGE2";/** 确认队列 */public static final String CONFIRM_QUEUE2 = "CONFIRM_QUEUE2";/** 路由键  */public static final String CONFIRM_ROUTE2 = "CONFIRM_ROUTE2";//    四种Exchange 模式
//    direct ：需要生产者和消费者绑定相同的Exchange和routing key。
//    fanout：广播模式需要生产者消费者绑定相同的Exchange。
//    topic：支持模糊匹配的广播模式以点分隔，*表示一个单词，#表示任意数量（零个或多个）单词。
//    header：根据生产者和消费者的header中信息进行匹配性能较差 ，x-match [all 匹配所有/any 任意一个]。public static void main(String[] args) throws Exception {/* 获取连接*/Connection conn = RBConnectionUtil.getConn();// 创建信道 Channel channel = conn.createChannel(); /* 声明交换机 */channel.exchangeDeclare(CONFIRM_EXCHANGE2, BuiltinExchangeType.FANOUT);/* 声明队列 */channel.queueDeclare(CONFIRM_QUEUE2, true, false, false, null); System.out.println(String.format("声明交换机【%s】，队列【%s】成功", CONFIRM_EXCHANGE2, CONFIRM_QUEUE2));/* 把队列绑定到交换机 */channel.queueBind(CONFIRM_QUEUE2, CONFIRM_EXCHANGE2, CONFIRM_ROUTE2);/* 关闭信道和连接 */channel.close();conn.close(); }
}

【2】生产者，基于事务实现消息确认

/*** 消息确认生产者*/
public class ConfirmProducer {public static void main(String[] args) throws Exception {/* 获取连接*/Connection conn = RBConnectionUtil.getConn();// 创建信道 Channel channel = conn.createChannel();String[] messages = new String[]{"first.-04130828", "second..-04130828", "third...-04130828", "fourth....-04130828", "fiveth.....-04130828", "6th.....-04130828", "7th.....-04130828", "8th.....-04130828", "9th.....-04130828", "10th.....-04130828"};channel.txSelect(); // 开启事务int i=0;for (String msg : messages) {try {send(channel, msg); // 发送消息 System.out.println(msg + " is sent");if (++i > 5) {int temp = 1/0; // 抛出0除异常  } channel.txCommit(); // 提交事务 System.out.println("消息发送完成，事务提交，消息=" + msg); } catch(Exception e) { channel.txRollback(); // 抛出异常， 回滚事务System.out.println("抛出异常，消息发送取消，事务回滚，消息=" + msg);  }}channel.close(); conn.close();}private static void send(Channel channel, String msg) throws Exception { //  发送消息channel.basicPublish(ConfirmDeclarer.CONFIRM_EXCHANGE2, ConfirmDeclarer.CONFIRM_ROUTE2, null, msg.getBytes());}
}

【3】日志

SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.
first.-04130828 is sent
消息发送完成，事务提交，消息=first.-04130828
second..-04130828 is sent
消息发送完成，事务提交，消息=second..-04130828
third...-04130828 is sent
消息发送完成，事务提交，消息=third...-04130828
fourth....-04130828 is sent
消息发送完成，事务提交，消息=fourth....-04130828
fiveth.....-04130828 is sent
消息发送完成，事务提交，消息=fiveth.....-04130828
6th.....-04130828 is sent
抛出异常，消息发送取消，事务回滚，消息=6th.....-04130828
7th.....-04130828 is sent
抛出异常，消息发送取消，事务回滚，消息=7th.....-04130828
8th.....-04130828 is sent
抛出异常，消息发送取消，事务回滚，消息=8th.....-04130828
9th.....-04130828 is sent
抛出异常，消息发送取消，事务回滚，消息=9th.....-04130828
10th.....-04130828 is sent
抛出异常，消息发送取消，事务回滚，消息=10th.....-04130828

【4】rabbitmq首页查看队列中的消息总数

rabbitmq生产者基于事务实现发送确认相关推荐

RabbitMq（十三）消息发送确认与回调机制
在rabbitmq中如何确认消息发送到交换机上以及是否正常交换机转发到消息队列上,在rabbitmq上均有其确认实现接口. confirm-callback :消息确认机制,也就是消息是否正常发送到交 ...
Springboot RabbitMQ 基础使用、消息发送确认、签收
概述 rabbitMQ 会做一个系列,包括:安装.基础使用.高级队列.集群. 使用环境: jdk 8 .springboot 2.4.10 常见概念: AMQP:高级消息队列协议,这是一个消息应用的规 ...
rabbitmq 查询版本_基于rabbitmq解决分布式事务
分布式事务要解决的问题是保证二个数据库数据的一致性,本地事务ACID属于刚性事务,基于CAP理论,分布式事务的核心要点柔性事务,最终一致性. 基于rabbitmq解决分布式事务要点如下生产者采用发送 ...
rabbitmq怎样确认是否已经消费了消息_【朝夕专刊】RabbitMQ生产者/消费者消息确认...
欢迎大家阅读<朝夕Net社区技术专刊> 我们致力于.NetCore的推广和落地,为更好的帮助大家学习,方便分享干货,特创此刊!很高兴你能成为忠实读者,文末福利不要错过哦! 上篇文章介绍了R ...
基于RabbitMQ的分布式事务最终一致性解决方案
1. 分布式事务所谓事务,通俗一点讲就是一系列操作要么同时成功,要么同时失败.而分布式事务就是这一系列的操作在不同的节点上,那要如何保证事务的ACID特性呢. 原子性(atomicity).一个事务 ...
RabbitMQ之事务以及Confirm确认模式
spring:rabbitmq:port: 5672host: 127.0.0.1username: guestpassword: guest 事务事务的实现主要是对信道(Channel)的设置,主 ...
RabbitMq 消息发送确认(可靠生产和推送确认)
RabbitMq 消息发送确认(可靠生产和推送确认) 此文档只是本人在项目中碰到的一些问题而产生的个人相关总结,实际上的消息确认机制可以做得更多(比如分布式事务等,但此处不做阐述). 一.消息发送确认 ...
rabbitmq 启动异常_RabbitMQ：消息发送确认与消息接收确认（ACK）
默认情况下如果一个 Message 被消费者所正确接收则会被从 Queue 中移除如果一个 Queue 没被任何消费者订阅,那么这个 Queue 中的消息会被 Cache(缓存),当有消费者订阅时则 ...
rabbitmq 手动提交_第四章----SpringBoot+RabbitMQ发送确认和消费手动确认机制
1. 配置RabbitMQ # 发送确认 spring.rabbitmq.publisher-confirms=true # 发送回调 spring.rabbitmq.publisher-return ...

rabbitmq生产者基于事务实现发送确认

rabbitmq生产者基于事务实现发送确认相关推荐

最新文章

热门文章