1 Feign是什么?
- Feign是声明式的Web Service客户端,它让微服务之间的调用变得更简单,类似于Controller调用Service。
- Spring Cloud集成了Ribbon和Eureka,可以在使用Feign时提供负载均衡的http客户端。
- 使用方式:只需要创建一个接口,然后添加注解即可。
- 调用微服务的两种方法:
- 微服务名字(Ribbon)。
- 接口和注解(Feign)。
2 Feign能干什么?
- Feign旨在使编写Java HTTP客户端变得更容易。
- 在使用Ribbon+RestTemplate时,利用RestTemplate对HTTP请求的封装处理,形成了一套模板化的调用方法。
- 但是在实际开发中,由于对服务依赖的调用可能不止一处,往往一个接口会被多处调用,所以通常都会针对每个微服务自行封装一些客户端来包装这些依赖服务的调用。
- 所以,Feign在此基础上做了进一步的封装,由它来帮助我们定义和实现依赖服务接口的定义。
- 在Feign的实现下,我们只需要创建一个接口并通过注解的方式来配置它(类似于在DAO接口上标注@Mapper,现在是一个微服务接口上标注一个Feign注解即可)。即可完成对微服务提供方的接口绑定,简化了使用Spring Cloud Ribbon时,自动封装服务调用客户端的开发量。
3 Feign集成了Ribbon
- 利用Ribbon维护了MicroServiceCloud-Dept的服务列表信息,并且通过轮询实现了客户端的负载均衡,而与Ribbon不同的是,通过Feign只需要定义服务绑定接口且以声明式的方法,优雅而且简单地实现了服务调用。
4 Feign起步
1、新建客户端module
2、pom.xml
<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <parent> <artifactId>springcloud</artifactId> <groupId>com.xianhuii</groupId> <version>1.0-SNAPSHOT</version> </parent> <modelVersion>4.0.0</modelVersion> <artifactId>springcloud-consumer-dept-feign</artifactId> <dependencies> <!--Feigh--> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-feign</artifactId> <version>1.4.7.RELEASE</version> </dependency> <!--Ribbon--> <!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-ribbon --> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-ribbon</artifactId> <version>1.4.7.RELEASE</version> </dependency> <!--Eureka--> <!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-eureka --> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-eureka</artifactId> <version>1.4.7.RELEASE</version> </dependency> <!-- 实体类 --> <dependency> <groupId>com.xianhuii</groupId> <artifactId>springcloud-api</artifactId> <version>1.0-SNAPSHOT</version> </dependency> <!-- Web --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <!-- 热部署 --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-devtools</artifactId> </dependency> </dependencies> </project>
3、FeignDeptConsumer_80
package xianhuii.springcloud; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.netflix.eureka.EnableEurekaClient; import org.springframework.cloud.openfeign.EnableFeignClients; import org.springframework.context.annotation.ComponentScan; @EnableEurekaClient @SpringBootApplication @EnableFeignClients(basePackages = {"com.xianhui.springcloud"}) @ComponentScan("com.xianhuii.springcloud") public class FeignDeptConsumer_80 { public static void main(String[] args) { SpringApplication.run(FeignDeptConsumer_80.class, args); } }
4、springcloud-api:DeptClientService
package com.xianhuii.springcloud.service; import com.xianhuii.springcloud.pojo.Dept; import org.springframework.cloud.openfeign.FeignClient; import org.springframework.stereotype.Component; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.PostMapping; import java.util.List; @Component @FeignClient(value = "SPRINGCLOUD-PROVIDER-DEPT") public interface DeptClientService { @GetMapping("/dept/get/{id}") Dept queryById(@PathVariable("id") Long id); @GetMapping("/dept/list") List<Dept> queryAll(); @PostMapping("/dept/add") Boolean addDept(Dept dept); }
5、DeptConsumerController
package xianhuii.springcloud.controller; import com.xianhuii.springcloud.pojo.Dept; import com.xianhuii.springcloud.service.DeptClientService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; import org.springframework.web.client.RestTemplate; import java.util.List; /** * 消费者:不应该有Service * RestTemplate:提供多种便捷访问远程http服务的方法,简单的RESTful服务模板 * (url, 参数, responseType) */ @RestController public class DeptConsumerController { @Autowired private DeptClientService service; @RequestMapping("/consumer/dept/get/{id}") public Dept get(@PathVariable("id") Long id) { return service.queryById(id); } @RequestMapping("/consumer/dept/add") public boolean add(Dept dept) { return service.addDept(dept); } @RequestMapping("/consumer/dept/list") public List<Dept> list() { return service.queryAll(); } }