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依赖。

<dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-starter-openfeign</artifactId>
    </dependency>

启动类添加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线程池的形式实现服务隔离

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

<dependency> 
    <groupId>com.netflix.hystrix</groupId> 
    <artifactId>hystrix-metrics-event-stream</artifactId>
    <version>1.5.12</version> 
</dependency> 
<dependency> 
    <groupId>com.netflix.hystrix</groupId> 
    <artifactId>hystrix-javanica</artifactId> 
    <version>1.5.12</version>
 </dependency>

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

public class OrderCommand extends HystrixCommand<String> {
    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");
        /*** 线程池配置 * withCoreSize : 线程池大小为10 * withKeepAliveTimeMinutes: 线程存活时间15秒 * withQueueSizeRejectionThreshold :队列等待的阈值为100,超过100执行拒绝 策略 */
        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完成调用。

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

三、SpringCloud--Feign