Retry (reactor-3)

java.lang.Object
- reactor.util.retry.Retry

直接已知子类:

RetryBackoffSpec, RetrySpec
```
public abstract class Retry
extends java.lang.Object
```
Base abstract class for a strategy to decide when to retry given a companion Flux of Retry.RetrySignal, for use with Flux.retryWhen(Retry) and Mono.retryWhen(Retry). Also provides access to configurable built-in strategies via static factory methods:
Users are encouraged to provide either concrete custom Retry strategies or builders that produce such concrete Retry. The RetrySpec returned by e.g. max(long) is a good inspiration for a fluent approach that generates a Retry at each step and uses immutability/copy-on-write to enable sharing of intermediate steps (that can thus be considered templates).
作者:

Simon Baslé

嵌套类概要

嵌套类
限定符和类型	类和说明
`static interface`	`Retry.RetrySignal` State used in `Flux.retryWhen(Retry)` and `Mono.retryWhen(Retry)`, providing the `Throwable` that caused the source to fail as well as counters keeping track of retries.

字段概要

字段
限定符和类型字段和说明

ContextView retryContext

字段
限定符和类型	字段和说明
`ContextView`	`retryContext`

构造器概要

构造器
构造器和说明

Retry()

构造器
构造器和说明
`Retry()`

方法概要

所有方法静态方法实例方法抽象方法具体方法
限定符和类型	方法和说明
`static RetryBackoffSpec`	`backoff(long maxAttempts, java.time.Duration minBackoff)` A `RetryBackoffSpec` preconfigured for exponential backoff strategy with jitter, given a maximum number of retry attempts and a minimum `Duration` for the backoff.
`static RetryBackoffSpec`	`fixedDelay(long maxAttempts, java.time.Duration fixedDelay)` A `RetryBackoffSpec` preconfigured for fixed delays (min backoff equals max backoff, no jitter), given a maximum number of retry attempts and the fixed `Duration` for the backoff.
`static Retry`	`from(java.util.function.Function<Flux<Retry.RetrySignal>,? extends org.reactivestreams.Publisher<?>> function)` A wrapper around `Function` to provide `Retry` by using lambda expressions.
`abstract org.reactivestreams.Publisher<?>`	`generateCompanion(Flux<Retry.RetrySignal> retrySignals)` Generates the companion publisher responsible for reacting to incoming `Retry.RetrySignal` emissions, effectively deciding when to retry.
`static RetrySpec`	`indefinitely()` A `RetrySpec` preconfigured for the most simplistic retry strategy: retry immediately and indefinitely (similar to `Flux.retry()`).
`static RetrySpec`	`max(long max)` A `RetrySpec` preconfigured for a simple strategy with maximum number of retry attempts.
`static RetrySpec`	`maxInARow(long maxInARow)` A `RetrySpec` preconfigured for a simple strategy with maximum number of retry attempts over subsequent transient errors.
`ContextView`	`retryContext()` Return the user provided context that was set at construction time.
`static Retry`	`withThrowable(java.util.function.Function<Flux<java.lang.Throwable>,? extends org.reactivestreams.Publisher<?>> function)` An adapter for `Flux` of `Throwable`-based `Function` to provide `Retry` from a legacy retryWhen `Function`.

从类继承的方法 java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- 字段详细资料
  - retryContext
```
public final ContextView retryContext
```
- 构造器详细资料
  - Retry
```
public Retry()
```
- 方法详细资料
  - generateCompanion
```
public abstract org.reactivestreams.Publisher<?> generateCompanion(Flux<Retry.RetrySignal> retrySignals)
```
    Generates the companion publisher responsible for reacting to incoming Retry.RetrySignal emissions, effectively deciding when to retry.
    When the source signals an error, that onError signal will be suppressed. Its Throwable will instead be attached to a Retry.RetrySignal, immediately emitted on the retrySignals publisher. Right after that emission, request(1) is called on the companion publisher.
    The response to that request decides if a retry should be made. Thus, the outer publisher will wait until a signal is emitted by the companion publisher, making it possible to delay retry attempts.
    Any onNext emitted by the companion publisher triggers a retry, onError will fail the outer publisher and onComplete will complete the outer publisher (effectively suppressing the original error/Throwable).
    As an example, the simplest form of retry companion would be to return the incoming Flux of Retry.RetrySignal without modification. This would render a retry strategy that immediately retries, forever.
    
    参数:
    
    retrySignals - the errors from the outer publisher as Retry.RetrySignal objects, containing the Throwable causing the error as well as retry counter metadata.
    
    返回:
    
    the companion publisher responsible for reacting to incoming Retry.RetrySignal emissions, effectively deciding when to retry.
  - retryContext
```
public ContextView retryContext()
```
    Return the user provided context that was set at construction time.
    
    返回:
    
    the user provided context that will be accessible via Retry.RetrySignal.retryContextView().
  - backoff
```
public static RetryBackoffSpec backoff(long maxAttempts,
                                       java.time.Duration minBackoff)
```
    A RetryBackoffSpec preconfigured for exponential backoff strategy with jitter, given a maximum number of retry attempts and a minimum Duration for the backoff.
    
    参数:
    
    maxAttempts - the maximum number of retry attempts to allow
    
    minBackoff - the minimum Duration for the first backoff
    
    返回:
    
    the exponential backoff spec for further configuration
    
    另请参阅:
    
    RetryBackoffSpec.maxAttempts(long), RetryBackoffSpec.minBackoff(Duration)
  - fixedDelay
```
public static RetryBackoffSpec fixedDelay(long maxAttempts,
                                          java.time.Duration fixedDelay)
```
    A RetryBackoffSpec preconfigured for fixed delays (min backoff equals max backoff, no jitter), given a maximum number of retry attempts and the fixed Duration for the backoff.
    
    Note that calling RetryBackoffSpec.minBackoff(Duration) or RetryBackoffSpec.maxBackoff(Duration) would switch back to an exponential backoff strategy.
    
    参数:
    
    maxAttempts - the maximum number of retry attempts to allow
    
    fixedDelay - the Duration of the fixed delays
    
    返回:
    
    the fixed delays spec for further configuration
    
    另请参阅:
    
    RetryBackoffSpec.maxAttempts(long), RetryBackoffSpec.minBackoff(Duration), RetryBackoffSpec.maxBackoff(Duration)
  - max
```
public static RetrySpec max(long max)
```
    A RetrySpec preconfigured for a simple strategy with maximum number of retry attempts.
    
    参数:
    
    max - the maximum number of retry attempts to allow
    
    返回:
    
    the max attempt spec for further configuration
    
    另请参阅:
    
    RetrySpec.maxAttempts(long)
  - maxInARow
```
public static RetrySpec maxInARow(long maxInARow)
```
    A RetrySpec preconfigured for a simple strategy with maximum number of retry attempts over subsequent transient errors. An Subscriber.onNext(Object) between errors resets the counter (see RetrySpec.transientErrors(boolean)).
    
    参数:
    
    maxInARow - the maximum number of retry attempts to allow in a row, reset by successful onNext
    
    返回:
    
    the max in a row spec for further configuration
    
    另请参阅:
    
    RetrySpec.maxAttempts(long), RetrySpec.transientErrors(boolean)
  - indefinitely
```
public static RetrySpec indefinitely()
```
    A RetrySpec preconfigured for the most simplistic retry strategy: retry immediately and indefinitely (similar to Flux.retry()).
    
    返回:
    
    the retry indefinitely spec for further configuration
  - from
```
public static final Retry from(java.util.function.Function<Flux<Retry.RetrySignal>,? extends org.reactivestreams.Publisher<?>> function)
```
    A wrapper around Function to provide Retry by using lambda expressions.
    
    参数:
    
    function - the Function representing the desired Retry strategy as a lambda
    
    返回:
    
    the Retry strategy adapted from the Function
  - withThrowable
```
public static final Retry withThrowable(java.util.function.Function<Flux<java.lang.Throwable>,? extends org.reactivestreams.Publisher<?>> function)
```
    An adapter for Flux of Throwable-based Function to provide Retry from a legacy retryWhen Function.
    
    参数:
    
    function - the Function representing the desired Retry strategy as a lambda
    
    返回:
    
    the Retry strategy adapted from the Function

类 Retry

嵌套类概要

字段概要

构造器概要

方法概要

从类继承的方法 java.lang.Object

字段详细资料

retryContext

构造器详细资料

Retry

方法详细资料

generateCompanion

retryContext

backoff

fixedDelay

max

maxInARow

indefinitely

from

withThrowable