同一个事务中调用方法的分步处理 @Transactional

如果在一个方法A中调用了方法B,B方法需要等A方法处理完成之后调用。如果A方法使用了@Transactional事务注解,方法A在执行后进行数据库操作时,因为事务的特性。方法A提交的数据并不会提交到数据库中,而是需要等方法B完成之后才会进行数据库的提交操作。但是方法B需要去数据库查询方法A提交的数据,如果没有提交的话则查不到数据,无法进行下一步操作。
这个问题可以使用事务监听进行处理。
注解:@TransactionalEventListener
这个事务监听其实就是会监听A方法,并在A方法的数据提交到数据库之后在对B方法进行回调。

在这里插入图片描述使用事务监听注入的方法。
@Autowired
ApplicationEventPublisher eventPublisher;


在方法A中合适的位置(可以是方法A更新或插入操作完成之后)调用监听方法。
可以用实体类去传递方法B所需要的参数。

@Getter
@Setter
public class SaveEleSheetEvent extends ApplicationEvent {
    public  Long sheetId;
    public List<Long> sheetIds;

    public SaveEleSheetEvent(Long sheetId) {
      super(sheetId);
      this.sheetId = sheetId;
    }

    public SaveEleSheetEvent(List<Long> sheetIds){
        super(sheetIds);
        this.sheetIds=sheetIds;
    }
}

在写一个监听处理类

@Slf4j
@Component
public class UpdateFlightCheckListen {
    @Autowired
    FlightCheckFeignApi flightCheckFeignApi;
    //在A方法提交之后进行操作
    @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT, classes=SaveEleSheetEvent.class)
    public void updateCheck(SaveEleSheetEvent event) {
        List<Long> sheetIds = event.getSheetIds();
        Long sheetId = event.getSheetId();
        if(ObjectUtils.isNotEmpty(sheetIds)){
        //需要执行的B方法
            flightCheckFeignApi.updateFlightCheckDeptForList(sheetIds);
        }else if(ObjectUtils.isNotEmpty(sheetId)){
            flightCheckFeignApi.updateFlightCheckDept(event.getSheetId());
        }else{
           log.error("xxxxxxx");
        }
    }
}

使用事务监听可以在将事务整体性进行分离开来。


版权声明:本文为on_the_stree原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。