發現stream裡邊乙個好用的retry元件

**設計的挺好的，以後可以參考，在此記錄下

翻譯說明

使用重試語義簡化操作執行的模板類。

retryable操作封裝在retrycallback介面的實現中，並使用提供的execute方法之一執行。

預設情況下，如果丟擲任何異常或異常的子類，則重試操作。可以使用setretrypolicy（retrypolicy）方法更改此行為。

另外，在預設情況下，每個操作最多重試三次，其間沒有後退。可以使用setretrypolicy（retrypolicy）和setbackoffpolicy（backoffpolicy）屬性配置此行為。backoffpolicy控制每次重試之間的暫停時間。

這個類是執行緒安全的，適合在執行操作和執行配置更改時併發訪問。因此，可以動態更改重試次數以及使用的backoffpolicy，並且不會影響正在進行的可重試操作。

org.springframework.retry

spring-retry

1.3.0

public static void main(string args) );
system.out.println(execute);
}

對於許多**，大概都包含配置config，作為全域性配置，用於元件啟動過程的初始化配置資訊和元件內部的區域性配置資訊，上下文context可作為執行緒上下文或全域性上下文，會貫穿整個元件生命週期前後，產生到銷毀的過程中，會在生命週期內的各個內部元件的執行過程中所應用，像spring也會實現該上下文介面轉化出乙個子類上下文，用於擴充套件元件，便於資料的隔離。具體執行處理器processer，執行器一般會作為乙個連線橋的功能，比如由乙個採集資料的執行器processer執行完之後，將進入格式化的執行器processer，格式化parser的執行器processer執行完之後，將進入傳送sink的執行器processer。設計模式好像都有單例模式、工廠模式、責任鏈、建造者、觀察者模式等等，如果包含manager管理者的話，一般包含靜態成員變數或threadlocal容器，有的元件還包含了統計的stat類，進行呼叫次數或執行狀態的統計，統計類一般被具體執行類繼承或者封裝到上下文content裡邊，如果需要對資料進行進一步增強處理，有的元件會加入***鏈的形式對資料進行格式化處理。並且多餘實現多型的乙個通性，大多都是execute進入方法，doexecute將執行方法，其他的例如process、doprocess，create、docreate，handler、dohandler，service、doservice，start、dostart，filter、dofilter等等，當然如果系統更加豐富的化，應該加入元資料資訊介面，被執行類所繼承，設定執行類的元資料資訊，如果像tomcat、spring等**，則需要生命週期lifecicle的管理，對於support結尾的類一般作為擴充套件介面出現。

**模式：類似於jdk8的流式程式設計更好的可讀性。這裡是這樣的，當然也可以直接進行例項化操作。

retrytemplate retrytemplate = retrytemplate.builder()
.maxattempts(10)
.fixedbackoff(1000)
.build();

1: 處理器processer

這裡邊叫做retryoperations，執行操作叫做execute。實現類即retrytemplate

2: backoff重試阻塞類圖構建

3:重試機制類圖構建：

4:監聽類圖，監聽作為列表資料存在retrytemplate中，執行execute後，retrycallback前遍歷執行，注釋表述是起到對context的增強作用

發現stream裡邊乙個好用的retry元件

乙個666的發現

乙個小發現

發現乙個問題

發現stream裡邊乙個好用的retry元件

乙個666的發現

乙個小發現

發現乙個問題

相關推薦