0

0

分布式事务 :可靠消息最终一致性方案

Java后端技术全栈

Java后端技术全栈

发布时间:2023-08-24 15:27:42

|

897人浏览过

|

来源于Java后端技术全栈

转载


事务想必大家并不陌生,比如经常被人提起的ACID,但是为了后续的分布式事务的内容,我们先来聊聊 ACID,然后再介绍下什么是分布式事务,最后着重讲下基于可靠消息的分布式事务解决方案。

什么是事务

严格意义上的事务应该是具备原子性、一致性、隔离性和持久性,简称 ACID

  1. 原子性(Atomicity),可以理解为一个事务内的所有操作要么都执行,要么都不执行。
  2. 一致性(Consistency),可以理解为数据是满足完整性约束的,也就是不会存在中间状态的数据,比如你钱包有100,我钱包有100,你给我打50块,此时你钱包的钱应该是50,我钱包的钱应该是150,不会存在我钱加了,你钱没扣的中间状态。
  3. 隔离性(Isolation),指的是多个事务并发执行的时候不会互相干扰,即一个事务内部的数据对于其他事务来说是隔离的。
  4. 持久性(Durability),指的是一个事务完成了之后数据就被永远保存下来,之后的其他操作或故障都不会对事务的结果产生影响。

而通俗意义上事务就是为了使得一些更新操作要么都成功,要么都失败

什么是分布式事务

分布式事务顾名思义就是要在分布式系统中实现事务,它其实是由多个本地事务组合而成。

一次大的操作由不同的小操作组成的,这些小的操作分布在不同的服务器上,分布式事务需要保证这些小操作要么全部成功,要么全部失败。从本质上来说,分布式事务就是为了保证不同数据库数据一致性

常见的分布式事务的解决方案有以下几种:2PC,3PC,TCC,本地消息表、可靠消息最终一致性、尽最大努力通知

今天我们就着重讲讲可靠消息最终一致性的解决方案

什么是可靠消息最终一致性方案

可靠消息最终一致性方案是指当事务发起方执行完成本地事务后发出消息到消息中间件事务参与方(消息消费者)一定能够接收到消息并处理事务成功,此方案强调的是只要消息发给事务参与方,则最终事务要达到一致

这个方式存在哪些问题?

此方案是通过消息中间件实现的,事务发起方(消息生产方)将消息发给消息中间件,事务参与方从消息中间件接收消息,由于网络通信的不确定性会导致分布式事务问题,如下图:

分布式事务 :可靠消息最终一致性方案

  1. 本地事务与消息的原子性问题

分布式事务 :可靠消息最终一致性方案

如上图在虚线框内,存在以下几种情况:

1)本地事务提交失败,则消息不发送。
2)本地事务成功,消息发送失败,本地事务回滚。
3)本地消息成功,消息超时,本地事务回滚,消息最终失败。
4)本地消息成功,消息超时,本地事务回滚,消息最终成功。

综上所述,存在第四种情况,造成本地事务,与消息参与方的事务不一致。

  1. 事务参与方接收消息的可靠性。

消息中间件与事务参与方要确保能够成功消费到消息。

  1. 消息重复消费

注意事务参与方的接口幂等性问题,消息参与方可能已经成功消费,由于网络问题导致消息中间件认为消息未消费,发起重试之后产生的问题。

解决方案

  1. 本地消息表

本地消息表的关键在于本地有一张存储消息日志的记录表,需要启动一个定时任务去不停地扫描消息日志记录,确保消息能够被发送。具体流程如下图:

分布式事务 :可靠消息最终一致性方案

上图流程:

1)事务发起方本地事务执行成功,在本地消息表中记录消息日志。
2)启动定时任务,循环扫描本地消息表。
3)定时任务扫描到消息则发送消息到消息中间件。
4)消息中间件收到消息,成功返回消息发送成功通知给事务发起方。
5)事务发起方收到消息发送成功则删除日志消息。
6)事务参与方订阅消息,消费消息。
7)事务参与方处理本地事务。
8)本地事务处理成功,发送成功ack给消息中间件。

需要注意的点:
事务参与方保证接口幂等性

  1. RocketMq事务消息方案

Apache RocketMQ 4.3之后的版本正式支持事务消息,为分布式事务实现提供了便利性支持。在RocketMQ 4.3后实现了完整的事务消息,实际上其实是对本地消息表的一个封装,将本地消息表移动到了MQ内部,解决 Producer 端的消息发送与本地事务执行的原子性问题。

分布式事务 :可靠消息最终一致性方案

实现流程:

1)事务发起方发送Half事务消息
2)RocketMq回复Half发送成功
3)事务发起方执行本地事务
4)事务发起方执行本地事务成功,发送commit到RocketMq,mq投递消息到事务参与方;事务发起方执行本地事务失败,发送rollback到RocketMq,mq删除消息。
5)当RocketMq一定时间内未收到来自事务发起方的确认信息,会对事务发起方进行事务回查
6)事务发起方查询本地事务状态。
7)事务发起方根据查询到的事务状态发送commint/rollback到RocketMq。
8)当RocketMq发起commit后,收到失败或一定时间未收到成功ack,则会发起重试。

优点

消息数据独立存储,降低业务系统与消息系统之间的耦合。
吞吐量优于本地消息表方案。

缺点

一次消息发送需要两次网络请求(half消息 + commit/rollback)。
需要实现消息回查接口。

其实每种分布式事务的解决方案都有优劣,我们需要权衡利弊,选择最合适业务场景的一种才是王道!

相关专题

更多
什么是分布式
什么是分布式

分布式是一种计算和数据处理的方式,将计算任务或数据分散到多个计算机或节点中进行处理。本专题为大家提供分布式相关的文章、下载、课程内容,供大家免费下载体验。

325

2023.08.11

分布式和微服务的区别
分布式和微服务的区别

分布式和微服务的区别在定义和概念、设计思想、粒度和复杂性、服务边界和自治性、技术栈和部署方式等。本专题为大家提供分布式和微服务相关的文章、下载、课程内容,供大家免费下载体验。

232

2023.10.07

什么是中间件
什么是中间件

中间件是一种软件组件,充当不兼容组件之间的桥梁,提供额外服务,例如集成异构系统、提供常用服务、提高应用程序性能,以及简化应用程序开发。想了解更多中间件的相关内容,可以阅读本专题下面的文章。

178

2024.05.11

Golang 中间件开发与微服务架构
Golang 中间件开发与微服务架构

本专题系统讲解 Golang 在微服务架构中的中间件开发,包括日志处理、限流与熔断、认证与授权、服务监控、API 网关设计等常见中间件功能的实现。通过实战项目,帮助开发者理解如何使用 Go 编写高效、可扩展的中间件组件,并在微服务环境中进行灵活部署与管理。

212

2025.12.18

硬盘接口类型介绍
硬盘接口类型介绍

硬盘接口类型有IDE、SATA、SCSI、Fibre Channel、USB、eSATA、mSATA、PCIe等等。详细介绍:1、IDE接口是一种并行接口,主要用于连接硬盘和光驱等设备,它主要有两种类型:ATA和ATAPI,IDE接口已经逐渐被SATA接口;2、SATA接口是一种串行接口,相较于IDE接口,它具有更高的传输速度、更低的功耗和更小的体积;3、SCSI接口等等。

1023

2023.10.19

PHP接口编写教程
PHP接口编写教程

本专题整合了PHP接口编写教程,阅读专题下面的文章了解更多详细内容。

66

2025.10.17

php8.4实现接口限流的教程
php8.4实现接口限流的教程

PHP8.4本身不内置限流功能,需借助Redis(令牌桶)或Swoole(漏桶)实现;文件锁因I/O瓶颈、无跨机共享、秒级精度等缺陷不适用高并发场景。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

429

2025.12.29

数据库三范式
数据库三范式

数据库三范式是一种设计规范,用于规范化关系型数据库中的数据结构,它通过消除冗余数据、提高数据库性能和数据一致性,提供了一种有效的数据库设计方法。本专题提供数据库三范式相关的文章、下载和课程。

348

2023.06.29

高德地图升级方法汇总
高德地图升级方法汇总

本专题整合了高德地图升级相关教程,阅读专题下面的文章了解更多详细内容。

68

2026.01.16

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
CSS3 教程
CSS3 教程

共18课时 | 4.6万人学习

Git 教程
Git 教程

共21课时 | 2.8万人学习

golang和swoole核心底层分析
golang和swoole核心底层分析

共3课时 | 0.1万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号