Spring Cloud Alibaba 实战(八) - 审核业务的分布式事务处理实现
本文主要讲解RabbitMQ的介绍和安装,Spring Cloud Stream核心概念,Spring Cloud Alibaba RocketMQ学习,异步消息推送与消费
1 审核业务的实现 
-
com/javaedge/contentcenter/service/content/ShareService.java
假设添加积分操作很耗时,我们的主要操作是审核,而不关心积分,所以可以将其异步化
1.1 Spring实现异步的方法
◆ AsyncRestTemplate
- 参考文档
Spring 的异步HTTP请求AsyncRestTemplate
◆ @ Async注解
- 参考文档
https://spring.io/guides/gs/a...
◆ WebClient ( Spring 5.0引入 ,为取代AsyncRestTemplate)
- 参考文档
https://docs.spring.io/spring... RELEASE/spring-framework-reference/web-reactive.html#webflux-client
◆ MQ
我们采用此法
2 引入MQ后的架构演进
3 MQ适用场景
- 异步处理
- 流量削峰填谷
- 解耦微服务
4 MQ的选择
流行的MQ那么多,如何选择?
- Kafka、RabbitMQ、 RocketMQ、 ActiveMQ...
5 搭建RocketMQ
- 下载与安装
RocketMQ实战(一) - 简介
6 搭建RocketMQ控制台
- 修改pom.xml版本
- 修改代码
7 Spring消息编程模型
- 推荐Maven依赖版本分析插件
7.1 编写生产者
content-center
开始拿出三板斧:
- 引入依赖
- 添加注解
无
- 写配置
- 服务类添加模板类
7.2 编写消费者
user-center
- 依赖
- 配置
-
com.javaedge.contentcenter.rocketmq.AddBonusTransactionListener
小结
- RocketMQ : RocketMQMessageListener
- ActiveMQ/Artemis : JmsListener
- RabbitMQ : RabbitListener
- Kafka : KafkaListener
8 分布式事务
流程剖析、概念术语、
如何实现事务呢,我们知道Spring有事务注解,那么直接就添加@Transaction注解吧!
可这样是万无一失了吗?显然不行,因为消息已经发出,没法撤回了
那么看看RocketMQ是怎么解决分布式事务问题呢
8.1 实现分布式事务流程
业务流程图
- 半消息,虽然被存储到MQserver,但会被标记为暂时不能投递,所以消费者不会接受到该消息
- 半消息发送成功,开始3
- 开始执行本地事务
- 生产者根据本地事务,发送二次确认请求
MQServer如果从4中接收到的是
- commit,就把消息置为可投递,这样消费者就可消费该消息了 - rollback:将该消息删除
- MQServer未收到4中的二次确认消息,就会回查
- 生产者检查本地事务的执行结果
- 根据本地事务执行结果,发送commit/rollback消息
总体来说,就是生产者把消息发送到MQ,但MQ只是将其标记,不让消费者消费
然后生产者就执行本地事务,执行完后就知道到底是该投递还是丢弃该消息了!
这其实就是典型的二次确认
消费回查就是防止二次确认消息发送异常的容错处理
8.2 关键概念
◆ 半消息( Half(Prepare) Message )
暂时无法消费的消息。生产者将消息发送到了MQ server ,但这个消息会被标记为"暂不能投递"状态,先存储起来;消费者不会去消费这条消息。
并不是消息的状态,只是一种特殊的消息而已
◆ 消息回查(Message Status Check )
网络断开或生产者重启可能导致丢失事务消息的第二次确认。当MQ Server发现消息长时间处于半消息状态时,将向消息生产者发送请求,询问该消息的最终状态(提交或回滚)。
8.3 事务消息三状态
◆ Commit
提交事务消息,消费者可以消费此消息
◆ Rollback
回滚事务消息, broker会删除该消息,消费者不能消费.
◆UNKNOWN
broker需要回查确认该消息的状态
9 分布式事务 - 编码实现
- 在内容中心新增事务日志表
rocketmq_transaction_log
对照上一小节流程图,开始code!
9.1/2 发半消息
改造接口
- 将原先如下代码删除
- 改为如下接方法
9.3 执行本地事务
- 新建
rocketmq包,并在其中创建一个新类AddBonusTransactionListener
- 一定要在该类上加
@RocketMQTransactionListener注解
其中的txProducerGroup一定要对应哦
注意这里的
- msg参数即对应
- args参数即对应
- 回查本地事务执行结果,即通过查询日志记录表,该表在执行完本地事务后更新
- 这即可回查啦
参考
- 消息队列对比参照表
- RocketMQ vs. ActiveMQ vs. Kafka
- 面向未来微服务:Spring Cloud Alibaba从入门到进阶
本文由博客一文多发平台 OpenWrite 发布！
正文到此结束
- 本文标签： java 配置 分布式事务 lib message RocketMQ spring 安装 消息队列 client ActiveMQ 分布式 https HTML 参数 JMS id 时间 REST 下载 MQ stream pom 代码 插件 博客 IO 微服务 maven NSA 架构演进 删除 Service Spring cloud db IDE list http Action 模型 web UI XML src producer rabbitmq
- 版权声明： 本文为互联网转载文章，出处已在文章中说明(部分除外)。如果侵权，请联系本站长删除，谢谢。
- 本文海报： 生成海报一 生成海报二
热门推荐
相关文章
近期评论
-
666
-
文章和留言都翻到11页了 没有OOM
-
-
朋友，翻页到11页，及以后，会出现OOM，无法访问
-
-
-
-
版本号是多少，你可以下载哪个代码仓库，jdk选1.8 直接跑就行
-
-
Loading...
![[HBLOG]公众号](https://www.liuhaihua.cn/img/qrcode_gzh.jpg)
