Wie greife ich innerhalb der asynchronen Aufgabenausführung auf Beans mit Anforderungsbereich zu?

So behalten Sie den Anforderungsbereich bei der asynchronen Aufgabenausführung bei

In Webanwendungen ist es üblich, asynchrone Vorgänge auszuführen, die die Verwendung von Beans erfordern mit Anforderungsbereich. Das Aktivieren des Anforderungsbereichs bei der asynchronen Aufgabenausführung kann durch die Implementierung eines benutzerdefinierten Task-Executors erreicht werden.

Problem:

Sie verfügen über asynchrone Webdienste, die die Verarbeitung in einem AsyncTaskExecutor initiieren. Allerdings müssen Sie innerhalb dieser Verarbeitung auf Klassen zugreifen, die mit @Scope(value = WebApplicationContext.SCOPE_REQUEST, ProxyMode = ScopedProxyMode.TARGET_CLASS) annotiert sind. Sie erhalten jedoch eine Ausnahme, da der Anforderungsbereich im SimpleAsyncTaskExecutor nicht aktiv ist.

Lösung:

Um den Anforderungsbereich in der asynchronen Aufgabenausführung zu aktivieren, werden wir implementieren Führen Sie die folgenden Schritte aus:

1. Erstellen Sie einen benutzerdefinierten TaskExecutor:

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

2. Implementieren Sie einen kontextsensitiven TaskExecutor 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>

3. Konfigurieren Sie den benutzerdefinierten TaskExecutor:

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

Erklärung :

Der ContextAwarePoolExecutor fängt übermittelte Aufgaben ab und verpackt sie in ContextAwareCallable-Instanzen. Diese Callables legen den aktuellen Anforderungskontext vor der Ausführung der eigentlichen Aufgabe fest und setzen ihn anschließend zurück. Dadurch wird sichergestellt, dass die Beans im Anforderungsbereich während der asynchronen Ausführung zugänglich sind.

Hinweis:

• Diese Lösung funktioniert sowohl für sitzungsbezogene als auch für anforderungsbezogene Beans Beans, jedoch nicht für Sicherheitskontexte.
• Eine ausführbare Implementierung kann erstellt und anstelle der aufrufbaren Implementierung für die Methodeexecute() verwendet werden.

Das obige ist der detaillierte Inhalt vonWie greife ich innerhalb der asynchronen Aufgabenausführung auf Beans mit Anforderungsbereich zu?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!