Umgang mit asynchroner Ausführung mit Transaktionen im Frühjahr: Eine häufige Gefahr und wie man sie löst

In modernen Spring-Anwendungen ist es üblich, asynchrone Ausführung mit Transaktionsverhalten zu kombinieren. Das Annotieren einer Methode mit @Async und @Transactional(propagation = Propagation.REQUIRES_NEW) kann jedoch zu unerwartetem Verhalten führen, da Spring asynchrone Aufgaben und Transaktionen verwaltet.

In diesem Artikel werden wir das Problem im Detail untersuchen und eine Lösung demonstrieren, um sowohl die asynchrone Ausführung als auch das Transaktionsmanagement korrekt zu handhaben.

Das Problem: @Async und @Transactional(propagation = Propagation.REQUIRES_NEW)

Bedenken Sie den folgenden Codeausschnitt:

@Async
@Transactional(propagation = Propagation.REQUIRES_NEW)
public void saveSomething() {
    // save-point one
    // save-point two
}

Auf den ersten Blick könnte es so aussehen, als ob alles wie erwartet funktioniert. Allerdings gibt es bei dieser Konfiguration einige wesentliche Probleme, die zu unbeabsichtigtem Verhalten führen können.

Was passiert hinter den Kulissen?

• @Async-Anmerkung:

Die Annotation @Async weist Spring an, die Methode asynchron in einem separaten Thread auszuführen. Dies bedeutet, dass die Methode nicht im ursprünglichen Thread ausgeführt wird, der sie aufgerufen hat, sondern in einen anderen Thread in einem Thread-Pool verlagert wird.
Spring verwendet Proxys, um asynchrone Methoden zu verwalten. Wenn Sie eine mit @Async annotierte Methode aufrufen, delegiert Spring die Ausführung an einen internen Executor, der die Methode in einem anderen Thread ausführt.

• @Transactional(propagation = Propagation.REQUIRES_NEW) Anmerkung:

Die Annotation @Transactional(propagation = Propagation.REQUIRES_NEW) stellt sicher, dass eine neue Transaktion für die Methode gestartet wird, unabhängig von einer vorhandenen Transaktion. Es unterbricht jede aktive Transaktion im aufrufenden Thread und beginnt eine neue Transaktion für die Methode.

Die Transaktionsverwaltung in Spring ist im Allgemeinen threadgebunden, was bedeutet, dass der Transaktionskontext an den aktuellen Thread gebunden ist.

Der Konflikt

Das Problem entsteht, weil @Async die Methode in einem anderen Thread ausführt und das Transaktionsmanagement von Spring darauf angewiesen ist, dass der Thread die Transaktion bindet. Wenn die Methode asynchron ausgeführt wird, wird der Transaktionskontext vom aufrufenden Thread nicht an den neuen Thread weitergegeben, was zu den folgenden Problemen führt:

• Die Annotation @Transactional erstellt keine neue Transaktion im asynchronen Thread und jegliches Transaktionsverhalten (wie Rollbacks, Commits usw.) wird nicht korrekt gehandhabt.
• Die Weitergabeeinstellung REQUIRES_NEW wird nicht angewendet, da die asynchrone Methode außerhalb des ursprünglichen Transaktionskontexts ausgeführt wird.

Die Lösung: Entkopplung von asynchroner Ausführung und Transaktionen

Um dieses Problem zu lösen, können Sie die asynchrone Ausführung von der Transaktionslogik entkoppeln, indem Sie die Transaktion in einer separaten Dienstmethode abwickeln. So können Sie es machen:

• Schritt 1: Erstellen Sie einen neuen synchronen Dienst für Transaktionslogik
  Erstellen Sie einen neuen Dienst, der die Transaktionslogik verarbeitet. Diese Methode wird synchron ausgeführt (ohne @Async), um sicherzustellen, dass die Transaktionsverwaltung wie erwartet funktioniert.

• Schritt 2: Rufen Sie die synchrone Methode asynchron auf
  Anschließend können Sie die synchrone Transaktionsmethode asynchron mit @Async aufrufen. Dadurch wird sichergestellt, dass die Transaktionslogik im Hauptthread korrekt verarbeitet wird und das asynchrone Verhalten weiterhin erhalten bleibt.

So sieht der überarbeitete Code aus:

@Async
@Transactional(propagation = Propagation.REQUIRES_NEW)
public void saveSomething() {
    // save-point one
    // save-point two
}

Wie funktioniert es?

In der überarbeiteten Lösung wird die asynchrone Ausführung durch Annotieren der Methode saveSomethingAsync() mit @Async erreicht. Das bedeutet, dass, wenn saveSomethingAsync() aufgerufen wird, es in einem separaten Thread ausgeführt wird, der vom asynchronen Task-Executor von Spring verwaltet wird. Wenn Sie dies in einem anderen Thread ausführen, kann der Hauptthread seine Ausführung fortsetzen, ohne auf den Abschluss von saveSomethingAsync() warten zu müssen. Dieser Ansatz ist für Szenarien von Vorteil, in denen Sie lang laufende Aufgaben entlasten, die Reaktionsfähigkeit verbessern oder unabhängige Vorgänge gleichzeitig ausführen möchten.

Für Transaktionsverhalten ist die Methode saveSomething() in TransactionalService mit @Transactional(propagation = Propagation.REQUIRES_NEW) annotiert. Dadurch wird sichergestellt, dass jeder Aufruf von saveSomething() eine neue Transaktion erstellt, unabhängig von einer vorhandenen Transaktion in der aufrufenden Methode. Die Weitergabe von REQUIRES_NEW startet eine neue Transaktion und unterbricht alle vorhandenen, sodass saveSomething() in einem isolierten Transaktionskontext ausgeführt werden kann. Das bedeutet, dass saveSomething() auch dann innerhalb seiner eigenen separaten Transaktion funktioniert, wenn die ursprünglich aufrufende Methode eine Transaktion hat, wodurch kontrollierte Commits und Rollbacks nur für diesen Vorgang ermöglicht werden.

Durch die Entkopplung der asynchronen Ausführung von der Transaktionslogik stellen wir sicher, dass das Transaktionsmanagement wie erwartet funktioniert. In diesem Setup wird der Transaktionskontext innerhalb der Methode saveSomething() weiterhin korrekt verarbeitet, während die Methode saveSomethingAsync() weiterhin in einem separaten Thread ausgeführt wird. Diese Trennung der Belange ermöglicht sowohl die Vorteile der asynchronen Verarbeitung als auch der zuverlässigen Transaktionsverwaltung und ermöglicht so unabhängige und sichere Datenvorgänge auch bei gleichzeitiger Verarbeitung.

Wann sollte dieser Ansatz verwendet werden?

• Wenn die Transaktionsisolation von entscheidender Bedeutung ist: Wenn Sie sicherstellen müssen, dass bestimmte Vorgänge in einer separaten Transaktion ausgeführt werden (d. h. REQUIRES_NEW), funktioniert dieser Ansatz gut.

• Asynchrone Vorgänge: Wenn Sie lang laufende, unabhängige Aufgaben haben, die asynchron ausgeführt werden müssen, aber auch ihre eigenen Transaktionsgrenzen erfordern.

Alternative: Verwendung einer Message Queue zur vollständigen Entkopplung

Wenn Sie eine erweiterte Entkopplung benötigen oder Wiederholungsversuche, Fehlerbehandlung und lang laufende Prozesse bewältigen möchten, sollten Sie die Aufgabe in eine Nachrichtenwarteschlange wie Kafka oder RabbitMQ verlagern. Durch die Verwendung einer Nachrichtenwarteschlange können Sie sicherstellen, dass jede Aufgabe in ihrem eigenen Kontext ausgeführt wird und die Transaktion unabhängig verwaltet werden kann.

Das obige ist der detaillierte Inhalt vonUmgang mit asynchroner Ausführung mit Transaktionen im Frühjahr: Eine häufige Gefahr und wie man sie löst. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!