1. 前置准备

1.1 数据表准备

CREATE TABLE `t1` (
  `id` bigint(20) NOT NULL AUTO_INCREMENT,
  `name` varchar(20) NOT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8;

CREATE TABLE `t2` (
  `id` bigint(20) NOT NULL AUTO_INCREMENT,
  `name` varchar(20) NOT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8;

1.2 相关代码准备

1.2.1 T1实体类

@Data
@NoArgsConstructor
@AllArgsConstructor
@Entity
@Table(name = "t1")
public class T1 {

    @Id
    @Column(name = "id", nullable = false)
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;

    @Column(name = "name", nullable = false)
    private String name;
}

1.2.2 T2实体类

@Data
@NoArgsConstructor
@AllArgsConstructor
@Entity
@Table(name = "t2")
public class T2 {

    @Id
    @Column(name = "id", nullable = false)
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;

    @Column(name = "name", nullable = false)
    private String name;
}

1.2.3 dao接口定义

public interface T1Dao extends JpaRepository<T1, Long> {
}

public interface T2Dao extends JpaRepository<T2, Long> {
}

1.2.4 service编写

@Slf4j
@Service
public class T1Service {

    @Autowired
    private T1Dao t1Dao;

    public void save() {
        T1 t1 = new T1();
        t1.setName("t1");
        t1Dao.save(t1);
    }
}

@Slf4j
@Service
public class T2Service {

    @Autowired
    private T2Dao t2Dao;

    public void save() {
        T2 t2 = new T2();
        t2.setName("t2");
        t2Dao.save(t2);
    }
}

1.2.5 controller编写

@RestController
@RequestMapping("/t1")
@SuppressWarnings("rawtypes")
public class T1Controller {

    @Autowired
    private T1Service t1Service;

    @GetMapping
    public CommonResponse save() {
        t1Service.save();
        return CommonResponse.ok();
    }
}

@RestController
@RequestMapping("/t2")
@SuppressWarnings("rawtypes")
public class T2Controller {

    @Autowired
    private T2Service t2Service;

    @GetMapping
    public CommonResponse save() {
        t2Service.save();
        return CommonResponse.ok();
    }
}

1.2.6 在事务发起的服务定义Feign接口

@GetMapping("/assets/t1")
CommonResponse save();

@GetMapping("/vip/t2")
CommonResponse save();

1.2.7 TM编写

@Slf4j
@Service
public class TestService {

    @Autowired
    private VipFeignClient vipFeignClient;

    @Autowired
    private AssetsFeignClient assetsFeignClient;

    @GlobalTransactional
    public void save() {
        assetsFeignClient.save();
        log.info("wallet save completed");
        vipFeignClient.save();
    }
}