最新要闻

广告

手机

iphone11大小尺寸是多少？苹果iPhone11和iPhone13的区别是什么？

iphone11大小尺寸是多少？苹果iPhone11和iPhone13的区别是什么？

 警方通报辅警执法直播中被撞飞：犯罪嫌疑人已投案

警方通报辅警执法直播中被撞飞：犯罪嫌疑人已投案

家电

  1. 首页
  2. 移动通信
  3. 内容

Seata分布式事务框架示例

来源：博客园

一、背景

阿里给出了Seata的官方示例，地址: https://github.com/seata/seata-samples, 提供了很多示例：


【资料图】

  • springcloud-seata-sharding-jdbc-mybatis-plus-samplesEasy to understand, high availability，Integration example ofSpring Cloud，Seata,ShardingJdbc,MyBatisPlus.
  • spring-cloud-alibaba-samples- Spring Cloud Alibaba + Nacos + Dubbo + OpenFeign + Sentinel + Seata
  • dubbo- Integration example ofSeataandApache Dubbo
  • springboot- Integration example ofSeataandSpring Boot
  • nacos- Integration example ofSeata、Apache DubboandAlibaba Nacos
  • springboot-dubbo-seata- Integration example ofSeata、Apache DubboandSpring Boot
  • nutzboot-dubbo-seata- Integration example ofSeata、Apache DubboandNutzBoot
  • springcloud-jpa-seata- Integration example ofSeataandSpring Cloudand JPA
  • spring-boot-multiple-datasource- Integration example ofSeataandSpring Bootwith multiple datasource and MyBatis
  • springboot-mybatis- Integration example ofSeataandSpring BootandMybatis
  • api- Non-Spring environment uses api to build Seata distributed transactions
  • spring-boot-multiple-datasource-mybatis-plus- Integration example ofSeataandSpring Bootwith multiple datasource andMyBatisPlus
  • springcloud-nacos-seata- Integration example ofSeataandSpring CloudandAlibaba Nacos
  • saga- Saga mode distributed transaction demo projects
  • dubbo-multiple-datasource-mybatis-plusIntegration example ofSeataandSpring BootApache Dubbowithdynamicmultiple datasource andMyBatisPlusandAlibaba Nacos

本文以springboot-mybatis为例，该示例中有5个module:

  • sbm-account-service
  • sbm-business-service
  • sbm-common-service
  • sbm-order-service
  • sbm-storage-service

二、环境部署

2.1 mysql DB建表

示例中提供了mysql的建表语句，位置：seata-samples/springboot-mybatis/sql/all_in_one.sql

建了3个DB, 详情如下：

dbtable1table2
db_account

account_tbl

undo_lob
db_orderorder_tblundo_lob
db_stockstock_tblundo_lob

2.2 Seata-Server 下载

官网下载：http://seata.io/zh-cn/blog/download.html

2.3 Seata-Server 配置

/conf/application.yml, seata3个节点(config、register、store)有多重配置方式，为了简单演示，这里采用默认file方式，其他方式可以参考application.example.yml

seata:  config:    # support: nacos, consul, apollo, zk, etcd3    type: file  registry:    # support: nacos, eureka, redis, zk, consul, etcd3, sofa    type: file  store:    # support: file 、 db 、 redis    mode: file

2.4Seata-Server 启动

sh/bin/seata-server.sh

启动日志：seata/logs/start.out

main] i.s.core.rpc.netty.NettyServerBootstrap : Server started, service listen port: 8091

默认启动接口：8091

三、服务启动

分别启动4个服务，启动端口分别为：

serverport
sbm-account-service8083
sbm-order-service8082
sbm-stock-service8081
sbm-business-service8084

四、测试

测试服务位置：sbm-business-service/src/main/java/io/seata/samples/business/controller/BusinessController.java

/**     * 购买下单，模拟全局事务提交     *     * @return     */    @RequestMapping("/purchase/commit")    public Boolean purchaseCommit(HttpServletRequest request) {        businessService.purchase("1001", "2001", 1);        return true;    }    /**     * 购买下单，模拟全局事务回滚     *     * @return     */    @RequestMapping("/purchase/rollback")    public Boolean purchaseRollback() {        try {            businessService.purchase("1002", "2001", 1);        } catch (Exception e) {            e.printStackTrace();            return false;        }        return true;    }

4.1 正常提交

http://localhost:8084/api/business/purchase/commit

4.2 异常提交

http://localhost:8084/api/business/purchase/rollback

关键词： 全局事务