內(nèi)置的事件發(fā)布功能從Spring的早期版本開始存在，對于處理同一應(yīng)用程序上下文中Spring組件之間的基本通信仍然有用。 通常，應(yīng)用程序可以生成應(yīng)用程序事件（可以是任意對象）并偵聽它們。 整個機制非常簡單：使用ApplicationPublisher發(fā)布事件，使用EventListener處理EventListener 。 我發(fā)現(xiàn)特別有用的是異步和事務(wù)性事件偵聽器 。

可以使用事件的示例之一是組件要發(fā)信號通知已創(chuàng)建或修改實體 （就JPA而言），以便其他感興趣的組件（偵聽器）可以對此事件做出反應(yīng)并觸發(fā)一些業(yè)務(wù)邏輯（例如計劃）通知）。 通常，此類代碼在Spring托管的事務(wù)中執(zhí)行。 例如：

@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);}} }

上面的服務(wù)在實際保存事件之前發(fā)布帶有任務(wù)實例的事件。 在Spring中，可以通過多種方式處理此類事件。 為了演示任務(wù)實例會發(fā)生什么，我將使用JPA EntityManager檢查其狀態(tài)：

• 如果是暫時的（未設(shè)置ID），
• 如果是由實體經(jīng)理管理的，或者
• 如果已分離（不是臨時的，不是托管的，但是存在）。

讓我們看一下監(jiān)聽器：

@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;}}

讓我們來看幾個例子。 如果我們有以下行為：

• @EventListener

這是同步調(diào)用的標(biāo)準(zhǔn)偵聽器。 該方法將在事務(wù)完成之前執(zhí)行，因此對象將處于過渡狀態(tài)。

• @Async @EventListener

將@Async添加到@EventListener將使該方法異步執(zhí)行，因此在不同線程中運行（請不要忘記在應(yīng)用程序中啟用異步方法執(zhí)行）。 在我們的場景中，對象很可能處于過渡狀態(tài)，但在現(xiàn)實生活中，由于發(fā)布者已經(jīng)可以保存任務(wù)，因此也可以將其拆離 。 因此，實際上，行為不是確定性的。

• @TransactionalEventListener

當(dāng)將偵聽器標(biāo)記為事務(wù)性事件偵聽器時，Spring僅在事務(wù)及其后提交階段（可以通過注釋對其進行調(diào)整）的邊界中調(diào)用發(fā)布者時才將事件發(fā)布給偵聽器。 在這種情況下，對象將處于托管狀態(tài)。

• @Async @TransactionalEventListener

這是最有趣的情況。 如上所述，Spring僅在事務(wù)邊界及其提交后階段中調(diào)用發(fā)布者時才將事件發(fā)布給偵聽器，但是事務(wù)完成了，因此對象處于分離狀態(tài)–正在運行另一個事務(wù)。

翻譯自: https://www.javacodegeeks.com/2017/10/asynchrouns-transactional-event-listeners-spring.html

總結(jié)

以上是生活随笔為你收集整理的Spring中的异步和事务性事件侦听器的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。