非同期タスク実行でリクエストスコープを有効にする方法は?

非同期タスク実行でのリクエスト スコープの有効化

問題:

非同期 Web サービスは次のことを行う必要があります。非同期処理内のリクエスト スコープの Bean、特に @Scope(value = WebApplicationContext.SCOPE_REQUEST) のアノテーションが付けられた Bean にアクセスします。ただし、SimpleAsyncTaskExecutor はスレッド バインドされたリクエスト属性を保持しないため、例外が発生します。

解決策:

非同期タスク実行でリクエスト スコープを有効にするには、カスタム TaskPoolExecutor が作成されます。バックグラウンド スレッドのリクエスト コンテキストを保存およびクリアする特別な Cal​​lable も伴います。

実装:

カスタム エグゼキュータ:

<code class="java">public class ContextAwarePoolExecutor extends ThreadPoolTaskExecutor {
    @Override
    public <T> Future<T> submit(Callable<T> task) {
        return super.submit(new ContextAwareCallable(task, RequestContextHolder.currentRequestAttributes()));
    }
}</code>

コンテキスト認識呼び出し可能:

<code class="java">public class ContextAwareCallable<T> implements Callable<T> {
    private Callable<T> task;
    private RequestAttributes context;

    public ContextAwareCallable(Callable<T> task, RequestAttributes context) {
        this.task = task;
        this.context = context;
    }

    @Override
    public T call() throws Exception {
        if (context != null) {
            RequestContextHolder.setRequestAttributes(context);
        }

        try {
            return task.call();
        } finally {
            RequestContextHolder.resetRequestAttributes();
        }
    }
}</code>

構成オーバーライド:

<code class="java">@Configuration
public class ExecutorConfig extends AsyncConfigurerSupport {
    @Override
    @Bean
    public Executor getAsyncExecutor() {
        return new ContextAwarePoolExecutor();
    }
}</code>

使用法:

<code class="java">taskExecutor.execute(new ContextAwareCallable(new Runnable() {
    @Override
    public void run() {
        asyncRequest(request);
    }
}), RequestContextHolder.currentRequestAttributes());</code>

注:

• このメソッドは、セキュリティ コンテキストではなく、リクエスト スコープとセッション スコープのみをサポートします。
• と互換性があります。 Callable インターフェイスと Runnable インターフェイスの両方。

以上が非同期タスク実行でリクエストスコープを有効にする方法は?の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。