Resilience4J adalah perpustakaan teras yang digunakan untuk membina aplikasi Java elastik. 1. Modulnya termasuk pemutus litar, kadar terhad, cuba lagi, bulkhead, masa terhad dan cache, yang boleh digunakan pada permintaan; 2. Pemutus litar menghalang kegagalan cascade dengan mengkonfigurasi FailureRatEthreshold dan parameter lain, dan menggunakan Decoratesupplier untuk membungkus panggilan perkhidmatan; 3. Cuba semula boleh digabungkan dengan ratelimiter, hadkan arus dan kemudian cuba semula untuk mengelakkan kelebihan perkhidmatan hiliran; 4. Pada boot musim bunga, konfigurasi boleh dipermudahkan oleh anotasi seperti @circuitbreaker dan @retry, dan peraturan boleh ditakrifkan dalam application.yml; 5. Sokongan mikrometer mengintegrasikan pemantauan untuk mengeksport metrik ke Prometheus atau Grafana untuk pemerhatian.

Apabila membina aplikasi Java yang bergantung kepada API seperti API, pangkalan data, atau kelebihan -pergeseran mesej luaran tidak dapat dielakkan. Rangkaian Hiccups, Timeouts, dan Outages Service berlaku. Resilience4J adalah perpustakaan berorientasikan pengaturcaraan yang ringan dan berfungsi yang direka untuk menjadikan sistem Java anda lebih berdaya tahan dengan mengendalikan kegagalan ini dengan anggun. Ia sangat popular dalam seni bina microservices di mana komunikasi perkhidmatan-ke-perkhidmatan adalah perkara biasa.

Tidak seperti penyelesaian yang lebih lama seperti Hystrix (sekarang dalam mod penyelenggaraan), Resilience4J adalah modular, dibina dengan Java 8 Fungsian Antara muka, dan mengintegrasikan dengan baik dengan kerangka moden seperti Spring Boot. Mari kita menyelam bagaimana anda boleh menggunakan resilience4j untuk membina sistem Java yang lebih mantap.

1. Memahami modul resilience4j teras

Resilience4j dibahagikan kepada beberapa modul, masing -masing memberi tumpuan kepada corak ketahanan tertentu. Anda boleh menggunakannya secara bebas atau bersama:

• Pemutus Litar : Menghalang memanggil perkhidmatan yang gagal berulang kali dengan membuka litar selepas ambang kegagalan.
• Kadar terhad : Mengehadkan bilangan panggilan ke perkhidmatan dalam tempoh masa tertentu.
• RECRY : Secara automatik menghidupkan semula operasi yang gagal dengan kelewatan dan syarat yang boleh dikonfigurasikan.
• Bulkhead : Mengehadkan bilangan panggilan serentak ke perkhidmatan untuk mengelakkan keletihan sumber.
• Masa Terbatas : Mendefinisikan masa untuk operasi, terutamanya berguna dengan panggilan async.
• Cache : Respons Cache Untuk mengelakkan panggilan berulang untuk operasi perlahan atau mahal.

Modulariti ini membolehkan anda memilih hanya apa yang anda perlukan, mengurangkan overhead.

2. Melaksanakan corak pemutus litar

Pemutus litar adalah salah satu corak yang paling banyak digunakan. Inilah cara untuk menetapkannya:

Pertama, tambahkan kebergantungan (Maven):

 <geterlihat>
    <groupId> io.github.resilience4j </groupId>
    <stifactid> resilience4j-circuitbreaker </artifactid>
    <versi> 2.1.0 </versi>
</ketergantungan>

Kemudian konfigurasikan dan gunakannya:

 Registry CircuitBreakErregistry = CircuitBreakerregistry.OfDefaults ();
Circuitbreaker circuitbreaker = registry.circuitbreaker ("backendservice");

Circuitbreaker.state state = circuitbreaker.getState (); // ditutup, terbuka, separuh_open

Pembekal <string> dihiasisupplier = circuitbreaker
    .DeCoratesUpplier (circuitbreaker, () -> callexternalservice ());

Hasil rentetan = try.ofsupplier (dihiasiSupplier)
    .recover (dibuang -> "nilai sandaran")
    .get ();

Anda boleh mengkonfigurasi pemutus litar melalui kod atau yaml (terutamanya dalam boot musim bunga), menetapkan ambang seperti failureRateThreshold , waitDurationInOpenState , dan permittedNumberOfCallsInHalfOpenState .

3. Menggabungkan semula dan mengehadkan kadar

Sering kali, kegagalan sementara (contohnya, gangguan rangkaian) dapat diselesaikan dengan mencuba semula. Campurkan semula dengan mengehadkan kadar untuk mengelakkan perkhidmatan hiliran.

Contoh dengan cuba semula:

 RetryConfig config = retryconfig.custom ()
    .MaxAttempts (3)
    .WaitDuration (duration.ofmillis (100))
    .build ();

Retry Retry = Retry.of ("BackendService", config);

Pembekal <string> serviceCall = () -> calleXternalservice ();
Pembekal <string> retryableCall = retry.decoratesupplier (retry, serviceCall);

Dan dengan ratelimiter:

 Ratelimiterconfig rconfig = ratelimiterconfig.custom ()
    .limitforperiod (10)
    .LimitRefreshPeriod (duration.ofseconds (1))
    .TimeOutDuration (duration.ofmillis (50))
    .build ();

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

Pembekal <string> terhadcall = ratelimiter
    .DecorateSupplier (Ratelimiter, RetryableCall);

Sekarang, setiap panggilan melalui kadar yang mengehadkan, kemudian cuba semula logik jika diperlukan.

4. Mengintegrasikan dengan Spring Boot (pilihan tetapi biasa)

Jika anda menggunakan Spring Boot, integrasi menjadi lebih lancar dengan anotasi:

Tambah starter:

 <geterlihat>
    <groupId> io.github.resilience4j </groupId>
    <stifactid> resilience4j-spring-boot2 </artifactid>
    <versi> 2.1.0 </versi>
</ketergantungan>

Kemudian konfigurasikan dalam application.yml :

 resilience4j.circuitbreaker:
  Contoh:
    BackendService:
      FailureRatEthreshold: 50
      WaitdurationInopenState: 5000
      SlidingWindowsize: 10

resilience4j.retry:
  Contoh:
    BackendService:
      MaxAttempts: 3

Gunakannya dengan anotasi:

 @Circuitbreaker (name = "backendservice", fallbackmethod = "fallback")
@Retry (name = "BackendService")
rentetan awam fetchData () {
    kembali externalApiclient.getData ();
}

rentetan public rentetan (pengecualian e) {
    mengembalikan "tindak balas lalai";
}

Spring mengendalikan hiasan secara automatik.

5. Pemantauan dan pemerhatian

Resilience4J berfungsi dengan baik dengan mikrometer, membolehkan anda mengeksport metrik (seperti kadar kegagalan, tempoh panggilan, negeri litar) untuk memantau sistem seperti Prometheus atau Grafana.

Membolehkannya dengan:

 MeterRegistry MeterRegistry = SimpleMeterRegistry baru ();
TaggedCircuitBreakermetrics.ofcircuitBreakErregistry (registry) .bindto (meterregistry);

Sekarang anda boleh menjejaki kesihatan dan prestasi dalam masa nyata.

Menggunakan resilience4j tidak menghilangkan kegagalan, tetapi ia membantu sistem anda mengendalikannya tanpa meleleh ke gangguan penuh. Dengan menggabungkan litar pemecahan, mencuba, mengehadkan kadar, dan pemerhatian, anda membina sistem yang bukan hanya berfungsi, tetapi benar -benar berdaya tahan.

Pada asasnya, jika perkhidmatan Java anda bercakap dengan perkhidmatan lain, Resilience4J bernilai mengintegrasikan. Ia bukan sihir -tetapi ia dekat.

Atas ialah kandungan terperinci Membina sistem java yang berdaya tahan dengan resilience4j. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!