背景
OpenFeign是微服务中服务远程调用组件。
circuitbreaker 是断路器的抽象接口。
resilience4j是断路器的一种实现。
在服务间远程调用过程中，为了避免服务雪崩，需要设置失败保护机制，当下游服务超时或者不可用时，上游服务可以快速返回，同时下游服务会降级，上游服务短时间不去请求下游服务。
实现远程调用
服务提供者
服务提供者就是正常的SpringBoot项目，为了让服务调用者可以请求该服务，需要将服务信息注册到Consul注册中心。
1依赖如下：
<dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-jpa</artifactId></dependency><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-consul-config</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-consul-discovery</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-circuitbreaker-resilience4j</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-actuator</artifactId></dependency></dependencies>
2配置如下：
spring:application:name: system-applicationcloud:consul:discovery:service-name: ${spring.application.name}instance-id: system-servicehost: localhostport: 8500config:format: yamldata-key: systemenabled: truewatch:enabled: truewait-time: 5config:import: optional:consul:${spring.cloud.consul.host}:${spring.cloud.consul.port}/testhello:name
3还需要自己实现一个普通controller。
启动服务提供者，打开consul控制台，服务成功注册即可。
服务消费
1 添加依赖
<dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-jpa</artifactId></dependency><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-consul-config</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-consul-discovery</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-circuitbreaker-resilience4j</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-actuator</artifactId></dependency></dependencies>
相比服务提供者，多了一个断路器的依赖：
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-circuitbreaker-resilience4j</artifactId></dependency>
2 配置：
spring:application:name: portal-applicationcloud:consul:discovery:service-name: ${spring.application.name}instance-id: portal-servicehost: localhostport: 8500config:import: optional:consul:${spring.cloud.consul.host}:${spring.cloud.consul.port}feign:circuitbreaker:enabled: true
# client:
# config:
# default:
# connectTimeout: 1000
# readTimeout: 1000server:port: 8081配置文件中只添加如下配置，用于打开circuitbreaker。
feign:
circuitbreaker:
enabled: true
3 配置断路器, 这里配置了1ms的超时。
@Configuration
public class BreakerConfig {@Beanpublic Customizer<Resilience4JCircuitBreakerFactory> defaultCustomizer() {return factory -> factory.configureDefault(id -> new Resilience4JConfigBuilder(id).timeLimiterConfig(TimeLimiterConfig.custom().timeoutDuration(Duration.ofMillis(1)).build()).circuitBreakerConfig(CircuitBreakerConfig.ofDefaults()).build());}
}4 实现FeignClient调用，主要是加入fallback逻辑，用于失败后的处理
@FeignClient(name ="system-application", fallback = UserClient.Fallback.class)
@Component
public interface UserClient {@GetMapping("")String getName();@Componentstatic class Fallback implements UserClient {@Overridepublic String getName() {return "00000000000000000000000";}}
}
至此，基本的Demo已经完成。
启动服务消费者，访问feignClient的接口，发现返回了fallback类中配置的信息。证明断路器配置起作用。
除了断路器的配置外，如下的配置和断路器无关，支持配置了http请求的超时时间，如果超时，会报错，不会触发Fallback。
client:config:default:connectTimeout: 1000readTimeout: 1000
总结
- 加入断路器依赖
- feign.circuitbreaker.enabled: true 开启断路器
- 注入Resilience4JConfigBuilder
以上三步在服务调用方实现。
