CREATE DATABASE `bank1` CHARACTER SET 'utf8' COLLATE 'utf8_general_ci';

DROP TABLE IF EXISTS `account_info`; CREATE TABLE `account_info` (`id` bigint(20) NOT NULL AUTO_INCREMENT,`account_name` varchar(100) CHARACTER SET utf8 COLLATE utf8_bin NULL DEFAULT NULL COMMENT '户主姓名',`account_no` varchar(100) CHARACTER SET utf8 COLLATE utf8_bin NULL DEFAULT NULL COMMENT '银行卡号',`account_password` varchar(100) CHARACTER SET utf8 COLLATE utf8_bin NULL DEFAULT NULL COMMENT '帐户密码',`account_balance` double NULL DEFAULT NULL COMMENT '帐户余额',PRIMARY KEY (`id`) USING BTREE) ENGINE = InnoDB AUTO_INCREMENT = 5 CHARACTER SET = utf8 COLLATE = utf8_bin ROW_FORMAT =Dynamic;INSERT INTO `account_info` VALUES (2, '张三的账户', '1', '', 10000);

CREATE DATABASE `bank2` CHARACTER SET 'utf8' COLLATE 'utf8_general_ci';

CREATE TABLE `account_info` (`id` bigint(20) NOT NULL AUTO_INCREMENT,`account_name` varchar(100) CHARACTER SET utf8 COLLATE utf8_bin NULL DEFAULT NULL COMMENT '户主姓名',`account_no` varchar(100) CHARACTER SET utf8 COLLATE utf8_bin NULL DEFAULT NULL COMMENT '银行卡号',`account_password` varchar(100) CHARACTER SET utf8 COLLATE utf8_bin NULL DEFAULT NULL COMMENT '帐户密码',`account_balance` double NULL DEFAULT NULL COMMENT '帐户余额',PRIMARY KEY (`id`) USING BTREE) ENGINE = InnoDB AUTO_INCREMENT = 5 CHARACTER SET = utf8 COLLATE = utf8_bin ROW_FORMAT =Dynamic;INSERT INTO `account_info` VALUES (3, '李四的账户', '2', NULL, 0);

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;

<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring‐boot‐dependencies</artifactId> <version>2.1.3.RELEASE</version> <type>pom</type> <scope>import</scope></dependency>
<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring‐cloud‐dependencies</artifactId> <version>Greenwich.RELEASE</version> <type>pom</type> <scope>import</scope></dependency>

<dependency> <groupId>com.alibaba.cloud</groupId> <artifactId>spring‐cloud‐alibaba‐dependencies</artifactId> <version>2.1.0.RELEASE</version> <type>pom</type> <scope>import</scope></dependency>

@Configurationpublic class DatabaseConfiguration {  @Bean @ConfigurationProperties(prefix = "spring.datasource.ds0")  public DruidDataSource ds0() { DruidDataSource druidDataSource = new DruidDataSource(); return druidDataSource; } @Primary @Bean public DataSource dataSource(DruidDataSource ds0) { DataSourceProxy pds0 = new DataSourceProxy(ds0); return pds0; }}

@Mapper @Componentpublic interface AccountInfoDao {
//更新账户金额@Update("update account_info set account_balance = account_balance + #{amount} where account_no = #{accountNo}")int updateAccountBalance(@Param("accountNo") String accountNo, @Param("amount") Double amount);
}

@FeignClient(value = "seata‐demo‐bank2",fallback = Bank2ClientFallback.class) public interface Bank2Client {
 @GetMapping("/bank2/transfer") String transfer(@RequestParam("amount") Double amount);}

@Componentpublic class Bank2ClientFallback implements Bank2Client{ @Override public String transfer(Double amount) {
 return "fallback"; }}

public class AccountInfoServiceImpl implements AccountInfoService { private Logger logger = LoggerFactory.getLogger(AccountInfoServiceImpl.class); @Autowired AccountInfoDao accountInfoDao; @Autowired Bank2Client bank2Client;
 //张三转账    @Override @GlobalTransactional @Transactional public void updateAccountBalance(String accountNo, Double amount) { logger.info("******** Bank1 Service Begin ... xid: {}", RootContext.getXID()); //张三扣减金额 accountInfoDao.updateAccountBalance(accountNo, amount *‐1); //向李四转账 String remoteRst = bank2Client.transfer(amount); //远程调用失败 if(remoteRst.equals("fallback")){ throw new RuntimeException("bank1 下游服务异常"); } //人为制造错误 if(amount==3){ throw new RuntimeException("bank1 make exception 3"); } }}

@RestControllerpublic class Bank1Controller {
 @Autowired AccountInfoService accountInfoService;
 //转账 @GetMapping("/transfer") public String transfer(Double amount){  accountInfoService.updateAccountBalance("1",amount);  return "bank1"+amount; }}

@Mapper @Componentpublic interface AccountInfoDao { //向李四转账 @Update("UPDATE account_info SET account_balance = account_balance + #{amount} WHERE account_no = #{accountNo}") int updateAccountBalance(@Param("accountNo") String accountNo, @Param("amount") Double amount);
}

@Servicepublic class AccountInfoServiceImpl implements AccountInfoService { private Logger logger = LoggerFactory.getLogger(AccountInfoServiceImpl.class); @Autowired AccountInfoDao accountInfoDao;
 @Override @Transactional public void updateAccountBalance(String accountNo, Double amount) { logger.info("******** Bank2 Service Begin ... xid: {}" , RootContext.getXID()); //李四增加金额 accountInfoDao.updateAccountBalance(accountNo,amount); //制造异常 if(amount==2){ throw new RuntimeException("bank1 make exception 2"); } }}

@RestControllerpublic class Bank2Controller {
 @Autowired AccountInfoService accountInfoService;
 @GetMapping("/transfer") public String transfer(Double amount){  accountInfoService.updateAccountBalance("2",amount); return "bank2"+amount; }}