分布式事务-本地消息表
2021-07-14 16:00:58 1 举报
分布式事务-本地消息表
作者其他创作
大纲/内容
微服务A
Ack
Request
4、发布消息
事件总线
1、拿到消息入库
消费消息
微服务B
3、消费消息
本地事务1、本地业务操作2、消息表入库操作状态
状态（成功）
消息状态（失败）
1、至少成功一次2、重试策略进行重试3、定时删除已发布成功的消息4、发布重试达到上限依然失败之后回调重试失败统一异常处理、例如回调统一发送邮件人工干预5、发送失败消息15天以后自动删除
3、内存发布队列轮询
2、Ack确认消息
分布式事务最终一致性
MQ
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天以后自动删除
状态（调度中）
消息状态（调度中）
0 条评论
回复 删除
下一页
