主要讲解 resilience4j-spring-boot2：

1、依赖导入

dependencies {

compile "io.github.resilience4j:resilience4j-spring-boot2:${resilience4jVersion}"

compile('org.springframework.boot:spring-boot-starter-actuator')

compile('org.springframework.boot:spring-boot-starter-aop')

}

2、yml文件配置

resilience4j.circuitbreaker: #熔断

instances:

backendA:

registerHealthIndicator: true

slidingWindowSize: 100

backendB:

registerHealthIndicator: true

slidingWindowSize: 10

permittedNumberOfCallsInHalfOpenState: 3

slidingWindowType: TIME_BASED

minimumNumberOfCalls: 20

waitDurationInOpenState: 50s

failureRateThreshold: 50

eventConsumerBufferSize: 10

recordFailurePredicate: io.github.robwin.exception.RecordFailurePredicate

resilience4j.retry: #重试

instances:

backendA:

maxRetryAttempts: 3

waitDuration: 10s

enableExponentialBackoff: true

exponentialBackoffMultiplier: 2

retryExceptions:

- org.springframework.web.client.HttpServerErrorException

- java.io.IOException

ignoreExceptions:

- io.github.robwin.exception.BusinessException

backendB:

maxRetryAttempts: 3

waitDuration: 10s

retryExceptions:

- org.springframework.web.client.HttpServerErrorException

- java.io.IOException

ignoreExceptions:

- io.github.robwin.exception.BusinessException

resilience4j.bulkhead: #降级

instances:

backendA:

maxConcurrentCalls: 10

backendB:

maxWaitDuration: 10ms

maxConcurrentCalls: 20

resilience4j.thread-pool-bulkhead:

instances:

backendC:

maxThreadPoolSize: 1

coreThreadPoolSize: 1

queueCapacity: 1

resilience4j.ratelimiter: # 限流

instances:

backendA:

limitForPeriod: 10

limitRefreshPeriod: 1s

timeoutDuration: 0

registerHealthIndicator: true

eventConsumerBufferSize: 100

backendB:

limitForPeriod: 6

limitRefreshPeriod: 500ms

timeoutDuration: 3s

3、注解Annotations

@CircuitBreaker(name = BACKEND, fallbackMethod = "fallback")

@RateLimiter(name = BACKEND)

@Bulkhead(name = BACKEND)

@Retry(name = BACKEND, fallbackMethod = "fallback")

public Mono method(String param1) {

return Mono.error(new NumberFormatException());

}

private Mono fallback(String param1, IllegalArgumentException e) {

return Mono.just("test");

}

private Mono fallback(String param1, RuntimeException e) {

return Mono.just("test");

}