Penjelasan terperinci tentang Praktik Retry Framework Pencala Ulang Musim Semi

Spring Retry adalah fungsi energi yang independen dari batch pegas, yang terutama mengimplementasikan coba lagi dan sekering. Ada pembatasan skenario untuk coba lagi, dan tidak semua skenario cocok untuk coba lagi, seperti verifikasi parameter ilegal, operasi tulis, dll. (Anda perlu mempertimbangkan apakah penulisannya idempoten) tidak cocok untuk dicoba lagi. Timeout panggilan jarak jauh atau gangguan jaringan dapat dicetak ulang. Dalam kerangka tata kelola layanan mikro, biasanya memiliki konfigurasi coba lagi dan waktu tunggu. Misalnya, Dubbo dapat mengatur retries = 1, timeout = 500 panggilan gagal dan coba lagi sekali, dan panggilan gagal jika tidak kembali setelah lebih dari 500ms. Di Spring Retry Anda dapat menentukan jenis pengecualian yang perlu dicoba lagi, dan mengatur interval untuk setiap coba lagi dan jika coba lagi gagal, apakah akan terus mencoba lagi atau sekering (berhenti coba lagi).

Desain dan Implementasi

RetryOperations mendefinisikan RETRY API. RetryTemplate adalah implementasi mode templat dari API, yang mengimplementasikan coba lagi dan memecahkan sirkuit. API yang disediakan adalah sebagai berikut:

 Retryoperations Antarmuka Publik {<t, e memperluas yang dapat dilaksanakan> t dieksekusi (retrycallback <t, e> retrycallback) melempar e; } // API lainnya telah dihilangkan

RetryCallback mendefinisikan operasi yang perlu dilakukan. Setelah mendefinisikan operasi, itu adalah pertanyaan tentang cara mencoba lagi. RetryTemplate menjalankan logika cara mencoba lagi dengan merumuskan strategi coba lagi yang berbeda. Strategi RETRY Default adalah SimpleRetryPlicy , yang berarti akan diceritakan kembali 3 kali. Jika coba lagi berhasil, Anda tidak akan terus mencoba lagi. Jadi bagaimana jika 3 kaki coba lagi gagal? Proses mengakhiri atau mengembalikan hasil bottom-up. Untuk mengembalikan hasil bottom-up, Anda perlu mengkonfigurasi RecoveyCallBack . Dari namanya, Anda dapat melihat bahwa ini adalah antarmuka callback bottom-up, yang merupakan logika eksekusi setelah coba lagi gagal. Selain SimpleRetryPolicy , ada strategi coba lagi. Mari kita lihat antarmuka RetryPolicy :

 antarmuka publik Retrypolicy memperluas serial {boolean canretry (retrycontext konteks); RetryContext Open (RetryContext Parent); void close (retrycontext konteks); void Registerthrowable (RetryContext Context, Throwable Throwable);}

canRetry dipanggil setiap kali Anda mencoba lagi. Kondisi penilaian apakah Anda dapat terus mencoba lagi
Dipanggil sebelum open Retry dimulai, konteks coba lagi akan dibuat ke RetryContext , dan Retry Stack akan disimpan.
registerThrowable dipanggil setiap kali pengecualian dicoba lagi (ada pengecualian dan akan terus mencoba lagi)

Ambil SimpleRetryPolicy sebagai contoh. Ketika jumlah retry mencapai 3 (default 3 kali), berhenti mencoba lagi, dan jumlah coba lagi disimpan dalam konteks coba lagi.

Berikan implementasi strategi coba lagi berikut:

1. NeverRetryPolicy: Hanya panggilan retrycallback yang diizinkan sekali, tidak ada lagi yang diperbolehkan
2. SELALUSTRYPOLICY: Izinkan Infinite Retry sampai berhasil. Logika yang tidak tepat dalam metode ini akan menyebabkan loop dead
3. SimpleRetryPolicy: Kebijakan RETRY TETAP, Jumlah Maksimum Kembali kali adalah 3 kali secara default, kebijakan yang digunakan oleh RetryTemplate secara default
4. TimeOUTRETREDYPOLICY: Kebijakan Ulang Waktu Batas waktu, batas waktu default adalah 1 detik, dan coba lagi diizinkan dalam waktu batas waktu yang ditentukan
5. ExceptionClassifierRyPolicy: Tetapkan strategi coba lagi untuk pengecualian yang berbeda, mirip dengan kombinasi strategi coba lagi, perbedaannya adalah bahwa hanya coba lagi untuk pengecualian yang berbeda dibedakan di sini.
6. CircuitbreakerretryPolicy: Coba lagi kebijakan dengan fungsi pemutus sirkuit, 3 parameter perlu diatur OpenTimeout, ResetTimeout dan Delegate
7. ComposIteretryPolicy: Ada dua metode kombinasi. Strategi Ceritry Kombinasi Optimis berarti bahwa selama ada strategi yang memungkinkan RETRY, dan strategi coba lagi kombinasi pesimistis berarti bahwa selama ada strategi yang tidak memungkinkan coba lagi, tetapi tidak peduli metode kombinasi mana, setiap strategi dalam kombinasi akan dieksekusi.

Coba lagi strategi fallback mengacu pada apakah setiap coba lagi segera atau tunggu sebentar sebelum mencoba lagi. Secara default, Anda perlu menentukan BackoffRetryPolicy kebijakan backoff jika Anda perlu mengonfigurasi masa tunggu dan kemudian mencoba lagi. Backoffretrypolicy memiliki implementasi berikut:

1. NOBACKOFFPOLICY: Tidak ada strategi algoritma backoff, cobalah segera setelah setiap coba lagi
2. FixEbackOffPolicy: Kebijakan cadangan waktu tetap. Parameter tidur dan backoffperiod harus diatur. Sleeper menentukan kebijakan tunggu. Standarnya adalah Thread.sleep, yaitu, Sleep Thread, Backoffperiod menentukan waktu tidur, dan standarnya 1 detik.
3. UniformRandOmbackOffPolicy: Kebijakan backoff waktu acak, sleeper, minbackoffperiod dan maxbackoffperiod, kebijakan ini membutuhkan waktu tidur acak antara [minbackoffperiod, maxbackoffperiod, minbackoffperiod, default 500 milidetik, default maxbackoffperiod 1500 miliseconds
4. ExponentialBackOffPolicy: Kebijakan Backoff Eksponensial, Parameter Sleeper, InitialInterval, MaxInterval dan Multiplier perlu diatur. InitialInterval Menentukan waktu tidur awal, default 100 milidetik, MaxInterval menentukan waktu tidur maksimum, default 30 detik, Multiplier menentukan pengganda, yaitu, waktu tidur berikutnya adalah waktu tidur saat ini*Pengganda
5. ExponentialRandombackoffpolicy: Strategi backoff eksponensial acak, memperkenalkan pengganda acak dapat mewujudkan backoff pengganda acak

Coba lagi atau coba lagi

Retry tanpa kewarganegaraan yang disebut mengacu kembali yang diselesaikan dalam konteks utas. Kalau tidak, jika coba lagi yang tidak diselesaikan dalam konteks utas adalah coba lagi. SimpleRetryPolicy sebelumnya adalah coba lagi karena coba lagi selesai dalam satu loop. Jadi apa yang terjadi setelah itu atau perlu dikembalikan dalam keadaan? Biasanya ada dua situasi: transaksi rollback dan pemutus sirkuit.

DataAccessException luar biasa. Coba lagi tidak dapat dilakukan, tetapi jika pengecualian lain dilemparkan, Anda dapat mencoba lagi.

Fuse berarti tidak menangani coba lagi di loop saat ini, tetapi untuk mode coba lagi global (bukan konteks utas). Pemutus sirkuit akan melompat keluar dari loop, dan informasi tumpukan konteks utas pasti akan hilang. Maka pasti perlu untuk menyimpan informasi ini dalam "mode global". Implementasi saat ini ditempatkan dalam cache (implementasi MAP). Anda dapat terus mencoba lagi setelah mendapatkannya dari cache lain kali.

Awal yang cepat

Gunakan @EnableRetry pada kelas yang perlu dilakukan Retry, jika proxyTargetClass=true diatur, ini menggunakan proxy dinamis CGLIB:

 @Configuration@enableretry (proxyTargetClass = true) @ComponentPublic kelas retryexamples {}

Coba lagi berdasarkan jumlah maksimum strategi retries, jika coba lagi diulang 3 kali dan pengecualian masih dilemparkan, coba lagi dihentikan dan panggilan balik bottom-up dijalankan. Oleh karena itu, hasil output akhir adalah Integer.MAX_VALUE :

 private void retryexample3 () melempar pengecualian {retrytemplate retrytemplate = retrytemplate baru (); SimpleretryPolicy SimpleretryPolicy = new SimpleretryPolicy (); SimpleretryPolicy.SetMaxAttempts (3); retrytemplate.setRetrypolicy (SimpleretryPolicy); Integer hasil = retrytemplate.execute (retrycallback baru <integer, exception> () {int i = 0; // coba lagi operasi @override public integer dowithretry (retrycontext retrycontext) lempar pengecualian {log.info ("jumlah retry: {},}, retrycet. }}, RecoveryCallback baru <Integer> () {// base callback @Override Public Integer Recover (RetryContext RetryContext) melempar Exception {log.info ("setelah RETRY: {}, REGORTING DAPATKAN!", log.info ("Hasil akhir: {}", hasilnya); } private int len (int i) melempar pengecualian {if (i <10) melempar pengecualian baru (i + "le 10"); Kembalikan i; }

Berikut ini menjelaskan cara menggunakan mode kebijakan pemutus pemutus sirkuit (sirkuitbreakerretrypolicy). Tiga parameter berikut perlu diatur:

1. Delegasi: Lulus dalam retrypolicy (masing -masing implementasi retrypolicy memiliki implementasi kebijakan yang coba lagi), adalah strategi yang benar -benar menentukan apakah akan mencoba lagi. Saat Palas gagal, kebijakan pemutus sirkuit dieksekusi
2. OpenTimeout: OpenWindow, mengkonfigurasi waktu batas waktu untuk sirkuit sekering untuk dibuka. Ketika openimeout melebihi openimeout, sirkuit sekering menjadi keadaan semi-terbuka (selama coba lagi berhasil, sirkuit akan ditutup)
3. ResetTimeOut: Timeout, Konfigurasikan waktu batas waktu untuk reset sekering reclosing

Pembukaan pemutus sirkuit dan penutupan penilaian:

1. Saat coba lagi gagal dan sekering membuka jendela waktu [0, OpenWindow) segera menyatu
2. Saat coba lagi gagal dan batas waktu melebihi, sirkuit sekering ditutup lagi
3. Ketika sekering setengah terbuka [OpenWindow, Timeout], konteksnya diatur ulang selama coba lagi dan pemutus sirkuit ditutup

Kode tes adalah sebagai berikut:

 Template RetryTemplate = RetryTemplate baru (); Sirkuitbreakerretrypolicy retrypolicy = new CircuitbreakerretryPolicy (new SimpleretryPolicy (3)); retrypolicy.setopentimeout (5000); Retrypolicy.SetResetTimeout (20000); template.setretrypolicy (retrypolicy); untuk (int i = 0; i <10; i ++) {//thread.sleep(100); coba {objek key = "sirkuit"; boolean isforcerefresh = false; Retrystate state = DEFAULTRETREDSTATE BARU (Key, ISFORCEREFRESH); String result = template.execute (retrycallback baru <string, runimeException> () {@Override public string dowithretry (retrycontext konteks) melempar runtimeeException {log.info ("retry count: {}", context.getRetrycount (); new runime runime: {}, context.getretcount (); new runime runime: {{}, context.getretcount (); RecoveryCallback <String> () {@Override Public String Recover (RetryContext Context) melempar Exception {return "default"; log.info ("hasil: {}", hasilnya); } catch (Exception e) {System.out.println (e); }}

Karena isForceRefresh = false diatur, nilai key = "circuit" (yaitu, retrycontext) akan diperoleh dari cache. Oleh RetryContext itu, ketika coba lagi gagal dan this.time < this.openWindow

Pengembangan Anotasi

Jika menulis RetryTemplate setiap kali Anda memiliki persyaratan coba lagi terlalu membengkak, menggunakan anotasi dapat sangat menyederhanakan pengembangan dan mengurangi kode duplikat. Berikut adalah coba lagi strategi coba lagi yang diimplementasikan menggunakan anotasi:

 @Retryable (value = sqldataException.class, backoff = @backoff (value = 0l)) public string service3 () melempar sqldataException {log.info ("service3 open"); lempar sqldataException baru (); } @Recover string public recover (sqldataException ne) {return "sqldataException Recover"; }

Anotasi meliputi:

@Enableretry

@Retryable

@Pulih

@Backoff

@Circuitbreaker

@Enableretry: Bisakah Anda mencoba lagi? Ketika properti ProxyTargetClass benar (default false), gunakan proxy cglib

@Retryable: Metode anotasi perlu dicoba lagi

1. Sertakan menentukan kelas pengecualian yang akan diproses. Default kosong
2. Kecualikan menentukan pengecualian yang tidak perlu ditangani. Default kosong
3. Vaue menentukan pengecualian untuk mencoba lagi. Default kosong
4. MaxAttempts jumlah maksimum retries. Default 3 kali
5. Coba lagi kembali kebijakan tunggu. Gunakan anotasi @Backoff secara default

@Backoff: Coba lagi strategi fallback (coba sekarang atau tunggu sebentar sebelum mencoba lagi)

1. Ketika tidak ada parameter yang ditetapkan, FixEbackOffPolicy digunakan secara default. Coba lagi dan tunggu 1000ms.
2. Saat mengatur properti hanya penundaan (), gunakan FixedBackOffPolicy untuk mencoba dan menunggu jumlah milidetik yang ditentukan
3. Saat mengatur penundaan () dan properti maxdealy (), coba lagi dan tunggu distribusi yang homogen antara kedua nilai ini
4. Gunakan Properti ExponentialBackOffPolicy Saat Menggunakan Delay (), MaxDealy () dan Multiplier () Properties
5. Ketika properti Multiplier () ditetapkan tidak sama dengan 0, dan properti acak () juga ditetapkan, gunakan ExponentialRandombackoffpolicy

@Recover: Untuk digunakan dengan metode. Digunakan sebagai metode "dijamin" ketika @Retryable gagal. Metode anotasi @Recover harus konsisten dengan metode "tanda tangan" anotasi @Retryable. Parameter entri pertama adalah pengecualian yang akan dikembalikan. Parameter lain konsisten dengan @etryable. Nilai pengembalian harus sama, jika tidak, itu tidak dapat dieksekusi!

@Circuitbreaker: Digunakan untuk metode, implementasikan mode pemecahan sirkuit.

1. Sertakan menentukan kelas pengecualian yang akan diproses. Default kosong
2. Kecualikan menentukan pengecualian yang tidak perlu ditangani. Default kosong
3. Vaue menentukan pengecualian untuk mencoba lagi. Default kosong
4. MaxAttempts jumlah maksimum retries. Default 3 kali
5. OpenTimeout mengkonfigurasi waktu batas waktu untuk pembukaan sekering, default 5s. Ketika openimeout melebihi openimeout, sirkuit sekering menjadi keadaan semi-terbuka (selama coba lagi berhasil, sirkuit akan ditutup)
6. ResetTimeOut Mengkonfigurasi Waktu Batas Waktu untuk Reclosing Fuse, Default 20S, Jika Pemutus Sirkuit ditutup setelah waktu ini

Untuk contoh lebih lanjut, selamat datang di GitHub saya (https://github.com/happyxiaofan/springboot-learning-example). Terima kasih

Di atas adalah semua konten artikel ini. Saya berharap ini akan membantu untuk pembelajaran semua orang dan saya harap semua orang akan lebih mendukung wulin.com.