Seata 分布式事务功能测试（三）

￡神魔★判官ぃ 2023-06-06 10:50 37阅读 0赞

> 前置内容：[Seata 分布式事务功能测试（一）][Seata]

当前数据库隔离级别为 read\_commit，测试调用服务后，再通过服务查询时获取的数据是否正确。

//查询当前账户余额
    Double amount = accountService.getAmount(orderVO.getUserId());
    logger.info("扣款前余额: " + amount);
    accountService.decreaseAccount(accountVO);
    //查询当前账户余额
    amount = accountService.getAmount(orderVO.getUserId());
    logger.info("扣款后余额: " + amount);

## 1. 测试用例 1 ##

> 结果：操作成功，库存变成500，余额变成2000，增加一个新订单

### 1.1 business 日志: ###

2019-10-11 10:09:07,960 [DubboServerHandler-10.10.10.130:20883-thread-27] INFO  i.s.t.a.DefaultGlobalTransaction - Begin new global transaction [10.42.1.30:8091:2024332412]
    开始全局事务，XID = 10.42.1.30:8091:2024332412
    2019-10-11 10:09:10,599 [DubboServerHandler-10.10.10.130:20883-thread-27] INFO  i.s.t.a.DefaultGlobalTransaction - [10.42.1.30:8091:2024332412] commit status:Committed

### 1.2 storage 日志: ###

2019-10-11 10:09:07,975 [DubboServerHandler-10.10.10.130:20882-thread-13] DEBUG c.n.s.d.T.decreaseStorage - ==>  Preparing: update t_storage set count = count-500 where commodity_code = ? and count >= ?
    2019-10-11 10:09:07,977 [DubboServerHandler-10.10.10.130:20882-thread-13] DEBUG c.n.s.d.T.decreaseStorage - ==> Parameters: C201901140001(String), 500(Integer)
    2019-10-11 10:09:08,430 [DubboServerHandler-10.10.10.130:20882-thread-13] DEBUG c.n.s.d.T.decreaseStorage - <==    Updates: 1
    2019-10-11 10:09:11,397 [rpcDispatch_RMROLE_3_8] INFO  i.s.c.r.n.RmMessageListener - onMessage:xid=10.42.1.30:8091:2024332412,branchId=2024332415,branchType=AT,resourceId=jdbc:mysql://10.10.10.233:3306/seata_demo_storage,applicationData=null
    2019-10-11 10:09:11,397 [rpcDispatch_RMROLE_3_8] INFO  i.s.r.AbstractRMHandler - Branch committing: 10.42.1.30:8091:2024332412 2024332415 jdbc:mysql://10.10.10.233:3306/seata_demo_storage null
    2019-10-11 10:09:11,397 [rpcDispatch_RMROLE_3_8] INFO  i.s.r.AbstractRMHandler - Branch commit result: PhaseTwo_Committed

### 1.3 account 日志: ###

2019-10-11 10:09:08,570 [DubboServerHandler-10.10.10.130:20880-thread-2] INFO  i.s.c.l.EnhancedServiceLoader - load ContextCore[null] extension by class[io.seata.core.context.ThreadLocalContextCore]
    2019-10-11 10:09:08,632 [DubboServerHandler-10.10.10.130:20880-thread-2] DEBUG c.n.a.d.T.selectOne - ==>  Preparing: SELECT id,user_id,amount FROM t_account WHERE user_id = ?
    2019-10-11 10:09:08,649 [DubboServerHandler-10.10.10.130:20880-thread-2] DEBUG c.n.a.d.T.selectOne - ==> Parameters: 1(String)
    2019-10-11 10:09:08,748 [DubboServerHandler-10.10.10.130:20880-thread-2] DEBUG c.n.a.d.T.selectOne - <==      Total: 1
    2019-10-11 10:09:08,807 [DubboServerHandler-10.10.10.130:20880-thread-3] DEBUG c.n.a.d.T.decreaseAccount - ==>  Preparing: update t_account set amount = amount-3000.0 where user_id = ? and amount > ?
    2019-10-11 10:09:08,808 [DubboServerHandler-10.10.10.130:20880-thread-3] DEBUG c.n.a.d.T.decreaseAccount - ==> Parameters: 1(String), 3000.0(Double)
    2019-10-11 10:09:09,268 [DubboServerHandler-10.10.10.130:20880-thread-3] DEBUG c.n.a.d.T.decreaseAccount - <==    Updates: 1
    2019-10-11 10:09:09,272 [DubboServerHandler-10.10.10.130:20880-thread-3] INFO  i.s.c.l.EnhancedServiceLoader - load LoadBalance[null] extension by class[io.seata.discovery.loadbalance.RandomLoadBalance]
    2019-10-11 10:09:09,415 [DubboServerHandler-10.10.10.130:20880-thread-3] INFO  i.s.c.l.EnhancedServiceLoader - load UndoLogParser[jackson] extension by class[io.seata.rm.datasource.undo.parser.JacksonUndoLogParser]
    2019-10-11 10:09:09,545 [DubboServerHandler-10.10.10.130:20880-thread-4] DEBUG c.n.a.d.T.selectOne - ==>  Preparing: SELECT id,user_id,amount FROM t_account WHERE user_id = ?
    2019-10-11 10:09:09,546 [DubboServerHandler-10.10.10.130:20880-thread-4] DEBUG c.n.a.d.T.selectOne - ==> Parameters: 1(String)
    2019-10-11 10:09:09,550 [DubboServerHandler-10.10.10.130:20880-thread-4] DEBUG c.n.a.d.T.selectOne - <==      Total: 1
    2019-10-11 10:09:11,459 [rpcDispatch_RMROLE_1_8] INFO  i.s.c.r.n.RmMessageListener - onMessage:xid=10.42.1.30:8091:2024332412,branchId=2024332418,branchType=AT,resourceId=jdbc:mysql://10.10.10.233:3306/seata_demo_account,applicationData=null
    2019-10-11 10:09:11,460 [rpcDispatch_RMROLE_1_8] INFO  i.s.r.AbstractRMHandler - Branch committing: 10.42.1.30:8091:2024332412 2024332418 jdbc:mysql://10.10.10.233:3306/seata_demo_account null
    2019-10-11 10:09:11,461 [rpcDispatch_RMROLE_1_8] INFO  i.s.r.AbstractRMHandler - Branch commit result: PhaseTwo_Committed

### 1.4 order 日志: ###

2019-10-11 10:09:08,523 [DubboServerHandler-10.10.10.130:20881-thread-2] INFO  i.s.c.l.EnhancedServiceLoader - load ContextCore[null] extension by class[io.seata.core.context.ThreadLocalContextCore]
    2019-10-11 10:09:08,795 [DubboServerHandler-10.10.10.130:20881-thread-2] INFO  c.n.o.s.i.TOrderServiceImpl - 扣款前余额: 4000.0
    2019-10-11 10:09:09,583 [DubboServerHandler-10.10.10.130:20881-thread-2] INFO  c.n.o.s.i.TOrderServiceImpl - 扣款后余额: 1000.0
    2019-10-11 10:09:09,871 [DubboServerHandler-10.10.10.130:20881-thread-2] DEBUG c.n.o.d.T.insert - ==>  Preparing: INSERT INTO t_order ( id,order_no,user_id,commodity_code,count,amount ) VALUES( ?,?,?,?,?,? )
    2019-10-11 10:09:09,890 [DubboServerHandler-10.10.10.130:20881-thread-2] DEBUG c.n.o.d.T.insert - ==> Parameters: 1314754168291853302(Long), 2d247c43418545b4812a4a8cc9efd718(String), 1(String), C201901140001(String), 500(Integer), 3000.0(Double)
    2019-10-11 10:09:10,178 [DubboServerHandler-10.10.10.130:20881-thread-2] DEBUG c.n.o.d.T.insert - <==    Updates: 1
    2019-10-11 10:09:10,185 [DubboServerHandler-10.10.10.130:20881-thread-2] INFO  i.s.c.l.EnhancedServiceLoader - load LoadBalance[null] extension by class[io.seata.discovery.loadbalance.RandomLoadBalance]
    2019-10-11 10:09:10,371 [DubboServerHandler-10.10.10.130:20881-thread-2] INFO  i.s.c.l.EnhancedServiceLoader - load UndoLogParser[jackson] extension by class[io.seata.rm.datasource.undo.parser.JacksonUndoLogParser]
    2019-10-11 10:09:11,531 [rpcDispatch_RMROLE_1_8] INFO  i.s.c.r.n.RmMessageListener - onMessage:xid=10.42.1.30:8091:2024332412,branchId=2024332422,branchType=AT,resourceId=jdbc:mysql://10.10.10.233:3306/seata_demo_order,applicationData=null
    2019-10-11 10:09:11,533 [rpcDispatch_RMROLE_1_8] INFO  i.s.r.AbstractRMHandler - Branch committing: 10.42.1.30:8091:2024332412 2024332422 jdbc:mysql://10.10.10.233:3306/seata_demo_order null
    2019-10-11 10:09:11,534 [rpcDispatch_RMROLE_1_8] INFO  i.s.r.AbstractRMHandler - Branch commit result: PhaseTwo_Committed

### 1.5 合并日志看整体执行顺序 ###

<table> 
 <thead> 
  <tr> 
   <th align="left">服务</th> 
   <th align="left">时间</th> 
   <th align="left">日志</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td align="left">business</td> 
   <td align="left">2019-10-11 10:09:07,960</td> 
   <td align="left">[DubboServerHandler-10.10.10.130:20883-thread-27] INFO i.s.t.a.DefaultGlobalTransaction - Begin new global transaction [10.42.1.30:8091:2024332412]</td> 
  </tr> 
  <tr> 
   <td align="left">business</td> 
   <td align="left">2019-10-11 10:09:07,960</td> 
   <td align="left">开始全局事务，XID = 10.42.1.30:8091:2024332412</td> 
  </tr> 
  <tr> 
   <td align="left">storage</td> 
   <td align="left">2019-10-11 10:09:07,975</td> 
   <td align="left">[DubboServerHandler-10.10.10.130:20882-thread-13] DEBUG c.n.s.d.T.decreaseStorage - ==&gt; Preparing: update t_storage set count = count-500 where commodity_code = ? and count &gt;= ?</td> 
  </tr> 
  <tr> 
   <td align="left">storage</td> 
   <td align="left">2019-10-11 10:09:07,977</td> 
   <td align="left">[DubboServerHandler-10.10.10.130:20882-thread-13] DEBUG c.n.s.d.T.decreaseStorage - ==&gt; Parameters: C201901140001(String), 500(Integer)</td> 
  </tr> 
  <tr> 
   <td align="left">storage</td> 
   <td align="left">2019-10-11 10:09:08,430</td> 
   <td align="left">[DubboServerHandler-10.10.10.130:20882-thread-13] DEBUG c.n.s.d.T.decreaseStorage - &lt;== Updates: 1</td> 
  </tr> 
  <tr> 
   <td align="left">order</td> 
   <td align="left">2019-10-11 10:09:08,523</td> 
   <td align="left">[DubboServerHandler-10.10.10.130:20881-thread-2] INFO i.s.c.l.EnhancedServiceLoader - load ContextCore[null] extension by class[io.seata.core.context.ThreadLocalContextCore]</td> 
  </tr> 
  <tr> 
   <td align="left">account</td> 
   <td align="left">2019-10-11 10:09:08,570</td> 
   <td align="left">[DubboServerHandler-10.10.10.130:20880-thread-2] INFO i.s.c.l.EnhancedServiceLoader - load ContextCore[null] extension by class[io.seata.core.context.ThreadLocalContextCore]</td> 
  </tr> 
  <tr> 
   <td align="left">account</td> 
   <td align="left">2019-10-11 10:09:08,632</td> 
   <td align="left">[DubboServerHandler-10.10.10.130:20880-thread-2] DEBUG c.n.a.d.T.selectOne - ==&gt; Preparing: SELECT id,user_id,amount FROM t_account WHERE user_id = ?</td> 
  </tr> 
  <tr> 
   <td align="left">account</td> 
   <td align="left">2019-10-11 10:09:08,649</td> 
   <td align="left">[DubboServerHandler-10.10.10.130:20880-thread-2] DEBUG c.n.a.d.T.selectOne - ==&gt; Parameters: 1(String)</td> 
  </tr> 
  <tr> 
   <td align="left">account</td> 
   <td align="left">2019-10-11 10:09:08,748</td> 
   <td align="left">[DubboServerHandler-10.10.10.130:20880-thread-2] DEBUG c.n.a.d.T.selectOne - &lt;== Total: 1</td> 
  </tr> 
  <tr> 
   <td align="left">order</td> 
   <td align="left">2019-10-11 10:09:08,795</td> 
   <td align="left">[DubboServerHandler-10.10.10.130:20881-thread-2] INFO c.n.o.s.i.TOrderServiceImpl - <strong>扣款前余额: 4000</strong></td> 
  </tr> 
  <tr> 
   <td align="left">account</td> 
   <td align="left">2019-10-11 10:09:08,807</td> 
   <td align="left">[DubboServerHandler-10.10.10.130:20880-thread-3] DEBUG c.n.a.d.T.decreaseAccount - ==&gt; Preparing: update t_account set amount = amount-3000.0 where user_id = ? and amount &gt; ?</td> 
  </tr> 
  <tr> 
   <td align="left">account</td> 
   <td align="left">2019-10-11 10:09:08,808</td> 
   <td align="left">[DubboServerHandler-10.10.10.130:20880-thread-3] DEBUG c.n.a.d.T.decreaseAccount - ==&gt; Parameters: 1(String), 3000.0(Double)</td> 
  </tr> 
  <tr> 
   <td align="left">account</td> 
   <td align="left">2019-10-11 10:09:09,268</td> 
   <td align="left">[DubboServerHandler-10.10.10.130:20880-thread-3] DEBUG c.n.a.d.T.decreaseAccount - &lt;== Updates: 1</td> 
  </tr> 
  <tr> 
   <td align="left">account</td> 
   <td align="left">2019-10-11 10:09:09,272</td> 
   <td align="left">[DubboServerHandler-10.10.10.130:20880-thread-3] INFO i.s.c.l.EnhancedServiceLoader - load LoadBalance[null] extension by class[io.seata.discovery.loadbalance.RandomLoadBalance]</td> 
  </tr> 
  <tr> 
   <td align="left">account</td> 
   <td align="left">2019-10-11 10:09:09,415</td> 
   <td align="left">[DubboServerHandler-10.10.10.130:20880-thread-3] INFO i.s.c.l.EnhancedServiceLoader - load UndoLogParser[jackson] extension by class[io.seata.rm.datasource.undo.parser.JacksonUndoLogParser]</td> 
  </tr> 
  <tr> 
   <td align="left">account</td> 
   <td align="left">2019-10-11 10:09:09,545</td> 
   <td align="left">[DubboServerHandler-10.10.10.130:20880-thread-4] DEBUG c.n.a.d.T.selectOne - ==&gt; Preparing: SELECT id,user_id,amount FROM t_account WHERE user_id = ?</td> 
  </tr> 
  <tr> 
   <td align="left">account</td> 
   <td align="left">2019-10-11 10:09:09,546</td> 
   <td align="left">[DubboServerHandler-10.10.10.130:20880-thread-4] DEBUG c.n.a.d.T.selectOne - ==&gt; Parameters: 1(String)</td> 
  </tr> 
  <tr> 
   <td align="left">account</td> 
   <td align="left">2019-10-11 10:09:09,550</td> 
   <td align="left">[DubboServerHandler-10.10.10.130:20880-thread-4] DEBUG c.n.a.d.T.selectOne - &lt;== Total: 1</td> 
  </tr> 
  <tr> 
   <td align="left">order</td> 
   <td align="left">2019-10-11 10:09:09,583</td> 
   <td align="left">[DubboServerHandler-10.10.10.130:20881-thread-2] INFO c.n.o.s.i.TOrderServiceImpl - <strong>扣款后余额: 1000</strong></td> 
  </tr> 
  <tr> 
   <td align="left">order</td> 
   <td align="left">2019-10-11 10:09:09,871</td> 
   <td align="left">[DubboServerHandler-10.10.10.130:20881-thread-2] DEBUG c.n.o.d.T.insert - ==&gt; Preparing: INSERT INTO t_order ( id,order_no,user_id,commodity_code,count,amount ) VALUES( ?,?,?,?,?,? )</td> 
  </tr> 
  <tr> 
   <td align="left">order</td> 
   <td align="left">2019-10-11 10:09:09,890</td> 
   <td align="left">[DubboServerHandler-10.10.10.130:20881-thread-2] DEBUG c.n.o.d.T.insert - ==&gt; Parameters: 1314754168291853302(Long), 2d247c43418545b4812a4a8cc9efd718(String), 1(String), C201901140001(String), 500(Integer), 3000.0(Double)</td> 
  </tr> 
  <tr> 
   <td align="left">order</td> 
   <td align="left">2019-10-11 10:09:10,178</td> 
   <td align="left">[DubboServerHandler-10.10.10.130:20881-thread-2] DEBUG c.n.o.d.T.insert - &lt;== Updates: 1</td> 
  </tr> 
  <tr> 
   <td align="left">order</td> 
   <td align="left">2019-10-11 10:09:10,185</td> 
   <td align="left">[DubboServerHandler-10.10.10.130:20881-thread-2] INFO i.s.c.l.EnhancedServiceLoader - load LoadBalance[null] extension by class[io.seata.discovery.loadbalance.RandomLoadBalance]</td> 
  </tr> 
  <tr> 
   <td align="left">order</td> 
   <td align="left">2019-10-11 10:09:10,371</td> 
   <td align="left">[DubboServerHandler-10.10.10.130:20881-thread-2] INFO i.s.c.l.EnhancedServiceLoader - load UndoLogParser[jackson] extension by class[io.seata.rm.datasource.undo.parser.JacksonUndoLogParser]</td> 
  </tr> 
  <tr> 
   <td align="left">business</td> 
   <td align="left">2019-10-11 10:09:10,599</td> 
   <td align="left">[DubboServerHandler-10.10.10.130:20883-thread-27] INFO i.s.t.a.DefaultGlobalTransaction - [10.42.1.30:8091:2024332412] commit status:Committed</td> 
  </tr> 
  <tr> 
   <td align="left">storage</td> 
   <td align="left">2019-10-11 10:09:11,397</td> 
   <td align="left">[rpcDispatch_RMROLE_3_8] INFO i.s.c.r.n.RmMessageListener - onMessage:xid=10.42.1.30:8091:2024332412,branchId=2024332415,branchType=AT,resourceId=jdbc:mysql://10.10.10.233:3306/seata_demo_storage,applicationData=null</td> 
  </tr> 
  <tr> 
   <td align="left"><strong>storage</strong></td> 
   <td align="left">2019-10-11 10:09:11,397</td> 
   <td align="left">[rpcDispatch_RMROLE_3_8] INFO i.s.r.AbstractRMHandler - <strong>Branch committing</strong>: 10.42.1.30:8091:2024332412 2024332415 jdbc:mysql://10.10.10.233:3306/seata_demo_storage null</td> 
  </tr> 
  <tr> 
   <td align="left"><strong>storage</strong></td> 
   <td align="left">2019-10-11 10:09:11,397</td> 
   <td align="left">[rpcDispatch_RMROLE_3_8] INFO i.s.r.AbstractRMHandler - <strong>Branch commit result: PhaseTwo_Committed</strong></td> 
  </tr> 
  <tr> 
   <td align="left">account</td> 
   <td align="left">2019-10-11 10:09:11,459</td> 
   <td align="left">[rpcDispatch_RMROLE_1_8] INFO i.s.c.r.n.RmMessageListener - onMessage:xid=10.42.1.30:8091:2024332412,branchId=2024332418,branchType=AT,resourceId=jdbc:mysql://10.10.10.233:3306/seata_demo_account,applicationData=null</td> 
  </tr> 
  <tr> 
   <td align="left"><strong>account</strong></td> 
   <td align="left">2019-10-11 10:09:11,460</td> 
   <td align="left">[rpcDispatch_RMROLE_1_8] INFO i.s.r.AbstractRMHandler - <strong>Branch committing</strong>: 10.42.1.30:8091:2024332412 2024332418 jdbc:mysql://10.10.10.233:3306/seata_demo_account null</td> 
  </tr> 
  <tr> 
   <td align="left"><strong>account</strong></td> 
   <td align="left">2019-10-11 10:09:11,461</td> 
   <td align="left">[rpcDispatch_RMROLE_1_8] INFO i.s.r.AbstractRMHandler - <strong>Branch commit result: PhaseTwo_Committed</strong></td> 
  </tr> 
  <tr> 
   <td align="left">order</td> 
   <td align="left">2019-10-11 10:09:11,531</td> 
   <td align="left">[rpcDispatch_RMROLE_1_8] INFO i.s.c.r.n.RmMessageListener - onMessage:xid=10.42.1.30:8091:2024332412,branchId=2024332422,branchType=AT,resourceId=jdbc:mysql://10.10.10.233:3306/seata_demo_order,applicationData=null</td> 
  </tr> 
  <tr> 
   <td align="left"><strong>order</strong></td> 
   <td align="left">2019-10-11 10:09:11,533</td> 
   <td align="left">[rpcDispatch_RMROLE_1_8] INFO i.s.r.AbstractRMHandler - <strong>Branch committing</strong>: 10.42.1.30:8091:2024332412 2024332422 jdbc:mysql://10.10.10.233:3306/seata_demo_order null</td> 
  </tr> 
  <tr> 
   <td align="left"><strong>order</strong></td> 
   <td align="left">2019-10-11 10:09:11,534</td> 
   <td align="left">[rpcDispatch_RMROLE_1_8] INFO i.s.r.AbstractRMHandler - <strong>Branch commit result: PhaseTwo_Committed</strong></td> 
  </tr> 
 </tbody> 
</table>

[Seata]: https://blog.csdn.net/isea533/article/details/102497681