

首页  流程图  详情



分布式事务-本地消息表

2021-07-14 16:00:58   1  举报





分布式事务-本地消息表

MQ事务

CAP理论

架构设计

模版推荐

作者其他创作

大纲/内容

微服务A

Ack

Request

4、发布消息

事件总线

1、拿到消息入库

消费消息

微服务B

3、消费消息

本地事务1、本地业务操作2、消息表入库操作状态

状态（成功）

消息状态（失败）

1、至少成功一次2、重试策略进行重试3、定时删除已发布成功的消息4、发布重试达到上限依然失败之后回调重试失败统一异常处理、例如回调统一发送邮件人工干预5、发送失败消息15天以后自动删除

3、内存发布队列轮询

2、Ack确认消息

分布式事务最终一致性

5、接收Ack消息

1、业务操作2、发布消息

状态（失败）

1、消费消息

定时任务

5、接收Ack消息6、修改消息状态

定时任务1、重试策略进行重试2、定时删除已消费成功的消息

消息状态（成功）

发布消息

业务表本地消息表

1、支持幂等自定义幂等2、消费消息支持重试策略配置3、失败消息会发送的队列名称.error队列（异常队列）支持再次消费4、找不到消费者队列会进入队列名.skip队列（跳过队列）支持再次消息5、支持回调队列

1、至少成功一次2、支持幂等、自定义幂等策略3、重试策略进行重试4、失败消息进行回调补偿队列，补偿事务5、定时删除已消费成功的消息6、消费重试达到上限依然失败之后回调重试失败统一异常处理、例如回调统一发送邮件人工干预7、消费失败消息15天以后自动删除

状态（调度中）

消息状态（调度中）

 Collect

Get Started

分布式事务解决方案-本地消息表

 Collect

Get Started

分布式事务-本地消息表

 Collect

Get Started

分布式事务

 Collect

Get Started

基于状态表的分布式事务





0 条评论

下一页