rabbitemq-补偿队列: RabbitMq解决分布式事务（最终一致性原理），这里主要使用了补偿队列

> 参考链接：

https://blog.csdn.net/qq_31463999/article/details/89788176?utm_medium=distribute.pc_aggpage_search_result.none-task-blog-2~all~first_rank_v2~rank_v25-3-89788176.nonecase&utm_term=rabbitmq%20%E8%A1%A5%E5%8D%95%E6%9C%BA%E5%88%B6

## MQ解决分布式事务三个重要概念

**1、	确保生产者消息一定要投递到MQ服务器中 Confirm机制**

**2、	确保消费者能够正确的消费消息，采用手动ACK（注意幂等）**

**3、	如何保证第一个事务一定要创建成功（在创建一个补单的队列，绑定同一个交换机，检查订单数据是否已经创建在数据库中 实现补偿机制）**

## 生产者 一定确保消息投递到MQ服务器（使用）

RabbitMQ解决分布式事务问题

**RabbitMQ解决分布式事务原理： 采用最终一致性原理**。
需要保证以下三要素:

- 确认生产者一定要将数据投递到MQ服务器中（采用MQ消息确认机制）
- MQ消费者消息能够正确消费消息，采用手动ACK模式（注意重试幂等性问题）
- 如何保证第一个事务先执行，采用补偿机制，在创建一个补单消费者进行监听，如果订单没有创建成功，进行补单。(如果第一个事务中出错，补单消费者会在重新执行一次第一个事务，例如第一个事务是添加订单表，如果失败在补单的时候重新生成订单记录，由于订单号唯一，所以不会重复)

**核心代码是下面的部分，主要是下单队列和补单队列的routingkey要一样：**

```
@Component
public class RabbitmqConfig {

// 下单并且派单存队列
	public static final String ORDER_DIC_QUEUE = "order_dic_queue";
	// 补单队列，判断订单是否已经被创建
	public static final String ORDER_CREATE_QUEUE = "order_create_queue";
	// 下单并且派单交换机
	private static final String ORDER_EXCHANGE_NAME = "order_exchange_name";

// 1.定义订单队列
	@Bean
	public Queue directOrderDicQueue() {
		return new Queue(ORDER_DIC_QUEUE);
	}

// 2.定义补订单队列
	@Bean
	public Queue directCreateOrderQueue() {
		return new Queue(ORDER_CREATE_QUEUE);
	}

// 2.定义交换机
	@Bean
	DirectExchange directOrderExchange() {
		return new DirectExchange(ORDER_EXCHANGE_NAME);
	}

// 3.订单队列与交换机绑定
	@Bean
	Binding bindingExchangeOrderDicQueue() {
		return BindingBuilder.bind(directOrderDicQueue()).to(directOrderExchange()).with("orderRoutingKey");
	}

// 3.补单队列与交换机绑定
	@Bean
	Binding bindingExchangeCreateOrder() {
		return BindingBuilder.bind(directCreateOrderQueue()).to(directOrderExchange()).with("orderRoutingKey");
	}

}
```

qmhl开到荼蘼/rabbitemq-补偿队列

简介

发行版

贡献者

近期动态

qmhl开到荼蘼/rabbitemq-补偿队列 .gitee-modal { width: 500px !important; }

简介

发行版

贡献者

近期动态

搜索帮助

qmhl开到荼蘼/rabbitemq-补偿队列