分布式事务：SpringBoot+Dubbo+Seata+Nacos 实现案例

CREATE TABLE `undo_log` (

  `id` bigint(20) NOT NULL AUTO_INCREMENT,

  `branch_id` bigint(20) NOT NULL,

  `xid` varchar(100) NOT NULL,

  `context` varchar(128) NOT NULL,

  `rollback_info` longblob NOT NULL,

  `log_status` int(11) NOT NULL,

  `log_created` datetime NOT NULL,

  `log_modified` datetime NOT NULL,

  `ext` varchar(100) DEFAULT NULL,

  PRIMARY KEY (`id`),

  UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`)

) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;

CREATE TABLE `t_user` (
  `id`bigint(32) NOT NULL AUTO_INCREMENT,
  `userName`varchar(32) NOT NULL,
  `passWord`varchar(50) NOT NULL,
  `realName`varchar(32) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8;

spring.datasource.platform=mysql
db.num=1
db.url.0=jdbc:mysql://127.0.0.1:3306/nacos?characterEncoding=utf8&connectTimeout=1000&socketTimeout=3000&autoReconnect=true
db.user=root
db.password=123456

/**
 * 发起事务控制器
 *
 * @author louis
 */
@RestController
public class TccController {

    @Resource
    private TccTransactionService tccTransactionService;

    /**
     * 分布式事务提交示例接口
     */
    @GetMapping("/testCommit")
    public String testCommit() {
        String result = tccTransactionService.testCommit();
        return "----------test transaction commit---------- \n" + result;
    }

    /**
     * 分布式事务回滚示例接口
     */
    @GetMapping("/testRollback")
    public String testRollback() {
        String result = "";
        try {
            tccTransactionService.testRollback();
        } catch (Throwable t) {
            result = t.getMessage();
        }
        return  "----------test transaction rollback ---------- \n" + result;
    }
}

@Service
public class TccTransactionService {

    @Resource
    private TccActionOne tccActionOne;
    @Resource
    private TccActionTwo tccActionTwo;
    @Reference(version = "1.0.0", group = "tcc")
    private UserService userService;

    /**
     * 测试分布式事务提交示例
     */
    @GlobalTransactional
    public String testCommit() {
        // 第一个TCC 事务参与者
        String result = tccActionOne.prepare("action-one-commit").getMessage();
        // 第二个TCC 事务参与者
        result = result + "\n" + tccActionTwo.prepare("action-two-commit").getMessage();
        // 数据库操作
        userService.save(getUser());
        return result;
    }

    /**
     * 测试分布式事务回滚示例
     */
    @GlobalTransactional
    public String testRollback() {
        //第一个TCC 事务参与者
        String result = tccActionOne.prepare("action-one-rollback").getMessage();
        // 第二个TCC 事务参与者
        result = result + "\n" + tccActionTwo.prepare("action-two-rollback").getMessage();
        // 数据库操作
        userService.save(getUser());
        throw new RuntimeException(result);
    }
}

seata:
  application-id: ${spring.application.name}
  tx-service-group: my_test_tx_group # 事务分组，与seata-server配置保持一致
  registry:
    type: nacos
    nacos:
      server-addr: 127.0.0.1:8848
      namespace:
      cluster: default
  config:
    type: nacos
    nacos:
      namespace:
      server-addr: 127.0.0.1:8848

@Component
@Service(version = "1.0.0", group = "tcc")
public class ActionOneServiceImpl implements ActionOneService {

    @Override
    public String prepare(String param) {
        String result = ":::: action-one-provider prepare, rpc called success, param:" + param + ".";
        System.out.println(result);
        return result;
    }

    @Override
    public String commit(String param) {
        String result = ":::: action-one-provider commit, rpc called success, param:" + param + ".";
        System.out.println(result);
        return result;
    }

    @Override
    public String rollback(String param) {
        String result = ":::: action-one-provider rollback, rpc called success, param:" + param + ".";
        System.out.println(result);
        return result;
    }
}

org.mybatis.spring.boot
    mybatis-spring-boot-starter
    1.3.2mysql
    mysql-connector-java

@Component
@Service(version = "1.0.0", group = "tcc")
public class UserServiceImpl implements UserService {

    @Resource
    private UserMapper userMapper;

    @Override
    public User save(User user) {
        if(user.getId() == null || "".equals(user.getId())) {
            userMapper.insert(user);
        } else {
            userMapper.updateByPrimaryKeySelective(user);
        }
        return user;
    }

...

}