8、SpringCloud 之声明式服务消费Feign

Feign 是什么

Feign是Netflix公司开发的一个声明式的REST调用客户端；

Ribbon负载均衡、Hystrix服务熔断是我们Spring Cloud中进行微服务开发非常基础的组件，在使用的过程中我们也发现它们一般都是同时出现，而且配置很相似，每次开发都有很多相同的代码，因此Spring Cloud基于Netflix Feign整合了Ribbon和Hystrix两个组件，让我们的开发工作变得更加简单， 就像Spring Boot是对 SpringFramework+SpringMVC的简化一样，Spring Cloud Feign 对 Ribbon 负载均衡、Hystrix 服务熔断进行简化，在其基础上进行了进一步的封装，不仅在配置上大大简化了开发工作，同时还提供了一种声明式的Web服务客户端定义方式；

使用 Feign 实现消费者

使用Feign实现消费者，我们通过下面步骤进行：

第一步：创建Spring Boot工程

第二步：添加依赖

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
<!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-feign -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-feign</artifactId>
    <version>1.4.7.RELEASE</version>
</dependency>

第三步：添加注解

在项目入口类上添加@EnableFeignClients注解表示开启Spring Cloud Feign的支持功能；

@EnableFeignClients
@SpringBootApplication
public class Application {

    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }

}

第四步：声明服务
定义一个HelloService接口，通过@FeignClient注解来指定服务名称，进而绑定服务，然后再通过SpringMVC中提供的注解来绑定服务提供者提供的接口，如下

//服务名称是配置服务提供者的配置spring.application.name的名称
@FeignClient("01-springcloud-service-provider")
public interface HelloService {

    /**
     * 声明一个方法，这个方法就是远程的服务提供者的方法
     * @return
     */
    @RequestMapping("/service/hello")
    public String hello();
}

这相当于绑定了一个名叫 01-springcloud-service-provider 的服务提供者提供的/service/hello接口；

@RequestMapping("/service/hello")
public String hello(){
    return "hello spring clound provider 1";
}

第五步：使用Controller中调用服务
创建Controller来调用上面的服务，如下：

@RestController
public class FeignController {
    @Autowired
    HelloService helloService;

    @RequestMapping("/web/hello")
    public String hello(){
        return helloService.hello();
    }
}

第六步：属性配置

#访问端口
server.port=8083
#服务名称
spring.application.name=05-springcloud-service-feign
#eureka注册中心地址
eureka.client.service-url.defaultZone=http://eureka8761:8761/eureka,http://eureka8762:8762/eureka

第七步：测试
依次启动注册中心、服务提供者和feign实现服务消费者，然后访问:http://localhost:8083/web/hello

使用 Feign 实现消费者的测试

负载均衡

Spring Cloud 提供了Ribbon来实现负载均衡，使用Ribbo直接注入一个RestTemplate对象即可RestTemplate已经做好了负载均衡的配置；

在Spring Cloud下，使用Feign也是直接可以实现负载均衡的，定义一个注解有@FeignClient 注解的接口，然后使用@RequestMapping 注解到方法上映射远程的REST服务，此方法也是做好负责均衡配置的。

服务熔断

第一步、在application.properties文件开启hystrix功能

#开启服务熔断
feign.hystrix.enabled=true 

第二步、指定熔断回调逻辑

(1)常见一个类用于编写回调方法

@Component
public class MyFallback implements HelloService{
    /**
     * 覆盖HelloService接口，重写hello方法
     * @return
     */
    @Override
    public String hello() {
        return "远程调用服务失败，调用熔断降级方法";
    }
}

(2)接口类添加fallback属性指定回调逻辑

/**
 * 服务名称是配置服务提供者的配置spring.application.name的名称
 * 当远程调用服务失败时，会调用fallback属性指定的类的同名方法为回调方法
 */
@FeignClient(name = "01-springcloud-service-provider", fallback = MyFallback.class)
public interface HelloService {

    /**
     * 声明一个方法，这个方法就是远程的服务提供者的方法
     * @return
     */
    @RequestMapping("/service/hello")
    public String hello();
}

3、服务熔断获取异常信息

为@FeignClient修饰的接口加上fallback方法可以实现远程服务发生异常后进行服务的熔断，但是不能获取到远程服务的异常信息，如果要获取远程服务的异常信息，此时可以使用fallbackFactory:

/**
 * 实现FallbackFactory接口，泛型为远程调用方法的接口
 */
@Component
public class MyFallbackFactory implements FallbackFactory<HelloService>{
    //重写creat方法，由于返回值是泛型，所以需要返回接口对象
    @Override
    public HelloService create(Throwable throwable) {
        return new HelloService() {
            @Override
            public String hello() {
                return throwable.getMessage();
            }
        };
    }
}

/**
 * 服务名称是配置服务提供者的配置spring.application.name的名称
 */
@FeignClient(name = "01-springcloud-service-provider", fallbackFactory= MyFallbackFactory.class /**fallback = MyFallback.class*/)
public interface HelloService {

    /**
     * 声明一个方法，这个方法就是远程的服务提供者的方法
     * @return
     */
    @RequestMapping("/service/hello")
    public String hello();
}