三、SpringCloud--Feign

1.服务调用Feign入门

        前面我们使用的RestTemplate实现REST API调用，代码大致如下：

@GetMapping("/buy/{id}")
public Product order() {
    Product product = restTemplate.getForObject("http://shop-serviceproduct/product/1", Product.class);
    return product; }

        由代码可知，我们是使用拼接字符串的方式构造URL 的，该 URL 只有一个参数。但是，在现实中， URL中往往含有多个参数。这时候我们如果还用这种方式构造URL ，那么就会非常痛苦。那应该如何解决？我们带着这样的问题进入到本章的学习。 1.1 Feign简介

        Feign是Netflflix开发的声明式，模板化的HTTP客户端，其灵感来自Retrofifit,JAXRS-2.0以及WebSocket。

• Feign可帮助我们更加便捷，优雅的调用HTTP API。
• 在SpringCloud中，使用Feign非常简单——创建一个接口，并在接口上添加一些注解，代码就完成了。
• Feign支持多种注解，例如Feign自带的注解或者JAX-RS注解等。
• SpringCloud对Feign进行了增强，使Feign支持了SpringMVC注解，并整合了Ribbon和Eureka，从而让Feign的使用更加方便。

1.2基于Feign的服务调用

        引入依赖 ：在服务消费者 shop_service_order 添加Fegin依赖 。

 org.springframework.cloud
 spring-cloud-starter-openfeign

        启动类添加Feign的支持

@SpringBootApplication(scanbasePackages="cn.itcast.order")
@EntityScan("cn.itcast.entity")
@EnableFeignClients
public class OrderApplication {
 public static void main(String[] args) {
 SpringApplication.run(OrderApplication.class, args);
 }
}

        通过@EnableFeignClients注解开启Spring Cloud Feign的支持功能。

        启动类激活FeignClient：创建一个Feign接口，此接口是在Feign中调用微服务的核心接口，在服务消费者 shop_service_order 添加一个 ProductFeginClient 接口 。

//指定需要调用的微服务名称
 @FeignClient(name="shop-service-product") public interface ProductFeginClient { //调用的请求路径 @RequestMapping(value = "/product/{id}",method = RequestMethod.GET) public Product findById(@PathVariable("id") Long id); }

• 定义各参数绑定时，@PathVariable、@RequestParam、@RequestHeader等可以指定参数属 性，在Feign中绑定参数必须通过value属性来指明具体的参数名，不然会抛出异常
• @FeignClient：注解通过name指定需要调用的微服务的名称，用于创建Ribbon的负载均衡器。 所以Ribbon会把 shop-service-product 解析为注册中心的服务。

        配置请求提供者的调用接口：修改 OrderController ，添加ProductFeginClient的自动注入，并在order方法中使用ProductFeginClient 完成微服务调用。

@RestController @RequestMapping("/order") public class OrderController { @Autowired private ProductFeginClient productFeginClient; @GetMapping("/buy/{id}") public Product order(@PathVariable Long id) { return productFeginClient.findById(id); } }

        测试效果。

1.3Feign和Ribbon的联系

        Ribbon是一个基于 HTTP 和 TCP 客户端 的负载均衡的工具。它可以 在客户端 配置 RibbonServerList（服务端列表），使用 HttpClient 或 RestTemplate 模拟http请求，步骤相当繁琐。

        Feign 是在 Ribbon的基础上进行了一次改进，是一个使用起来更加方便的 HTTP 客户端。采用接口的 方式只需要创建一个接口，然后在上面添加注解即可 ，将需要调用的其他服务的方法定义成抽象方法即可， 不需要自己构建http请求。然后就像是调用自身工程的方法调用，而感觉不到是调用远程方法，使得编写客户端变得非常容易。

1.4负载均衡

        Feign中本身已经集成了Ribbon依赖和自动配置，因此我们不需要额外引入依赖，也不需要再注册 RestTemplate 对象。另外，我们可以像上节课中讲的那样去配置Ribbon，可以通过 ribbon.xx 来进行全局配置。也可以通过 服务名.ribbon.xx 来对指定服务配置：启动两个 shop_service_product ，重新测试可以发现使用Ribbon的轮询策略进行负载均衡。

2.服务调回Feigh高级 2.1Feign的配置

        从Spring Cloud Edgware开始，Feign支持使用属性自定义Feign。对于一个指定名称的Feign Client（例如该Feign Client的名称为 feignName ），Feign支持如下配置项：

• feignName：FeginClient的名称  
• connectTimeout ： 建立链接的超时时长
• readTimeout ： 读取超时时长
• loggerLevel: Fegin的日志级别
• errorDecoder ：Feign的错误解码器
• retryer ： 配置重试
• requestInterceptors ： 添加请求拦截器
• decode404 ： 配置熔断不处理404异常

2.2请求压缩

        Spring Cloud Feign 支持对请求和响应进行GZIP压缩，以减少通信过程中的性能损耗。通过下面的参数即可开启请求与响应的压缩功能：

2.3日志级别

        在开发或者运行阶段往往希望看到Feign请求过程的日志记录，默认情况下Feign的日志是没有开启的。要想用属性配置方式来达到日志效果，只需在 application.yml 中添加如下内容即可：

2.4源码分析

        通过上面的使用过程，@EnableFeignClients和@FeignClient两个注解就实现了Feign的功能，那我们从 @EnableFeignClients注解开始分析Feign的源码。

        EnableFeignClients注解：通过 @EnableFeignClients 引入了FeignClientsRegistrar客户端注册类。

        FeignClientsRegistrar注册类：

        注册FeignClient对象：

        FeignClientFactoryBean类：

        发送请求 ：

3.服务注册与发现总结 3.1注册中心

        Eureka ：

        搭建注册中心 ：

•         引入依赖 spring-cloud-starter-netflix-eureka-server
•         配置EurekaServer
•         通过 @EnableEurekaServer 激活Eureka Server端配置

        服务注册 ：

• 服务提供者引入 spring-cloud-starter-netflix-eureka-client 依赖
• 通过 eureka.client.serviceUrl.defaultZone 配置注册中心地址

3.2服务调用

        Ribbon：

• 通过Ribbon结合RestTemplate方式进行服务调用只需要在声明RestTemplate的方法上添加注解 @LoadBalanced即可；
• 可以通过 {服务名称}.ribbon.NFLoadBalancerRuleClassName 配置负载均衡策略。

        Feign ：

• 服务消费者引入 spring-cloud-starter-openfeign 依赖；
• 通过 @FeignClient 声明一个调用远程微服务接口；
• 启动类上通过 @EnableFeignClients 激活Feign。

4.微服务架构的高并发问题

        通过注册中心已经实现了微服务的服务注册和服务发现，并且通过Ribbon实现了负载均衡，已经借助 Feign可以优雅的进行微服务调用。那么我们编写的微服务的性能怎么样呢，是否存在问题呢？

4.1性能工具Jmetter

         Apache JMeter是Apache组织开发的基于Java的压力测试工具。用于对软件做压力测试，它最初被设计 用于Web应用测试，但后来扩展到其他测试领域。 它可以用于测试静态和动态资源，例如静态文件、 Java 小服务程序、CGI 脚本、Java 对象、数据库、FTP 服务器， 等等。JMeter 可以用于对服务器、网络或对象模拟巨大的负载，来自不同压力类别下测试它们的强度和分析整体性能。另外JMeter能够对应用程序做功能/回归测试，通过创建带有断言的脚本来验证你的程序返回了你期望的结果。为了最大限度的灵活性，JMeter允许使用正则表达式创建断言。

4.1.1安装Jmetter

       Jmetter安装十分简单，使用资料中的 apache-jmeter-2.13.zip 完整压缩包，解压找到安装目录下bin/jmeter.bat 已管理员身份启动即可。

4.1.2配置Jmetter

•         创建新的测试计划；
•         测试计划下创建发起请求的线程组；
•         可以配置请求的线程数；
•         以及每个请求发送的请求次数；
•         创建http请求模板；
•         配置测试的接口信息。        

4.2系统负载过高存在的问题 4.2.1问题分析

        在微服务架构中，我们将业务拆分成一个个的服务，服务与服务之间可以相互调用，由于网络原因或者自身的原因，服务并不能保证服务的100%可用，如果单个服务出现问题，调用这个服务就会出现网络延迟，此时若有大量的网络涌入，会形成任务累计，导致服务瘫痪。

4.2.2线程池的形式实现服务隔离

        配置坐标 ：为了方便实现线以线程池的形式完成资源隔离，需要引入如下依赖 。

 
    com.netflix.hystrix 
    hystrix-metrics-event-stream
    1.5.12 
 
 
    com.netflix.hystrix 
    hystrix-javanica 
    1.5.12
 

        配置线程池：配置HystrixCommand接口的实现类，再实现类中可以对线程池进行配置 。

public class OrderCommand extends HystrixCommand { private RestTemplate restTemplate; private Long id; public OrderCommand(RestTemplate restTemplate, Long id) { super(setter()); this.restTemplate = restTemplate; this.id = id; }private static Setter setter() { // 服务分组 HystrixCommandGroupKey groupKey = HystrixCommandGroupKey.Factory.asKey("order_product"); // 服务标识 HystrixCommandKey commandKey = HystrixCommandKey.Factory.asKey("product"); // 线程池名称 HystrixThreadPoolKey threadPoolKey = HystrixThreadPoolKey.Factory.asKey("order_product_pool");  HystrixThreadPoolProperties.Setter threadPoolProperties = HystrixThreadPoolProperties.Setter().withCoreSize(50) .withKeepAliveTimeMinutes(15).withQueueSizeRejectionThreshold(100); // 命令属性配置Hystrix 开启超时 HystrixCommandProperties.Setter commandProperties = HystrixCommandProperties.Setter() // 采用线程池方式实现服务隔离
.withExecutionIsolationStrategy(HystrixCommandProperties.ExecutionIsolationStrat egy.THREAD) // 禁止 .withExecutionTimeoutEnabled(false); return HystrixCommand.Setter.withGroupKey(groupKey).andCommandKey(commandKey).andThread PoolKey(threadPoolKey) .andThreadPoolPropertiesDefaults(threadPoolProperties).andCommandPropertiesDefau lts(commandProperties); }@Override protected String run() throws Exception { return restTemplate.getForObject("http://shop-service- product/product/"+id, String.class); }@Override protected String getFallback(){ return "熔断降级"; } }

        配置调用 ：修改 OrderController ，使用自定义的OrderCommand完成调用 。

@Autowired private RestTemplate restTemplate; @GetMapping("/buy/{id}") public String order(@PathVariable Long id) throws ExecutionException, InterruptedException, TimeoutException { return new OrderCommand(restTemplate,id).execute(); }