如何为同一个CompletionStage同时配置Akka Dispatcher与HttpContext？

我来帮你搞定这个问题～其实核心在于Play的HTTP上下文是通过HttpExecutionContext来管理的，它可以轻松和自定义的Akka Dispatcher结合起来，步骤很清晰：

1. 先配置好你的自定义Dispatcher #

首先确保你已经在application.conf里定义了自己的Dispatcher，比如：

my-custom-dispatcher {
  type = Dispatcher
  executor = "thread-pool-executor"
  thread-pool-executor {
    core-pool-size-factor = 2.0
    max-pool-size-factor = 4.0
    task-queue-size = 100
  }
  throughput = 100
}

2. 注入必要的依赖 #

在你的Controller或者需要使用的类里，注入HttpExecutionContext和ActorSystem——前者负责管理HTTP上下文，后者用来获取自定义Dispatcher：

import play.libs.concurrent.HttpExecutionContext;
import akka.actor.ActorSystem;
import javax.inject.Inject;
import play.mvc.Controller;
import play.mvc.Result;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.Executor;

public class MyTaskController extends Controller {

    private final HttpExecutionContext httpExecutionContext;
    private final ActorSystem actorSystem;

    @Inject
    public MyTaskController(HttpExecutionContext httpExecutionContext, ActorSystem actorSystem) {
        this.httpExecutionContext = httpExecutionContext;
        this.actorSystem = actorSystem;
    }

3. 包装自定义Dispatcher和HTTP上下文 #

接下来，我们要把自定义Dispatcher和当前请求的HTTP上下文结合成一个Executor，这样两者就能同时生效：

// 从ActorSystem中获取我们定义的自定义Dispatcher
Executor customDispatcher = actorSystem.dispatchers().lookup("my-custom-dispatcher");
// 用HttpExecutionContext包装这个Dispatcher，让它带上当前的HTTP上下文
Executor contextAwareExecutor = httpExecutionContext.withExecutor(customDispatcher);

4. 传递给CompletionStage使用 #

最后把这个包装好的Executor传给CompletableFuture.supplyAsync就可以了：

public CompletableFuture<Result> runTask() {
    return CompletableFuture.supplyAsync(() -> {
        // 这里的代码会在自定义Dispatcher的线程池中执行，同时能访问到当前的HTTP上下文
        doSomethingWithContext();
        return ok("Task completed with custom dispatcher and HTTP context!");
    }, contextAwareExecutor);
}

private void doSomethingWithContext() {
    // 比如在这里获取当前请求的信息
    String remoteAddress = request().remoteAddress();
    System.out.println("Processing request from: " + remoteAddress);
}

原理说明 #

HttpExecutionContext.withExecutor()方法的作用就是把普通的Executor包装成一个“上下文感知”的Executor——当任务在这个Executor上执行时，Play会自动把当前的HTTP上下文绑定到线程上，这样你在任务里就能像在普通请求处理方法中一样访问request()、session()这些上下文相关的内容，同时任务会在你指定的自定义Dispatcher线程池中运行，完美满足你的需求。

注意：如果是在非Controller的类里使用，确保你拿到的HttpExecutionContext是当前请求的上下文，推荐通过依赖注入传递，而不是直接用HttpExecutionContext.current()（虽然也能用，但依赖注入更符合Play的设计理念）。

内容的提问来源于stack exchange，提问作者AHH