SpringCloud Alibaba Seata (收藏版)_Java

一、简介

官网地址: http://seata.io/zh-cn/

1，概念

seata是一款开源的分布式事务解决方案，致力于在微服务架构在提供高性能和简单一样的分布式事务服务。

2，处理过程

transaction id xid:全局唯一的事务id

transaction coordinator(tc) :维护全局和分支事务的状态，驱动全局事务提交或回滚。

transaction manager™ :定义全局事务的范围：开始全局事务、提交或回滚全局事务。

resource manager(rm) :管理分支事务处理的资源，与tc交谈以注册分支事务和报告分支事务的状态，并驱动分支事务提交或回滚。

tm向tc申请开启一个全局事务，全局事务创建成功并生成一个全局唯一的xid
xid在微服务调用链路的上下文中传播
rm向tc注册分支事务，将其纳入xid对应全局事务的管辖
tm向tc发起针对xid的全局提交或回滚决议
tc调度xid下管辖的全部分支事务完成提交或回滚请求

二、seata-server的安装

1，下载

http://seata.io/zh-cn/blog/download.html 选择指定版本下载(我这里用的是0.9.0)

2，修改配置文件

修改seata/conf/file.conf

#将service中修改group
vgroup_mapping.my_test_tx_group = "my_group"
#将store模块修改为db并修改数据连接，将conf目录下的db_store.sql文件导入到数据库中
mode = "db"
db {
  datasource = "dbcp"
  db-type = "mysql"
  driver-class-name = "com.mysql.jdbc.driver"
  url = "jdbc:mysql://127.0.0.1:3306/seata"
  user = "root"
  password = "123456"
}

修改seata/conf/registry.conf

registry {
 type = "nacos"
 nacos {
  serveraddr = "localhost:8848"
  namespace = ""
  cluster = "default"
 }

三、seata的应用

1，订单服务

源码: seata-order-service2001

a，配置pom

<!--nacos-->
<dependency>
  <groupid>com.alibaba.cloud</groupid>
  <artifactid>spring-cloud-starter-alibaba-nacos-discovery</artifactid>
</dependency>
<!--seata-->
<dependency>
  <groupid>com.alibaba.cloud</groupid>
  <artifactid>spring-cloud-starter-alibaba-seata</artifactid>
  <exclusions>
    <exclusion>
      <artifactid>seata-all</artifactid>
      <groupid>io.seata</groupid>
    </exclusion>
  </exclusions>
</dependency>
<dependency>
  <groupid>io.seata</groupid>
  <artifactid>seata-all</artifactid>
  <version>0.9.0</version>
</dependency>
<!--feign-->
<dependency>
  <groupid>org.springframework.cloud</groupid>
  <artifactid>spring-cloud-starter-openfeign</artifactid>
</dependency>
<!--web-actuator-->
<dependency>
  <groupid>org.springframework.boot</groupid>
  <artifactid>spring-boot-starter-web</artifactid>
</dependency>
<dependency>
  <groupid>org.springframework.boot</groupid>
  <artifactid>spring-boot-starter-actuator</artifactid>
</dependency>
<!--mysql-druid-->
<dependency>
  <groupid>mysql</groupid>
  <artifactid>mysql-connector-java</artifactid>
  <version>5.1.37</version>
</dependency>
<dependency>
  <groupid>com.alibaba</groupid>
  <artifactid>druid-spring-boot-starter</artifactid>
  <version>1.1.10</version>
</dependency>
<dependency>
  <groupid>org.mybatis.spring.boot</groupid>
  <artifactid>mybatis-spring-boot-starter</artifactid>
  <version>2.0.0</version>
</dependency>

b，配置yaml

server:
 port: 2001

spring:
 application:
  name: seata-order-service
 cloud:
  alibaba:
   seata:
    #自定义事务组名称需要与seata-server中的对应
    tx-service-group: my_group
  nacos:
   discovery:
    server-addr: localhost:8848
 datasource:
  driver-class-name: com.mysql.jdbc.driver
  url: jdbc:mysql://localhost:3306/seata_order
  username: root
  password: 123456

feign:
 hystrix:
  enabled: false

logging:
 level:
  io:
   seata: info

mybatis:
 mapperlocations: classpath:mapper/*.xml

c，添加file.conf(与seata-server配置相同)

transport {
 # tcp udt unix-domain-socket
 type = "tcp"
 #nio native
 server = "nio"
 #enable heartbeat
 heartbeat = true
 #thread factory for netty
 thread-factory {
  boss-thread-prefix = "nettyboss"
  worker-thread-prefix = "nettyservernioworker"
  server-executor-thread-prefix = "nettyserverbizhandler"
  share-boss-worker = false
  client-selector-thread-prefix = "nettyclientselector"
  client-selector-thread-size = 1
  client-worker-thread-prefix = "nettyclientworkerthread"
  # netty boss thread size,will not be used for udt
  boss-thread-size = 1
  #auto default pin or 8
  worker-thread-size = 8
 }
 shutdown {
  # when destroy server, wait seconds
  wait = 3
 }
 serialization = "seata"
 compressor = "none"
}

service {

 vgroup_mapping.my_group = "default"

 default.grouplist = "127.0.0.1:8091"
 enabledegrade = false
 disable = false
 max.commit.retry.timeout = "-1"
 max.rollback.retry.timeout = "-1"
 disableglobaltransaction = false
}

client {
 async.commit.buffer.limit = 10000
 lock {
  retry.internal = 10
  retry.times = 30
 }
 report.retry.count = 5
 tm.commit.retry.count = 1
 tm.rollback.retry.count = 1
}

## transaction log store
store {
 ## store mode: file、db
 mode = "db"

 ## file store
 file {
  dir = "sessionstore"

  # branch session size , if exceeded first try compress lockkey, still exceeded throws exceptions
  max-branch-session-size = 16384
  # globe session size , if exceeded throws exceptions
  max-global-session-size = 512
  # file buffer size , if exceeded allocate new buffer
  file-write-buffer-cache-size = 16384
  # when recover batch read size
  session.reload.read_size = 100
  # async, sync
  flush-disk-mode = async
 }

 ## database store
 db {
  ## the implement of javax.sql.datasource, such as druiddatasource(druid)/basicdatasource(dbcp) etc.
  datasource = "dbcp"
  ## mysql/oracle/h2/oceanbase etc.
  db-type = "mysql"
  driver-class-name = "com.mysql.jdbc.driver"
  url = "jdbc:mysql://127.0.0.1:3306/seata"
  user = "root"
  password = "123456"
  min-conn = 1
  max-conn = 3
  global.table = "global_table"
  branch.table = "branch_table"
  lock-table = "lock_table"
  query-limit = 100
 }
}
lock {
 ## the lock store mode: local、remote
 mode = "remote"

 local {
  ## store locks in user's database
 }

 remote {
  ## store locks in the seata's server
 }
}
recovery {
 #schedule committing retry period in milliseconds
 committing-retry-period = 1000
 #schedule asyn committing retry period in milliseconds
 asyn-committing-retry-period = 1000
 #schedule rollbacking retry period in milliseconds
 rollbacking-retry-period = 1000
 #schedule timeout retry period in milliseconds
 timeout-retry-period = 1000
}

transaction {
 undo.data.validation = true
 undo.log.serialization = "jackson"
 undo.log.save.days = 7
 #schedule delete expired undo_log in milliseconds
 undo.log.delete.period = 86400000
 undo.log.table = "undo_log"
}

## metrics settings
metrics {
 enabled = false
 registry-type = "compact"
 # multi exporters use comma divided
 exporter-list = "prometheus"
 exporter-prometheus-port = 9898
}

support {
 ## spring
 spring {
  # auto proxy the datasource bean
  datasource.autoproxy = false
 }
}

d，添加registry.conf(与seata-server的配置相同)

registry {
 # file 、nacos 、eureka、redis、zk、consul、etcd3、sofa
 type = "nacos"

 nacos {
  serveraddr = "localhost:8848"
  namespace = ""
  cluster = "default"
 }
 eureka {
  serviceurl = "http://localhost:8761/eureka"
  application = "default"
  weight = "1"
 }
 redis {
  serveraddr = "localhost:6379"
  db = "0"
 }
 zk {
  cluster = "default"
  serveraddr = "127.0.0.1:2181"
  session.timeout = 6000
  connect.timeout = 2000
 }
 consul {
  cluster = "default"
  serveraddr = "127.0.0.1:8500"
 }
 etcd3 {
  cluster = "default"
  serveraddr = "http://localhost:2379"
 }
 sofa {
  serveraddr = "127.0.0.1:9603"
  application = "default"
  region = "default_zone"
  datacenter = "defaultdatacenter"
  cluster = "default"
  group = "seata_group"
  addresswaittime = "3000"
 }
 file {
  name = "file.conf"
 }
}

config {
 # file、nacos 、apollo、zk、consul、etcd3
 type = "file"

 nacos {
  serveraddr = "localhost"
  namespace = ""
 }
 consul {
  serveraddr = "127.0.0.1:8500"
 }
 apollo {
  app.id = "seata-server"
  apollo.meta = "http://192.168.1.204:8801"
 }
 zk {
  serveraddr = "127.0.0.1:2181"
  session.timeout = 6000
  connect.timeout = 2000
 }
 etcd3 {
  serveraddr = "http://localhost:2379"
 }
 file {
  name = "file.conf"
 }
}

e，fegin调用(这里以其中一个account为例)

@feignclient(value = "seata-account-service")
public interface accountservice {

  @requestmapping("/account/decrease")
  public commonresult decrease(@requestparam("userid") long userid, @requestparam("money") bigdecimal money);

}

f，事务service

@slf4j
@service
public class orderserviceimpl implements orderservice {

  @autowired
  orderdao orderdao;
  @autowired
  accountservice accountservice;
  @autowired
  storageservice storageservice;

  @override
  @globaltransactional(name = "my-order-test",rollbackfor = exception.class) //加注解使用全局的事务，name 为事务名称不重复就行
  public long create(order order) {
    log.info("=========================下订单，开始");
    orderdao.create(order);
    log.info("=========================下订单，完成");

    log.info("=========================减库存，开始");
    storageservice.decrease(order.getproductid(), order.getcount());
    log.info("=========================减库存，完成");

    log.info("=========================减积分，开始");
    accountservice.decrease(order.getuserid(), order.getmoney());
    log.info("=========================减积分，完成");

    log.info("=========================订单状态修改，开始");
    orderdao.update(order.getid(),1);
    log.info("=========================订单状态修改，完成");

    return order.getid();
  }
}

g，启动类

2，库存服务

源码： seata-storage-service2002

与订单服务中的a，b，c，d，g配置步骤相同

3，账户服务

源码: seata-account-service2003

与库存服务的配置步骤相同