7.10.2. 事务观察器

在交易开始阶段之前或之后,交易处理接收事件通知。事务处理在有状态对象模型中很重要,因为状态通常保留比单个原子交易更长的时间。

交易有五种类型:

  • IN_PROGRESS :默认情况下,会立即调用。
  • AFTER_SUCCESS :观察器在事务完成阶段后会被调用,但前提是事务成功完成。
  • AFTER_FAILURE :观察者在事务完成阶段后会被调用,但前提是事务无法成功完成。
  • AFTER_COMPLETION :观察器在事务完成后被调用。
  • BEFORE_COMPLETION :在事务完成阶段前调用观察者。

以下观察方法刷新应用程序上下文中缓存的查询结果集,但只有在更新 Category 树的操作成功时才会刷新:

public void refreshCategoryTree(@Observes(during = AFTER_SUCCESS) CategoryUpdateEvent event) { ... }

假设您缓存了 Jakarta Persistence 查询结果,请在应用程序范围中设置,如下例所示:

import javax.ejb.Singleton;
import javax.enterprise.inject.Produces;

@ApplicationScoped @Singleton

public class Catalog {
   @PersistenceContext EntityManager em;
   List<Product> products;
   @Produces @Catalog
   List<Product> getCatalog() {
      if (products==null) {
         products = em.createQuery("select p from Product p where p.deleted = false")
            .getResultList();
      }
      return products;
   }
}

有时 会创建 或删除产品。发生这种情况时,您需要刷新 产品 目录。但是,您必须等待事务成功完成,然后才能进行此刷新。

以下是创建和删除 Products 触发事件的 bean 示例:

import javax.enterprise.event.Event;

@Stateless

public class ProductManager {
   @PersistenceContext EntityManager em;
   @Inject @Any Event<Product> productEvent;
   public void delete(Product product) {
      em.delete(product);
      productEvent.select(new AnnotationLiteral<Deleted>(){}).fire(product);
   }

   public void persist(Product product) {
      em.persist(product);
      productEvent.select(new AnnotationLiteral<Created>(){}).fire(product);
   }
   ...
}

Catalog 现在可在成功完成事务后观察事件:

import javax.ejb.Singleton;

@ApplicationScoped @Singleton
public class Catalog {
   ...
   void addProduct(@Observes(during = AFTER_SUCCESS) @Created Product product) {
      products.add(product);
   }

   void removeProduct(@Observes(during = AFTER_SUCCESS) @Deleted Product product) {
      products.remove(product);
   }

}