今天做测试，发现在public方法上添加注解@Transactional事物不生效，网上查了很多的事物不生效的案例。我都符合标准的呀。为什么事物不生效呢？仔细检查之后才发现自己的错误。异常不能被try catch 掉。要抛到事务方法上去。我try catch掉异常了。当然事务不生效了。
案例：这样事务是不回滚的
@Transactional(rollbackFor = Exception.class) public RocketMQLocalTransactionState executeLocalTransaction(Message message, Object o) { try { //解析message，转成AccountChangeEvent String messageString = new String((byte[]) message.getPayload()); JSONObject jsonObject = JSONObject.parseObject(messageString); String accountChangeString = jsonObject.getString("accountChange"); //将accountChange（json）转成AccountChangeEvent AccountChangeEvent accountChangeEvent = JSONObject.parseObject(accountChangeString, AccountChangeEvent.class); //执行本地事务，扣减金额 accountInfoService.doUpdateAccountBalance(accountChangeEvent); //模拟异常，这个异常被catch住了，事务不会生效，数据不会回滚 if(accountChangeEvent.getAmount() == 2) { //int i = 1 / 0; throw new RuntimeException("人工异常"); } //当返回RocketMQLocalTransactionState.COMMIT，自动向mq发送commit消息，mq将消息的状态改为可消费 return RocketMQLocalTransactionState.COMMIT; } catch (Exception e) { log.error("执行本地事物异常:{}", e); return RocketMQLocalTransactionState.ROLLBACK; } }
案例：这样，事务才会回滚
@Override @Transactional public void doUpdateAccountBalance(AccountChangeEvent accountChangeEvent) { //幂等判断 if(accountInfoDao.isExistTx(accountChangeEvent.getTxNo())>0){ return ; } //扣减金额 accountInfoDao.updateAccountBalance(accountChangeEvent.getAccountNo(),accountChangeEvent.getAmount() * -1); //添加事务日志 accountInfoDao.addTx(accountChangeEvent.getTxNo());
//事务生效，数据回滚 if(accountChangeEvent.getAmount() == 3){ throw new RuntimeException("人为制造异常"); } }
参考：