访问以下线程中的作用域代理 bean

Question

我有一个在 tomcat 中运行的 Web 应用程序，其中我使用 ThreadPool (Java 5 ExecutorService) 并行运行 IO 密集型操作以提高性能。我希望每个池线程中使用的一些 bean 位于请求范围内，但 ThreadPool 中的线程无法访问 spring 上下文并获得代理失败。关于如何使 Spring 上下文可供 ThreadPool 中的线程使用以解决代理失败的任何想法吗？

我猜测必须有一种方法可以为每个任务使用 spring 注册/取消注册 ThreadPool 中的每个线程，但还没有找到如何做到这一点的运气。

谢谢！

Answer 1

我正在使用以下超类来执行需要访问请求范围的任务。基本上你可以扩展它并在 onRun() 方法中实现你的逻辑。

import org.springframework.web.context.request.RequestAttributes;
import org.springframework.web.context.request.RequestContextHolder;

/**
 * @author Eugene Kuleshov
 */
public abstract class RequestAwareRunnable implements Runnable {
  private final RequestAttributes requestAttributes;
  private Thread thread;

  public RequestAwareRunnable() {
    this.requestAttributes = RequestContextHolder.getRequestAttributes();
    this.thread = Thread.currentThread();
  }

  public void run() {
    try {
      RequestContextHolder.setRequestAttributes(requestAttributes);
      onRun();
    } finally {
      if (Thread.currentThread() != thread) {
        RequestContextHolder.resetRequestAttributes();
      }
      thread = null;
    }
  }

  protected abstract void onRun();
}

Answer 2

我还希望我有 1000 票来支持当前接受的答案。一段时间以来，我一直对如何做到这一点感到困惑。基于此，如果您想在 Spring 3.0 中使用一些新的 @Async 内容，这里是我使用 Callable 接口的解决方案。

public abstract class RequestContextAwareCallable<V> implements Callable<V> {

    private final RequestAttributes requestAttributes;
    private Thread thread;

    public RequestContextAwareCallable() {
        this.requestAttributes = RequestContextHolder.getRequestAttributes();
        this.thread = Thread.currentThread();
    }

    public V call() throws Exception {
        try {
            RequestContextHolder.setRequestAttributes(requestAttributes);
            return onCall();
        } finally {
            if (Thread.currentThread() != thread) {
                RequestContextHolder.resetRequestAttributes();
            }
            thread = null;
        }
    }

    public abstract V onCall() throws Exception;
}

Answer 3

你能反过来试试吗？使用存储在请求范围中的数据容器并将其提供给线程池（也许将其放入队列中，以便线程池可以一次获取一个数据容器，对其进行处理，将其标记为“完成”并继续与下一个）。

Answer 4

Spring 有一个 ThreadPoolTask​​Executor可用于从 Spring 管理线程池的类。然而，看起来您必须做一些工作才能使 Spring 上下文可供每个线程使用。

即使您以这种方式连接，我也不确定它是否会起作用。 Spring 在本地线程中使用令牌来定位请求（或会话）作用域中的对象，因此如果您尝试从不同的线程访问请求作用域 bean，则该令牌可能不存在。