rabbitMQ解决分布式事物

淡淡的烟草味﹌ 2022-04-22 11:34 170阅读 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 条评论，170人围观）

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

相关阅读

相关分布式事物

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

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

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

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

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

相关 rabbitMQ解决分布式事物

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

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

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

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

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

相关 RabbitMQ分布式事物方案

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

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

相关分布式事物

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

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

相关分布式事物解决方案

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

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

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

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

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

相关分布式事物

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

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

相关 RabbitMQ解决分布式事务

[RabbitMQ解决分布式事务][RabbitMQ] 案例：经典案例，以目前流行点外卖的案例，用户下单后，调用订单服务，让后订单服务调用派单系统通知送外卖人员送单

深藏阁楼爱情的钟/ 2022年01月28日 11:35/ 0 赞/ 219 阅读