Resilience4J ist die Kernbibliothek, mit der elastische Java -Anwendungen erstellt werden. 1. Seine Module umfassen Leistungsschalter, Rate Limited, Wiederholung, Schott, Zeitbeschr?nkung und Cache, die bei Bedarf verwendet werden k?nnen. 2. Der Leistungsschalter verhindert Kaskadenfehler durch Konfigurieren von Failureratethreshold und anderen Parametern und verwendet DecorateSupplier, um Service -Anrufe zu wickeln. 3. Wiederholung kann mit Ratelimiter kombiniert werden, den Strom einschr?nken und dann wiederholen, um eine nachgeschaltete Service -überlastung zu vermeiden. 4. Im Spring Start kann die Konfiguration durch Annotationen wie @Circuitbreaker und @Retry vereinfacht werden, und Regeln k?nnen in application.yml definiert werden. 5. Support Micrometer integrieren überwachung, um Metriken in Prometheus oder Grafana zur Beobachtbarkeit zu exportieren.

Beim Erstellen von Java -Anwendungen, die auf externen Diensten stützen - wie APIs, Datenbanken oder Nachrichtenwarteschlangen - sind unvermeidliche Aufgaben unvermeidlich. Network -Schluckauf, Zeitüberschreitungen und Serviceausf?lle ereignen sich. Resilience4J ist eine leichte, funktionelle programmierorientierte Bibliothek, die Ihre Java-Systeme durch den Umgang mit diesen Fehlern anmutiger umgehen. Es ist besonders beliebt in Microservices-Architekturen, bei denen die Kommunikation von Service-to-Service-Kommunikation üblich ist.

Im Gegensatz zu ?lteren L?sungen wie Hystrix (jetzt im Wartungsmodus) ist Resilience4J modular, mit Java 8 -funktionalen Schnittstellen erstellt und in moderne Frameworks wie Spring Boot integriert. Lassen Sie uns darüber eingehen, wie Sie Resilience4J verwenden k?nnen, um robustere Java -Systeme zu erstellen.

1. Verst?ndnis der Kernresilienz4J -Module

Resilience4J ist in mehrere Module aufgeteilt, wobei sich jeweils auf ein bestimmtes Resilienzmuster konzentriert. Sie k?nnen sie unabh?ngig oder zusammen verwenden:

• Leistungsschalter : verhindert, dass das Aufrufen eines fehlerhaften Dienstes wiederholt durch ?ffnen der Schaltung nach einem Fehlerschwelle ge?ffnet wird.
• Rate Limited : Begrenzt die Anzahl der Anrufe an einen Dienst in einem bestimmten Zeitraum.
• Wiederholung : automatisch fehlgeschlagene Vorg?nge mit konfigurierbaren Verz?gerungen und Bedingungen.
• Bulkhead : Begrenzt die Anzahl der gleichzeitigen Anrufe in einen Dienst, um die Ersch?pfung der Ressourcen zu verhindern.
• Time Limited : Definiert eine Zeitüberschreitung für Operationen, insbesondere bei asynchronen Aufrufen.
• Cache : Reaktionen zwischen Caches, um wiederholte Anrufe zu langsamen oder teuren Vorg?ngen zu vermeiden.

Mit dieser Modularit?t k?nnen Sie nur das ausw?hlen, was Sie brauchen, und reduzieren Sie den Aufwand.

2. Implementieren des Leistungsschaltermusters

Der Leistungsschalter ist eines der am h?ufigsten verwendeten Muster. Hier erfahren Sie, wie Sie es einrichten:

Fügen Sie zun?chst die Abh?ngigkeit (Maven) hinzu:

 <De vorangehen>
    <GruppeId> io.github.resilience4j </Groupid>
    <artifactid> resilience4j-circuitbreaker </artifactid>
    <version> 2.1.0 </Version>
</abh?ngig>

Konfigurieren und verwenden Sie es dann:

 CircuitBreakerRegistry Registry = CircuitBreakerRegistry.Ofdefaults ();
CircuitBreaker CircuitBreaker = Registry.Circuitbreaker ("Backendservice");

CircuitBreaker.State State = CircuitBreaker.getState (); // geschlossen, ge?ffnet, halb_open

Lieferant <string> dekoriertes Supplier = Circuitbreaker
    .DecorateSupplier (CircuitBreaker, () -> CallexTernalService ());

String -Ergebnis = try.ofSupplier (dekoriertes Supplier)
    .Recover (Throwable -> "Fallback -Wert")
    .erhalten();

Sie k?nnen den Leistungsschalter über Code oder YAML (insbesondere im Spring -Start) konfigurieren, Schwellenwerte wie failureRateThreshold , waitDurationInOpenState einstellen und permittedNumberOfCallsInHalfOpenState ,

3.. Kombinieren Sie Rethery und Rate Begrenzung

Oft k?nnen vorübergehende Ausf?lle (z. B. Netzwerkst?rungen) mit einem Wiederholung aufgel?st werden. Kombinieren Sie die Wiederholung mit einer Rate einschr?nkend, um den nachgeschalteten Service zu vermeiden.

Beispiel mit Wiederholung:

 Retryconfig config = retryconfig.custom ())
    .Maxattemutptes (3)
    .waitDuration (Dauer.Ofmillis (100))
    .bauen();

Wiederholung RETRY = RETRY.OF ("Backendservice", config);

Lieferant <string> serviceCall = () -> CallexTernalService ();
Lieferant <string> retryableCall = retyry.DecorateSupplier (RETRY, ServiceCall);

Und mit Ratelimiter:

 Ratelimiterconfig rconfig = ratelimiterconfig.custom ()
    .LimitForperiod (10)
    .LimitreFreshperiod (Dauer.Fach (1))
    .TimeoutDuration (Dauer.Ofmillis (50))
    .bauen();

Ratelimiter ratelimiter = ratelimiter.of ("Backendservice", rconfig);

Lieferant <string> eingeschr?nkter = ratelimiter
    .DecorateSupplier (Ratelimiter, retryableCall);

Jetzt verl?uft jeder Anruf die Ratenbegrenzung und mache dann bei Bedarf Logik erneut.

4. Integrieren in Spring Boot (optional, aber h?ufig)

Wenn Sie Spring Boot verwenden, wird die Integration mit Anmerkungen noch glatter:

Fügen Sie den Starter hinzu:

 <De vorangehen>
    <GruppeId> io.github.resilience4j </Groupid>
    <artifactid> resilience4j-pring-boot2 </artifactid>
    <version> 2.1.0 </Version>
</abh?ngig>

Dann konfigurieren Sie in application.yml :

 Resilience4J.Circuitbreaker:
  Instanzen:
    Backendservice:
      failureratethreshold: 50
      WaitDurationInopenstate: 5000
      Slidingwindowsize: 10

Resilience4J.Retry:
  Instanzen:
    Backendservice:
      Maxattemptes: 3

Verwenden Sie es mit Anmerkungen:

 @Circuitbreaker (name = "Backendservice", FallbackMethod = "Fallback"))
@Retry (name = "Backendservice"))
public String fetchdata () {
    return externalapiclient.getData ();
}

public String Fallback (Ausnahme E) {
    Rückgabe "Standardantwort";
}

Feder behandelt die Dekoration automatisch.

5. überwachung und Beobachtbarkeit

Resilience4J funktioniert gut mit dem Mikrometer und erm?glicht es Ihnen, Metriken (wie Fehlerraten, Aufrufdauer, Schaltungszustand) in die überwachung von Systemen wie Prometheus oder Grafana zu exportieren.

Aktivieren Sie es mit:

 Meterregistry Meterregistry = new SimpleMeterregistry ();
Markgecircuitbreakermetrics.ofcircuitbreakerregistry (Registry) .Bindto (Meterregistry);

Jetzt k?nnen Sie Gesundheit und Leistung in Echtzeit verfolgen.

Die Verwendung von Resilience4J beseitigt keine Fehler, aber es hilft Ihrem System, sie umzugehen, ohne in vollst?ndige Ausf?lle zu kassieren. Durch die Kombination von Schaltkreisen, Wiederholung, Ratenlimit und Beobachtbarkeit erstellen Sie Systeme, die nicht nur funktional, sondern wirklich belastbar sind.

Wenn Ihr Java -Service zu einem anderen Service spricht, lohnt es sich im Grunde genommen, integriert zu werden. Es ist keine Magie - aber es ist nah.

Das obige ist der detaillierte Inhalt vonAufbau von widerstandsf?higen Java -Systemen mit Resilience4J. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!