Wie kann ich den Anforderungsbereich in asynchronen Aufgaben beibehalten?

Anfragebereich in asynchronen Aufgaben beibehalten

In Webanwendungen ist es üblich, asynchrone Aufgaben nach dem Empfang einer Anfrage auszuführen. Allerdings kann es eine Herausforderung sein, sicherzustellen, dass diese Aufgaben Zugriff auf anforderungsspezifische Objekte haben, beispielsweise solche, die mit @Scope(value = WebApplicationContext.SCOPE_REQUEST) annotiert sind.

Bei der nicht blockierenden Verarbeitung von Anforderungen wird die Der standardmäßige SimpleAsyncTaskExecutor hat keinen Zugriff auf den Bereich des Anforderungsthreads, was zu Ausnahmen wie „Bereich ‚Anfrage‘ ist für den aktuellen Thread nicht aktiv“ führt.

Um dieses Problem zu beheben, kann ein benutzerdefinierter ContextAwarePoolExecutor erstellt werden. Dieser Executor speichert Anforderungskontextinformationen mit Aufgaben und nutzt ein ContextAwareCallable, um den erforderlichen Kontext für den Hintergrundthread festzulegen und zu löschen.

Benutzerdefinierte Executor-Implementierung:

<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>

Kontextbewusst aufrufbar:

<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>

Konfigurationsüberschreibung:

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

Durch die Verwendung dieses benutzerdefinierten Executors können asynchrone Aufgaben nahtlos auf Anforderungsanfragen zugreifen. Objekte mit Gültigkeitsbereich, wodurch die Einschränkungen des Standard-SimpleAsyncTaskExecutors überwunden werden.

Das obige ist der detaillierte Inhalt vonWie kann ich den Anforderungsbereich in asynchronen Aufgaben beibehalten?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!