Feign實現和負載均衡

Feign是一個聲明式WebService客戶端，使用方法是定義一個介面並在上面添加註解即可。Feign支持可拔插式的編碼器和解碼器。

Spring Cloud對Feign進行了封裝，使其支持SpringMVC和HttpMessageConverters。Feign可以與Eureka和Ribbon組合使用以支持負載均衡。

[Feign源碼]: https://github.com/OpenFeign/Feign

使用案例：

1.新建一個Feign模塊，類似之前Ribbon中使用的consume-9001模塊。在依賴信息中加入Feign的依賴；

2. <?xml version="1.0" encoding="UTF-8"?>
3. <project xmlns="http://maven.apache.org/POM/4.0.0"
4. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
5. xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
6. <parent>
7. <artifactId>spring-cloud-demo</artifactId>
8. <groupId>com.wangcw.springcloud</groupId>
9. <version>1.0-SNAPSHOT</version>
10. </parent>
11. <modelVersion>4.0.0</modelVersion>
13. <artifactId>springclouddemo-consume-feign-9002</artifactId>
15. <dependencies>
16. <!--Feign模塊依賴-->
17. <dependency>
18. <groupId>org.springframework.cloud</groupId>
19. <artifactId>spring-cloud-starter-feign</artifactId>
20. </dependency>
21. <!-- 自己定義的api -->
22. <dependency>
23. <groupId>com.wangcw.springcloud</groupId>
24. <artifactId>springclouddemo-api</artifactId>
25. <version>${project.version}</version>
26. </dependency>
27. <!-- Ribbon相關 -->
28. <dependency>
29. <groupId>org.springframework.cloud</groupId>
30. <artifactId>spring-cloud-starter-eureka</artifactId>
31. </dependency>
32. <dependency>
33. <groupId>org.springframework.cloud</groupId>
34. <artifactId>spring-cloud-starter-ribbon</artifactId>
35. </dependency>
36. <dependency>
37. <groupId>org.springframework.cloud</groupId>
38. <artifactId>spring-cloud-starter-config</artifactId>
39. </dependency>
40. <dependency>
41. <groupId>org.springframework.boot</groupId>
42. <artifactId>spring-boot-starter-web</artifactId>
43. </dependency>
44. </dependencies>
46. </project>

2. 因為Feign開發其實是面向介面編程，所以Feign介面可以放在公共模塊【springclouddemo-api】模塊中供各模塊使用，所以要在【springclouddemo-api】模塊中添加也添加Feign依賴；

2. <?xml version="1.0" encoding="UTF-8"?>
3. <project xmlns="http://maven.apache.org/POM/4.0.0"
4. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
5. xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
6. <parent>
7. <artifactId>spring-cloud-demo</artifactId>
8. <groupId>com.wangcw.springcloud</groupId>
9. <version>1.0-SNAPSHOT</version>
10. </parent>
11. <modelVersion>4.0.0</modelVersion>
13. <artifactId>springclouddemo-api</artifactId>
15. <dependencies>
16. <!--Feign依賴-->
17. <dependency>
18. <groupId>org.springframework.cloud</groupId>
19. <artifactId>spring-cloud-starter-feign</artifactId>
20. </dependency>
21. <!--mybatis-->
22. <dependency>
23. <groupId>org.mybatis.spring.boot</groupId>
24. <artifactId>mybatis-spring-boot-starter</artifactId>
25. <version>1.3.0</version>
26. </dependency>
27. <dependency>
28. <groupId>tk.mybatis</groupId>
29. <artifactId>mapper-spring-boot-starter</artifactId>
30. <version>2.0.0</version>
31. </dependency>
32. <dependency>
33. <groupId>javax.persistence</groupId>
34. <artifactId>persistence-api</artifactId>
35. <version>1.0.2</version>
36. </dependency>
38. <dependency>
39. <groupId>org.projectlombok</groupId>
40. <artifactId>lombok</artifactId>
41. </dependency>
42. </dependencies>
44. </project>

3.在公共模塊【springclouddemo-api】中編寫介面，介面上添加@FeignClient註解，並通過value指定作用的微服務名；

2. package com.wangcw.service;
5. /* 新建Feign介面供各個模塊調用微服務 【SPRINGCLOUDDEMO-PROVIDER-DEPT】*/
6. @FeignClient(value = "SPRINGCLOUDDEMO-PROVIDER-DEPT")
7. public interface FeignClientService{
9. @RequestMapping(value = "/provider/dept/get/{id}", method = RequestMethod.GET)
10. Dept get(@PathVariable("id") long id);
12. @RequestMapping(value = "/provider/dept/list", method = RequestMethod.GET)
13. List<Dept> list();
15. }

4.在步驟1中新建的Feign模塊中編寫Controller，並注入FeignClient介面，直接調用service介面中的方法即可（因為聲明Feign介面時已經指定過微服務，所以訪問時會正確地找到微服務）

2. @RestController
3. @RequestMapping(value = "/consumer")
4. public class DeptController_Consumer {
6. /* 注入公共模塊中的FeignService */
7. @Autowired
8. private FeignClientService feignClientService;
10. @RequestMapping(value = "/dept/get/{id}")
11. public Dept get(@PathVariable("id") Long id) {
12. return this.feignClientService.get(id);
13. }
15. @RequestMapping(value = "/dept/list")
16. public List<Dept> list() {
17. return this.feignClientService.list();
18. }
21. }

5.修改Feign模塊的主啟動類，加入@EnableFeignClients註解（主要是掃描公共模塊【springclouddemo-api】中聲明的介面）

2. @SpringBootApplication(exclude = {DataSourceAutoConfiguration.class, HibernateJpaAutoConfiguration.class})
3. @EnableEurekaClient
4. @EnableFeignClients(basePackages= {"com.wangcw.service"})
5. public class DeptConsumer_Feign_9002_App {
6. public static void main(String[] args) {
7. SpringApplication.run(DeptConsumer_Feign_9002_App.class, args);
8. }
9. }

6.啟動訪問測試，會發現訪問時帶有輪詢機制的負載均衡。

（原理：其實就是類似於在公共工程api中加入Service介面，在介面中利用@FeignClient註解去調用對應的服務暴露的方法。

所有需要調用註冊的服務的類都直接去調用api中的service，即相當於是在調用對應的在線服務了）

總結：

- Feign通過介面方法調用REST服務，在Eureka中查找對應的服務

- Feign集成了Ribbon技術，所以也支持負載均衡（輪詢）

喜歡這篇文章嗎？立刻分享出去讓更多人知道吧！