seata事务视频实践

绝地灬酷狼 2022-12-19 01:19 99阅读 0赞

### 分布式事务：熟悉 分布式事物2pc,3pc,TCC,消息事务（rocketmq）,最大努力通知和自定义本地消息及seata的at saga ###

### 20. 使用 AT 模式需要的注意事项有哪些 ？[http://seata.io/zh-cn/docs/overview/faq.html][http_seata.io_zh-cn_docs_overview_faq.html] ###

**A:**

1.  必须使用代理数据源，有 3 种形式可以代理数据源：

*  依赖 seata-spring-boot-starter 时，自动代理数据源，无需额外处理。
 *  依赖 seata-all 时，使用 @EnableAutoDataSourceProxy (since 1.1.0) 注解，注解参数可选择 jdk 代理或者 cglib 代理。
 *  依赖 seata-all 时，也可以手动使用 DatasourceProxy 来包装 DataSource。

1.  配置 GlobalTransactionScanner，使用 seata-all 时需要手动配置，使用 seata-spring-boot-starter 时无需额外处理。
2.  业务表中必须包含单列主键，若存在复合主键，请参考问题 13 。
3.  每个业务库中必须包含 undo\_log 表，若与分库分表组件联用，分库不分表。
4.  跨微服务链路的事务需要对相应 RPC 框架支持，目前 seata-all 中已经支持：Apache Dubbo、Alibaba Dubbo、sofa-RPC、Motan、gRpc、httpClient，对于 Spring Cloud 的支持，请大家引用 spring-cloud-alibaba-seata。其他自研框架、异步模型、消息消费事务模型请结合 API 自行支持。
5.  目前AT模式支持的数据库有：MySQL、Oracle、PostgreSQL和 TiDB。
6.  使用注解开启分布式事务时，若默认服务 provider 端加入 consumer 端的事务，provider 可不标注注解。但是，provider 同样需要相应的依赖和配置，仅可省略注解。
7.  使用注解开启分布式事务时，若要求事务回滚，必须将异常抛出到事务的发起方，被事务发起方的 @GlobalTransactional 注解感知到。provide 直接抛出异常 或 定义错误码由 consumer 判断再抛出异常。

上面seata:问题1,3,6,7问题要注意；

seata对 Dubbo 的支持，是利用了 Dubbo 框架的 *org.apache.dubbo.rpc.Filter* 机制。把xid注入Rootconext中通过inovoke()// 然后代理：业务方法的调用

1: seata

--------------------

先遗留两个问题

> 问题1：如果异常是在orderService子服务消费者内发生，orderItemService还会继续执行吗？觉得应该不会了吧？  
> 问题2：如果orderService发生异常，但是又想orderItemService继续执行而且还能正常提交，这种场景怎么用seata呢？不会直接用trycatch吧，

正文：先看图后实践：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMyNDQ3MzIx_size_16_color_FFFFFF_t_70][]

1:当Application（Controller）模拟Restful请求触发和返回下图

项目重新启动completed时间时**09：34：01，**异常事务测试是此时间之后。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMyNDQ3MzIx_size_16_color_FFFFFF_t_70 1][]

2：事务提供者Service发起者GlobalTransaction（时间**09：34：14开始**），并进行业务order-insert,与orderItem-insert两个业务操作,流程是先begin new Global transaction 标识ip:id； 异常时又一次 Begin new Global transaction；  下图console执行 时间和日志

成功insert  xid: ~1035   ;   fail回滚：xid: ~1038   (xid是全局事务id)

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMyNDQ3MzIx_size_16_color_FFFFFF_t_70 2][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMyNDQ3MzIx_size_16_color_FFFFFF_t_70 3][]

2.1：查看服务消费者orderSevice（时间**09：34：15开始**）; 由于Application模拟两次测试，第一次无RuntimeExp;第二次模拟测试触发的异常，所以orderSevice第一次模拟同时就会两段式事务机制并成功（下图SUCCESS蓝色区域onMessage:xid~1029,branchId=~1030），onMessage:xid~1035,branchId=~1036

第二次模拟RuntimeExp，当全局事务触发RuntimeExp, orderSevice重新onMessage:xid~1038,branchId=~1039，下图FAIL 红色区域，进行事务回滚

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMyNDQ3MzIx_size_16_color_FFFFFF_t_70 4][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMyNDQ3MzIx_size_16_color_FFFFFF_t_70 5][]

2.2：同理：服务消费者orderItemProvider，消费成功及回滚失败同” 服务消费者orderSevice“（时间**09：34：14开始**） orderSevice是onMessage:xid~1038,branchId=~1039；orderItemProvider是onMessage:xid~1038,branchId=~1040

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMyNDQ3MzIx_size_16_color_FFFFFF_t_70 6][]![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMyNDQ3MzIx_size_16_color_FFFFFF_t_70 7][]

3: seata数据库日志

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMyNDQ3MzIx_size_16_color_FFFFFF_t_70 8][]

[http_seata.io_zh-cn_docs_overview_faq.html]: http://seata.io/zh-cn/docs/overview/faq.html
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMyNDQ3MzIx_size_16_color_FFFFFF_t_70]: /images/20221120/94e8504412c04768a2dcdfbc3e957153.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMyNDQ3MzIx_size_16_color_FFFFFF_t_70 1]: /images/20221120/395325e7f63b444e92173bb8c9a4654a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMyNDQ3MzIx_size_16_color_FFFFFF_t_70 2]: /images/20221120/02e2edc376914d4099b54d811b0b16ef.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMyNDQ3MzIx_size_16_color_FFFFFF_t_70 3]: /images/20221120/2bafb33a0eac435c89393c43ef8fa2fa.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMyNDQ3MzIx_size_16_color_FFFFFF_t_70 4]: /images/20221120/eadb97d10cce4c48b91ceefcf0061ac6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMyNDQ3MzIx_size_16_color_FFFFFF_t_70 5]: /images/20221120/a681f5764e814a93ae743da3ef2ac8d0.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMyNDQ3MzIx_size_16_color_FFFFFF_t_70 6]: https://img-blog.csdnimg.cn/20201105093649306.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMyNDQ3MzIx,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMyNDQ3MzIx_size_16_color_FFFFFF_t_70 7]: /images/20221120/cf7bae6c80bf49c6887954cdcfa21638.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMyNDQ3MzIx_size_16_color_FFFFFF_t_70 8]: /images/20221120/75777f62e7dc48ae989f0c96bba4c0fc.png