RxJava: thử lạiKhi thử lại giới hạn

Question

Tôi mới sử dụng ReactiveX và chương trình phản ứng nói chung. Tôi cần phải thực hiện một cơ chế thử lại cho các hoạt động Couchbase CAS, nhưng ví dụ trên trang web của Couchbase cho thấy một lần thử lạiKhi có vẻ như thử lại vô thời hạn. Tôi cần phải có một giới hạn thử lại và thử lại đếm ở đâu đó trong đó.

Thử lại đơn giản() sẽ hoạt động, vì nó chấp nhận retryLimit, nhưng tôi không muốn thử lại trên mọi ngoại lệ, chỉ trên CASMismatchException.

Bất kỳ ý tưởng nào? Tôi đang sử dụng thư viện RxJava.

Answer 1

retryWhen rõ ràng là một chút phức tạp hơn retry đơn giản, nhưng đây là ý chính của nó:

• bạn vượt qua một chức năng notificationHandler để retryWhen mà phải mất một Observable<Throwable> và kết quả đầu ra một Observable<?>
• sự phát xạ của điều này trở lại Quan sát xác định khi thử lại sẽ xảy ra hoặc dừng
• vì vậy, đối với mỗi Ngoại lệ xảy ra trong luồng gốc, nếu trình xử lý phát ra 1 mục, sẽ có 1 lần thử lại. Nếu nó phát ra 2 mục, sẽ có 2 ...
• ngay sau khi luồng xử lý phát ra lỗi, thử lại bị hủy.

Sử dụng này, bạn có thể vừa:

• làm việc chỉ trên CasMismatchExceptions: chỉ có chức năng của bạn trả về một Observable.error(t) trong các trường hợp khác
• retry chỉ dành cho một số cụ thể của lần: đối với từng ngoại lệ, flatMap từ một số Observable.range đại diện cho số lần thử lại tối đa, có trả lại số Observable.timer bằng cách thử lại # nếu bạn cần sự chậm trễ tăng lên.

trường hợp sử dụng của bạn là khá gần với một trong RxJava doc here

Answer 2

Ngoài những gì Simon Basle nói, đây là một phiên bản nhanh chóng với backoff tuyến tính:

.retryWhen(notification -> 
    notification 
    .zipWith(Observable.range(1, 5), Tuple::create) 
    .flatMap(att -> 
      att.value2() == 3 ? Observable.error(att.value1()) : Observable.timer(att.value2(), TimeUnit.SECONDS) 
    ) 
) 

Lưu ý rằng " att "đây là một tuple bao gồm cả throwable và số retries, vì vậy bạn có thể thực hiện rất cụ thể một logic trả về dựa trên hai params đó.

Nếu bạn muốn tìm hiểu nhiều hơn, bạn có thể lén nhìn doc kiên cường Tôi hiện đang viết: https://gist.github.com/daschl/db9fcc9d2b932115b679#retry-with-delay

Answer 3

phục hồi chủ đề này vì trong Couchbase Java SDK 2.1.2 có một cách mới đơn giản hơn để làm điều đó : sử dụng số RetryBuilder:

Observable<Something> retryingObservable = 
sourceObservable.retryWhen(
    RetryBuilder 
    //will limit to the relevant exception 
    .anyOf(CASMismatchException.class) 
    //will retry only 5 times 
    .max(5) 
    //delay doubling each time, from 100ms to 2s 
    .delay(Delay.linear(TimeUnit.MILLISECONDS, 2000, 100, 2.0)) 
    .build() 
);