共计 3525 个字符，预计需要花费 9 分钟才能阅读完成。
这篇文章给大家分享的是有关 Spring Cloud 中 Feign 与 Hystrix 整合的示例分析的内容。丸趣 TV 小编觉得挺实用的，因此分享给大家做个参考，一起跟随丸趣 TV 小编过来看看吧。
Feign 与 Hystrix 整合
Feign 对 Hystrix 提供了支持，为“服务调用者”加入以下 Feign 依赖：
dependency
groupId org.springframework.cloud /groupId
artifactId spring-cloud-starter-feign /artifactId
/dependency在 application.yml 中打开 Feign 的 Hystrix 开关，请见以下配置：
feign:
hystrix:
enabled: true在应用启动类里面，加入开 Feign 的开关，本小节的“服务调用者”应用启动类，所使用的注解如下：
@SpringBootApplication
@EnableDiscoveryClient
@EnableCircuitBreaker
@ServletComponentScan
@EnableFeignClients新建 Feign 接口，调用“服务提供者（spring-hystrix-provider）”的“/hello”服务，请见代码清单 6 -24。
代码清单 6 -24：
codes\06\6.4\spring-hystrix-invoker\src\main\java\org\crazyit\cloud\feign\HelloClient.java
@FeignClient(name = spring-hystrix-provider , fallback = HelloClientFallback.class)
public interface HelloClient { @RequestMapping(method = RequestMethod.GET, value = /hello)
public String hello();
@Component
static class HelloClientFallback implements HelloClient { public String hello() {
System.out.println( hello 方法的回退
return error hello
}
}
}与普通的 Feign 客户端无异，仅仅设置了处理回退的类，回退类实现了客户端接口。为了能测试效果，修改服务器端的“/hello”服务，让其有 800 毫秒的延时。根据前面章节可知，默认情况下，Hystrix 的超时时间为 1 秒，因此，还需要修改配置超时配置。代码清单 6 -25，在 application.yml 中修改命令配置。
代码清单 6 -25：codes\06\6.4\spring-hystrix-invoker\src\main\resources\application.yml
hystrix:
command:
HelloClient#hello():
execution:
isolation:
thread:
timeoutInMilliseconds: 500
circuitBreaker:
requestVolumeThreshold: 3注意，如果是针对全局配置，则使用与下面类似的配置片断：
hystrix.command.default.circuitBreaker.requestVolumeThreshold // 默认时间段内发生的请求数
hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds // 超时时间 如果针对某个客户端，如使用下面的配置片断：
hystrix.command.CommandKey.circuitBreaker.requestVolumeThresholdFeign 与 Hystrix 整合使用时，会自动帮我们生成 CommandKey，格式为：“Feign 客户端接口名 #方法名 ()”。例如本例中的客户端为 HelloClient，方法为 hello，生成的 CommandKey 为“HelloClient#hello()”。而默认情况下，生成的 GroupKey 为 @FeignClient 注解的 name 属性。
以上的配置中，我们针对了 hello 方法，设置了超时时间为 500 毫秒，而“/hello”服务超时时间为 800 毫秒，换言之，hello 方法总会超时。另外，如果请求超过 3 次并且失败率超过 50%，断路器将被打开。编写控制器，调用 hello 服务，并查看断路器的情况，请见代码清单 6 -26。
代码清单 6 -26：HelloController.java
@RestController
public class HelloController {
@Autowired
HelloClient helloClient;
@RequestMapping(value = /feign/hello , method = RequestMethod.GET)
public String feignHello() {
// hello 方法会超时
String helloResult = helloClient.hello();
// 获取断路器
HystrixCircuitBreaker breaker = HystrixCircuitBreaker.Factory
.getInstance(HystrixCommandKey.Factory
.asKey(HelloClient#hello() ));
System.out.println(断路器状态： + breaker.isOpen());
return helloResult;
}
}控制器的方法中，获取了 hello 方法的断路器，并输出其状态。接下来，编写一个测试客户端，多线程访问：http://localhost:9000/feign/hello/{index}，也就是控制器的 feignHello 方法，客户端请见代码清单 6 -27。
代码清单 6 -27：
06\6.4\spring-hystrix-invoker\src\main\java\org\crazyit\cloud\feign\TestFeignClient.java
public class TestFeignClient {
public static void main(String[] args) throws Exception {
// 创建默认的 HttpClient
final CloseableHttpClient httpclient = HttpClients.createDefault();
// 调用多次服务并输出结果
for(int i = 0; i 6; i++) {
// 建立线程访问接口
Thread t = new Thread() { public void run() {
try {
String url = http://localhost:9000/feign/hello
// 调用 GET 方法请求服务
HttpGet httpget = new HttpGet(url);
// 获取响应
HttpResponse response = httpclient.execute(httpget);
// 根据 响应解析出字符串
System.out.println(EntityUtils.toString(response.getEntity()));
} catch (Exception e) { e.printStackTrace();
}
}
};
t.start();
}
// 等待完成
Thread.sleep(15000);
}
}完成后，依次启动 Eureka 服务器、服务提供者、服务调用者，运行代码清单 6 -27，可看到“服务计用者”的控制台输出如下：
断路器状态：false
断路器状态：false
断路器状态：false
断路器状态：false
断路器状态：true
断路器状态：true根据输出可知，断路器已经被打开。
感谢各位的阅读！关于“Spring Cloud 中 Feign 与 Hystrix 整合的示例分析”这篇文章就分享到这里了，希望以上内容可以对大家有一定的帮助，让大家可以学到更多知识，如果觉得文章不错，可以把它分享出去让更多的人看到吧！
