rabbitMQ解决分布式事物

淡淡的烟草味﹌ 2022-04-22 11:34 276阅读 0赞

**RabbitMQ****解决分布式事务原理： 采用最终一致性原理。**

**需要保证以下三要素**

**1****、确认生产者一定要将数据投递到****MQ****服务器中（采用****MQ****消息确认机制）**

生产者发送消息代码：

// 封装消息
    Message message = MessageBuilder.withBody(msg.getBytes()).setContentType(MessageProperties.CONTENT_TYPE_JSON)
    				.setContentEncoding("utf-8").setMessageId(orderId).build();
    // 构建回调返回的数据
    CorrelationData correlationData = new CorrelationData(orderId);
    
    this.rabbitTemplate.setMandatory(true);
    this.rabbitTemplate.setConfirmCallback(this);
    
    // 发送消息
    rabbitTemplate.convertAndSend("order_exchange_name", "orderRoutingKey", message, correlationData);

生产者继承** **RabbitTemplate.ConfirmCallback ，重写confirm方法

// 生产消息确认机制
    @Override
    public void confirm(CorrelationData correlationData, boolean ack, String cause) {
    	String orderId = correlationData.getId();
    	System.out.println("消息id:" + correlationData.getId());
    	if (ack) {
    		System.out.println("消息发送确认成功");
    	} else {
    		send(orderId);
    		System.out.println("消息发送确认失败:" + cause);
    	}
    }

**2****、****MQ消费者消息能够正确消费消息，采用手动****ACK****模式（注意重试幂等性问题）**

**3****、如何保证第一个事务先执行，采用补偿机制，在创建一个补单消费者进行监听，如果订单没有创建成功，进行补单。**

发表评论取消回复

表情：

评论列表（有 0 条评论，276人围观）

还没有评论，来说两句吧...

相关阅读

相关分布式事物

一般分布式事物不能同时满足高可用性和一致性。如果是强一致性，那可用性，就不一定，实际是在高可用性的前提下，只要满足最终一致性就可以。分布式事物的几种解决方案 1 2阶

淡淡的烟草味﹌/ 2023年08月17日 16:05/ 0 赞/ 111 阅读

相关分布式事物的解决方案

一：理论依据（讨论的前提） 1. 本地事务、分布式事务（如果说本地事务是解决单个数据源上的数据操作的一致性问题的话，那么分布式事务则是为了解决跨越多个数据源上数据操作的一致

àì夳堔傛蜴生んèń/ 2023年06月23日 13:13/ 0 赞/ 100 阅读

相关分布式事物介绍

分布式事物本地事务概念分布式理论 CAP定理分布式事务概念分布式事务解决方法 1.两阶段提交（2PC）

向右看齐/ 2022年04月23日 12:20/ 0 赞/ 294 阅读

相关 rabbitMQ解决分布式事物

RabbitMQ解决分布式事务原理：采用最终一致性原理。需要保证以下三要素 1、确认生产者一定要将数据投递到MQ服务器中（采用MQ消息确认机制）生产者发送消息代码：

淡淡的烟草味﹌/ 2022年04月22日 11:34/ 0 赞/ 277 阅读

相关分布式事物几种解决方案

本文只做引荐，大概说一些自己的理解 -------------------- 分布式事物几种解决方案分布式不存在绝对的事物处理！！！大概四种解决方案 1.

比眉伴天荒/ 2022年04月16日 04:40/ 0 赞/ 273 阅读

相关 RabbitMQ分布式事物方案

我们在rabbitmq上肉身实战了一下可靠消息，rabbitmq的发送过程如下 1. 生产者发送消息到消息服务 2. 如果消息落地，则返回一个标志给消息发起端。 3.

系统管理员/ 2022年03月21日 02:51/ 0 赞/ 256 阅读

相关分布式事物

分布式事物事物特性(acid) 原子性（A）所谓的原子性就是说，在整个事务中的所有操作，要么全部完成，要么全部不做，没有中间状态。对于事务在执行中发生错误，所有

快来打我*/ 2022年02月17日 15:49/ 0 赞/ 268 阅读

相关分布式事物解决方案

分布式事物解决方案常见解决方案 1. 分布式事物解决方案可以使用全局事物2pc（两段提交协议）、3pc(三段提交协议)，tcc补偿机制、提供回滚接口、分布式数据库

朴灿烈づ我的快乐病毒、/ 2022年02月17日 15:45/ 0 赞/ 271 阅读

相关 rabbitmq-04 rabbitmq解决分布式事务

1.RabbitMQ消息重试机制消费者在消费消息的时候，如果消费者业务逻辑出现程序异常，这时候应该如何处理？答案：使用消息重试机制。(springb

短命女/ 2022年02月09日 14:21/ 0 赞/ 237 阅读

相关分布式事物

BASE理论：BASE理论是对CAP（Consistency：一致性、 Availability：可用性、Partition tolerance：分区容错性）中

蔚落/ 2022年02月02日 18:37/ 0 赞/ 304 阅读