Spring中的异步和事务性事件侦听器

内置的事件发布功能从Spring的早期版本开始存在，对于处理同一应用程序上下文中Spring组件之间的基本通信仍然有用。通常，应用程序可以生成应用程序事件（可以是任意对象）并侦听它们。整个机制非常简单：使用ApplicationPublisher发布事件，使用EventListener处理EventListener 。我发现特别有用的是异步和事务性事件侦听器 。

可以使用事件的示例之一是组件要发信号通知已创建或修改实体（就JPA而言），以便其他感兴趣的组件（侦听器）可以对此事件做出反应并触发一些业务逻辑（例如计划）通知）。通常，此类代码在Spring托管的事务中执行。例如：

@Service
public class TaskService {private static final Logger LOG = LoggerFactory.getLogger(TaskService.class);@Autowiredprivate TaskRepository taskRepository;@Autowiredprivate ApplicationEventPublisher eventPublisher;public Task createTask(String name) {Task task = new Task();task.setName(name);task.setCreated(LocalDateTime.now());LOG.info("Publishing task created event: {}", task);eventPublisher.publishEvent(new TaskCreatedEvent(task));try {return taskRepository.save(task);} finally {LOG.info("Event published. Saving task: {}", task);}}
}

上面的服务在实际保存事件之前发布带有任务实例的事件。在Spring中，可以通过多种方式处理此类事件。为了演示任务实例会发生什么，我将使用JPA EntityManager检查其状态：

如果是暂时的（未设置ID），
如果是由实体经理管理的，或者
如果已分离（不是临时的，不是托管的，但是存在）。

让我们看一下监听器：

@Service
public class TaskCreatedEventListener {private static final Logger LOG = LoggerFactory.getLogger(TaskCreatedEventListener.class);@ResourceEntityManager entityManager;// @Async// @EventListener// @TransactionalEventListenerpublic void handleEvent(TaskCreatedEvent taskCreatedEvent) throws InterruptedException {Task task = taskCreatedEvent.getTask();LOG.info("Is task transient? {}", isTransient(task));LOG.info("Is task managed? {}", isManaged(task));LOG.info("Is task detached? {}", isDetached(task));}private boolean isTransient(Task task) {return task.getId() == null;}private boolean isManaged(Task task) {return entityManager.contains(task);}private boolean isDetached(Task task) {return !isTransient(task)&& !isManaged(task)&& exists(task);}private boolean exists(Task task) {return entityManager.find(Task.class, task.getId()) != null;}}

让我们来看几个例子。如果我们有以下行为：