Spring @Transactional 和 @Async

Posted 2023-02-26

【中文标题】Spring @Transactional 和 @Async

【英文标题】：Spring @Transactional and @Async

【发布时间】：2019-11-10 05:02:26

【问题描述】：

在我的应用程序中，在创建任务时，我需要对 Google 进行 API 调用以创建 Google 日历事件。

我决定在单独的线程上进行 API 调用，这样我们的客户端就不必等待更长时间的响应。

@Override
@Transactional( rollbackFor = DataException.class )
public TaskResponseBean createTask( TaskCreationBean taskCreationBean, UserAccessDetails accessDetails )
        throws DataException

    String googleEventId = "";
    try
    
        TaskServiceUtil.validateInputBeforeCreatingTask(taskCreationBean, accessDetails);

        MatterModel matterModel = matterService.giveMatterIfExistElseThrowException(taskCreationBean.getMatterId(),
                owner);

        //A task is unique for a user for a matter
        taskCommons.throwExceptionIfTaskNameAlreadyExistForTheMatter(taskCreationBean.getTaskName().trim(), owner,
                matterModel);

        TaskModel savedTask = taskModelRepository.save(savableTask);

        if( !NullEmptyUtils.isNull(savableTask.getDueDate()) )
        
            final CreateEventBean createEventBean = getCreateEventBean(getEventParticipants(savedTask), savedTask);
            calendarTrigerer.triggerEventCreation(createEventBean, savedTask.getId(), null,
                    GoogleCalendarTrigerer.EVENT_TYPE_CREATE);
        
        // Keep track of the list of assignees of a task
        if( taskCreationBean.getHaveAssignee() || taskCreationBean.getIsSelfAssigned() )
        
            saveTaskAssignedHistory(savedTask, owner, savedTask.getAssignedTo(), false);
        

    
    catch( DataException e )
    
        LOGGER.error(GeneralConstants.ERROR, e);
        if( !NullEmptyUtils.isNullOrEmpty(googleEventId) )
        
            LOGGER.info("Deleting google event id ", googleEventId);
            googleCalendarService.deleteGoogleCalendarEvent(googleEventId);
        
        throw e;
    
    catch( Exception e )
    
        LOGGER.error(GeneralConstants.ERROR, e);
        if( !NullEmptyUtils.isNullOrEmpty(googleEventId) )
        
            LOGGER.info("Deleting google event id ", googleEventId);
            googleCalendarService.deleteGoogleCalendarEvent(googleEventId);
        
        throw new DataException(GeneralConstants.EXCEPTION, GeneralConstants.SOMETHING_WENT_WRONG,
                HttpStatus.INTERNAL_SERVER_ERROR);
    


@Async
void triggerEventCreation( CreateEventBean createEventBean, Long taskId, String eventId, String eventType )
        throws DataException

    try
    

        TaskModel taskModel = null;

        if( !NullEmptyUtils.isNullOrEmpty(taskId) )
        
            int retryCount = 0;
            Optional<TaskModel> taskModelOptional = taskModelRepository.findByIdAndIsActiveTrue(taskId);
            while( !taskModelOptional.isPresent() )
            
                System.out.println("NOT PRESENT***********************************************");
                taskModelOptional = taskModelRepository.findByIdAndIsActiveTrue(taskId);
                if( retryCount++ > 50 )
                
                    throw new DataException(GeneralConstants.EXCEPTION, "Transaction is unable to commit",
                            HttpStatus.INTERNAL_SERVER_ERROR);
                
            

            taskModel = taskModelOptional.get();
        

        switch ( eventType )
        
            case EVENT_TYPE_CREATE :

                eventId = googleCalendarService.addGoogleCalendarEvent(createEventBean);
                System.out.println("ADDED EVENT***********************************************" + eventId);

                System.out.println("PRESENT***********************************************");
                taskModel.setGoogleEventId(eventId);
                taskModelRepository.save(taskModel);
                break;
            case EVENT_TYPE_DELETE :
                NullEmptyUtils.throwExceptionIfInputIsNullOrEmpty(eventId);
                googleCalendarService.deleteGoogleCalendarEvent(eventId);
                taskModel.setGoogleEventId(null);
                taskModel.setIsActive(false);
                taskModelRepository.save(taskModel);
                break;
            case EVENT_TYPE_UPDATE :
                NullEmptyUtils.throwExceptionIfInputIsNullOrEmpty(eventId);
                NullEmptyUtils.throwExceptionIfInputIsNullOrEmpty(createEventBean);

                taskModel.setGoogleEventId(
                        googleCalendarService.updateGoogleCalendarEvent(eventId, createEventBean));
                taskModelRepository.save(taskModel);
                break;
            default :
                throw new DataException(GeneralConstants.EXCEPTION, "Invalid eventType", HttpStatus.BAD_REQUEST);
        

    
    catch( DataException e )
    
        log.error(GeneralConstants.ERROR, e);
        throw e;
    
    catch( Exception e )
    
        log.error(GeneralConstants.ERROR, e);
        throw new DataException(GeneralConstants.EXCEPTION,
                "Something went wrong while trigering create event action", HttpStatus.INTERNAL_SERVER_ERROR);
    

我在创建活动时如何解决（确保它有效） 在单独的线程中，我将迭代并等待任务被创建，然后使用事件 ID 更新它并保存它。

但是，出现了一个新问题，更新任务时，我已经在数据库中有它的详细信息。在更新方法中，我将更新值设置为TaskModel 并执行taskModelRepo.save() 并在单独的线程中调用谷歌日历更新API，在成功调用API 后，我必须更新相应的TaskModel 并保存它。

这里的问题是，有时当我在 google API 调用成功后通过 id 获取任务时，我会得到带有未更新值的 TaskModel，因为之前的事务尚未提交。

那么如何保证新线程只在调用它的方法的事务提交后才运行呢？

【问题讨论】：

您遇到了烦人的竞争状况。我目前在同时使用@Transactional 和@Async 时遇到同样的问题。我通过使用 Camunda 引擎解决了这个问题，但我认为这对你的问题来说太重了。也许您可以使用某种事件总线并在异步方法中等待“事务完成”信号？

有没有办法通过spring事件发布者发布事务提交事件？

【参考方案1】：

您可以使用 Google Guava Event 总线来解决这个问题。这是一个发布-订阅模型，其中生产者负责发出事件，然后这些事件被传递到事件总线并发送到订阅该事件的所有侦听器。

侦听器订阅一个事件，并在该事件从生产者发布时触发，您可以让侦听器方法运行同步或异步，具体取决于您使用的事件总线。

这是链接：https://github.com/google/guava/wiki/EventBusExplained

【讨论】：

但是，我仍然看不到任何将事务提交作为事件发布的方法

如果您想将事务提交作为事件发布，并且希望稍后由某个消费者处理该事件。我认为您应该设置一个 apache Kafka 流。 kafka.apache.org

如果您正在寻找有关春季活动发布者的解决方案，这将对您有所帮助 - blog.pragmatists.com/…