@Asynchronous bean 中的 Java 注入

Question

我有 2 个 bean 使用注入来“传递”从 HttpRequest 提取的 UserData 信息。如果我从 WorkerBean 中删除 @Asynchronous 那么它的所有工作和 WorkerBean 可以访问被注入的 UserInfo。 但是，如果我在 WorkerBean 上使用@Asynchronous，则注入将停止工作。

如果必须是异步的，手动创建/传递 UserInfo 到 WorkerBean 的最佳方法是什么？

// resource class
@Stateless
class MainRs {
    @Context
    protected HttpServletRequest request;
    @Inject
    protected UserData userData;
    @EJB
    WorkerBean job;

    @Path("/batch/job1")
    public function startJob() {
      // call on worker bean
      job.execute();
    }
}

// user data extracted from HttpRequest
@RequestScoped
@Default
class UserData {
  private HttpServletRequest request;
  private String userId;

  @Inject
  public UserData(HttpServletRequest request) {
    super();
    this.request = request;
    userId = request.getHeader("userId");
  }
  public int getUserId() {
    return userId;
  }
}

@Stateless
@Asynchronous
class WorkerBean {
    private UserData userData;

    // inject userData rom caller bean
    @Inject
    public WorkerBean(UserData userData) {
      super();
      this.userData = userData;
    }

    public function execute() {
      String userId = userData.getUserId();
      // do something
    }
}

Answer 1

UserData 是 RequestScoped 并绑定到 http 请求上下文，这意味着它依赖于当前请求，因此依赖于当前执行线程。 @Asynchronous 将主要通过使用服务器的线程池来实现。此外，CDI 不会将上下文传播到另一个线程，至少对于会话和请求上下文。在这种情况下，它会创建一个新的 request-context，一个 ejb-invocation 请求上下文，它与 http-request-context 无关。因此，在另一个线程中，您丢失了所有 http 会话和 http 请求上下文数据。按照目前的 CDI 规范，没有办法绕过它。

我的工作涉及完全放弃@Asynchronous 注释，并使用ManagedExecutionService，它基于某些标准，对于我需要的一些数据，通过ThreadLocal 将一些上下文数据传播到线程。因此：

@Stateless
public class AsynchronouseService {

   @Resource
   private ManagedExecutorService managedExecutorService;

   @EJB
   private AsynchronouseServiceDelegate asynchronousServiceDelegate;

   @Inject
   private ManagedContextData managedContextData;


   public void executeAsync(Runnable runnable) {

   managedExecutorService.submit(() ->  asynchronousServiceDelegate.execute(runnable, managedContextData));

   }

}

@Stateless
public class AsynchronouseServiceDelegate {

   @Inject
   private ManagedContextDataProvider managedContextDataProvider;

   public void execute(Runnable runnable, ManagedContextData managedContextData){

    try {

       managedContextDataProvider.setExecutionContextData(managedContextData)
    runnable.run();

    } finally {
       managedContextDataProvider.clearExecutionContextData();
    }

   }
}

```

@ApplicationScoped
public class ManagedContextDataProvider {

   private static final ThreadLocal<ManagedContextData> managedContextDataContext;

   @Inject
   private Instance<HttpSession> httpSession;

   @Produces
   @Depedent
   public ManagedContextData getManagedContextData() {
     firstNonNull(managedContextDataContext.get(), httpSession.get().getAttribute(context_data_key));
   }

  public void setExecutionContextData(ManagedContextData managedContextData) {
    managedContextDataContext.set(managedContextData);
  }

  public void clearExecutionContextData() {
    managedContextDataContext.remove();
  }

}

关于 managedexecutorservice 中的线程局部变量的一些注意事项。线程是 重用，您必须确定您传播的上下文是 删除，否则在具有不同用户数据的不同会话中，您 会得到混淆的数据，而且这将是一个难以调试的场景。

如果您可以避免这种情况，并且只需将UserData 作为方法参数传递，那就更好了。