內置的事件發布功能從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;}}

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

• @EventListener

這是同步調用的標準偵聽器。 該方法將在事務完成之前執行，因此對象將處于過渡狀態。

• @Async @EventListener

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

• @TransactionalEventListener

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

• @Async @TransactionalEventListener

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

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

總結

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

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。