Spring Cloud中Feign与Hystrix整合的示例分析

85次阅读
没有评论

共计 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.requestVolumeThreshold

 Feign 与 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 整合的示例分析”这篇文章就分享到这里了,希望以上内容可以对大家有一定的帮助,让大家可以学到更多知识,如果觉得文章不错,可以把它分享出去让更多的人看到吧!

正文完
 
丸趣
版权声明:本站原创文章,由 丸趣 2023-08-16发表,共计3525字。
转载说明:除特殊说明外本站除技术相关以外文章皆由网络搜集发布,转载请注明出处。
评论(没有评论)