pp 2019-06-01
什么是 Feign?
与 Ribbon 一样,Feign 也是由 Netflix 提供的,Feign 是一个提供模版的声明式 Web Service 客户端, 使用 Feign 可以简化 Web Service 客户端的编写,开发者可以通过简单的接口和注解来调用 HTTP API,使得开发更加快捷、方便。Spring Cloud 也提供了 Feign 的集成组件:Spring Cloud Feign,它整合了 Ribbon 和 Hystrix ,具有可插拔、基于注解、负载均衡、服务熔断等一系列便捷功能。
在 Spring Cloud 中使用 Feign 非常简单,我们说过 Feign 是一个声明式的 Web Service 客户端,所以只需要创建一个接口,同时在接口上添加相关注解即可完成服务提供方的接口绑定,相比较于 Ribbon + RestTemplate 的方式,Feign 大大简化了代码的开发,Feign 支持多种注解,包括 Feign 注解、JAX-RS 注解、Spring MVC 注解等。Spring Cloud 对 Feign 进行了优化,整合了 Ribbon 和 Eureka ,从而让 Feign 的使用更加方便。
官网地址:
http://cloud.spring.io/spring-cloud-static/Finchley.RELEASE/single/spring-cloud.html#_spring_cloud_openfeign
我们说过 Feign 是一种比 Ribbon 更加方便好用的 Web 服务客户端,那么二者有什么具体区别呢?Feign 好用在哪里?
Ribbon 与 Feign 的区别
关于 Ribbon 和 Feign 的区别可以简单地理解为 Ribbon 是个通用的 HTTP 客户端工具,而 Feign 则是基于 Ribbon 来实现的,同时它更加灵活,使用起来也更加简单,上节课中我们通过 Ribbon + RestTemplate 实现了服务调用的负载均衡,相比较于这种方式,使用 Feign 可以直接通过声明式接口的形式来调用服务,非常方便,比 Ribbon 使用起来要更加简便,只需要创建接口并添加相关注解配置,即可实现服务消费的负载均衡。
Feign 的特点
1、Feign 是一个声明式 Web Service 客户端。
2、支持 Feign 注解、JAX-RS 注解、Spring MVC 注解。
3、Feign 基于 Ribbon 实现,使用起来更加简单。
4、Feign 集成了 Hystrix,具备服务熔断功能。
了解完 Feign 的基本概念,接下来我们一起实现 Feign。
代码实现
1、在父工程下创建 Module。
2、输入 ArtifactId,点击 Next。
3、设置工程名和工程存放路径,点击 Finish。
4、在 pom.xml 中添加 Eureka Client 和 Feign 依赖。
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
</dependencies>
5、在 resources 路径下创建配置文件 application.yml,添加 Feign 相关配置。
server:
port: 8050
spring:
application:
name: feign
eureka:
client:
service-url:
defaultZone: http://localhost:8761/eureka/
instance:
prefer-ip-address: true
属性说明:
server.port:当前 feign 服务端口。
spring.application.name:当前服务注册在 Eureka Server 上的名称。
eureka.client.service-url.defaultZone:注册中心的访问地址。
eureka.instance.prefer-ip-address:是否将当前服务的 IP 注册到 Eureka Server。
6、在 java 路径下创建启动类 FeignApplication。
@SpringBootApplication
@EnableFeignClients
public class FeignApplication {
public static void main(String[] args) {
SpringApplication.run(FeignApplication.class,args);
}
}
注解说明:
@SpringBootApplication:声明该类是 Spring Boot 服务的入口。
@EnableFeignClients:声明启用 Feign。
7、接下来通过接口的方式调用 provider 服务,首先创建对应的实体类 Student。
@Data
@AllArgsConstructor
@NoArgsConstructor
public class Student {
private long id;
private String name;
private char gender;
}
8、创建 FeignProviderClient 接口。
@FeignClient(value = "provider")
public interface FeignProviderClient {
@GetMapping("/student/index")
public String index();
@GetMapping("/student/findAll")
public Collection<Student> findAll();
@GetMapping("/student/findById/{id}")
public Student findById(@PathVariable("id") long id);
@PostMapping("/student/save")
public void save(@RequestBody Student student);
@PutMapping("/student/update")
public void update(@RequestBody Student student);
@DeleteMapping("/student/deleteById/{id}")
public void deleteById(@PathVariable("id") long id);
}
@FeignClient 指定 feign 要调用的微服务,直接指定服务提供者在注册中心的 application name 即可。
9、创建 FeignHandler,通过 @Autowired 注入 FeignProviderClient 实例,完成相关业务。
@RequestMapping("/feign")
@RestController
public class FeignHandler {
@Autowired
private FeignProviderClient feignProviderClient;
@GetMapping("/index")
public String index(){
return feignProviderClient.index();
}
@GetMapping("/findAll")
public Collection<Student> findAll(){
return feignProviderClient.findAll();
}
@GetMapping("/findById/{id}")
public Student findById(@PathVariable("id") long id){
return feignProviderClient.findById(id);
}
@PostMapping("/save")
public void save(@RequestBody Student student){
feignProviderClient.save(student);
}
@PutMapping("/update")
public void update(@RequestBody Student student){
feignProviderClient.update(student);
}
@DeleteMapping("/deleteById/{id}")
public void deleteById(@PathVariable("id") long id){
feignProviderClient.deleteById(id);
}
}
10、依次启动注册中心,端口为 8010 的 provider,端口为 8011 的 provider,feign,如下图所示。
11、打开浏览器,访问 http://localhost:8761,看到如下界面。
12、可以看到两个 provider 和 feign 已经在注册中心完成注册,接下来使用 Postman 工具测试 feign 相关接口,如下图所示。
13、Feign 也提供了负载均衡功能,通过 Postman 访问 http://localhost:8050/feign/index,交替出现下图所示情况,实现了负载均衡。
14、Feign 同时提供了容错功能,如果服务提供者 provider 出现故障无法访问,直接访问 Feign 会报错,如下图所示。
15、很显然这种直接返回错误状态码的交互方式不友好,可以通过容错机制给用户相应的提示信息,而非错误状态码,使得交互方式更加友好,容错机制非常简单,首先在 application.yml 中添加配置。
server:
port: 8050
spring:
application:
name: feign
eureka:
client:
service-url:
defaultZone: http://localhost:8761/eureka/
instance:
prefer-ip-address: true
feign:
hystrix:
enabled: true
feign.hystrix.enabled:是否开启熔断器。
16、创建 FeignProviderClient 接口的实现类 FeignError ,定义容错处理逻辑,通过 @Component 将 FeignError 实例注入 IoC 容器。
@Component
public class FeignError implements FeignProviderClient {
@Override
public String index() {
return "服务器维护中....";
}
@Override
public Collection<Student> findAll() {
return null;
}
@Override
public Student findById(long id) {
return null;
}
@Override
public void save(Student student) {
}
@Override
public void update(Student student) {
}
@Override
public void deleteById(long id) {
}
}
17、在 FeignProviderClient 定义处通过 @FeignClient 的 fallback 属性设置映射。
@FeignClient(value = "provider",fallback = FeignError.class)
public interface FeignProviderClient {
}
18、启动注册中心和 feign ,此时没有服务提供者 provider 被注册,直接访问 feign 接口,如下图所示。