springboot中使用Feign整合nacos,gateway進行微服務之間的調用方法
1、什么是Feign
Feign 是 Spring Cloud Netflix 組件中的一個輕量級 RESTful 的 HTTP 服務客戶端，實現了負載均衡和 Rest 調用的開源框架，封裝了 Ribbon 和 RestTemplate，實現了 WebService 的面向接口編程，進一步降低了項目的耦合度。
Feign 內置了 Ribbon(其主要功能是提供客戶端實現負載均衡算法)，用來做客戶端負載均衡調用服務注冊中心的服務。
Feign 本身并不支持 Spring MVC 的注解，它有一套自己的注解，為了更方便的使用，Spring Cloud 孵化了 OpenFeign。
Feign 是一種聲明式、模板化的 HTTP 客戶端（僅在 Consumer 中使用）。
Feign 支持的注解和用法請參考官方文檔：https://github.com/OpenFeign/feign 或 spring.io 官網文檔
Feign 的使用方式是：使用 Feign 的注解定義接口，調用這個接口，就可以調用服務注冊中心的服務。
2、為什么使用Feign?
1.微服務之間調用變得簡單
它讓微服務之間的調用變得更簡單了，類似controller調用service
2.使用簡單
只需要創(chuàng)建一個接口，然后添加注解即可使用Feign
3.簡化代碼
Feign默認集成了Ribbon，簡化了使用Spring Cloud Ribbon負載均衡時，自動封裝服務調用客戶端的開發(fā)量
3、如何使用Feign？
目錄及項目結構
子工程
<modules>
<module>service-provider</module>
<module>service-provider02</module>
<module>service-consumer</module>
<module>service-gateway</module>
</modules>注:
注冊中心實例 nacos
service-provider | service-provider02 服務提供者實例
service-consumer 服務消費者
service-gateway 網關服務
3.1注冊中心Nacos部署
部署nacos(略)
3.2部署生產者
1.新建maven項目,過程省略…
2.關鍵配置
server:
port: 7070 # 端口
spring:
application:
name: service-provider # 應用名稱(集群下相同)
#nacos配置
spring:
cloud:
nacos:
discovery:
server-addr: localhost:88483.邏輯部分
為了檢測Feign的負載均衡,所以在provide01中,將返回結果增加01后綴
/**
* 查詢商品列表
*
* @return
*/
@Override
public List<Product> selectProductList() {
return Arrays.asList(
new Product(1, "華為手機01", 1, 5800D),
new Product(2, "聯想筆記本01", 1, 6888D),
new Product(3, "小米平板01", 5, 2020D)
);
}4.部署雙節(jié)點provide02
重復步驟 【1~3】,修改serverImpl邏輯,改為后綴加02
/**
* 查詢商品列表
*
* @return
*/
@Override
public List<Product> selectProductList() {
return Arrays.asList(
new Product(1, "華為手機02", 1, 5800D),
new Product(2, "聯想筆記本02", 1, 6888D),
new Product(3, "小米平板02", 5, 2020D)
);
}5.啟動雙節(jié)點,監(jiān)控Nacos
3.3 部署消費者,使用Feign調用provider方法
1.新建maven工程,過程省略…
2.引入nacos和feign的pom依賴
<!-- nacos 依賴 -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
<version>0.9.0.RELEASE</version>
</dependency><!-- spring cloud openfeign 依賴 -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>3.添加配置文件
server:
port: 9090 # 端口
spring:
application:
name: service-consumer # 應用名稱
spring:
cloud:
nacos:
discovery:
server-addr: localhost:88484.在服務接口層聲明使用Feign
使用FeignClient注解,聲明要調用的服務
// 聲明需要調用的服務
@FeignClient("service-provider")
public interface ProductService對方法使用GetMapping注解,配置需要調用的服務路由地址
// 配置需要調用的服務地址及參數
@GetMapping("/product/list")
List<Product> selectProductList();5.方法調用
在另一個impl里調用ProductService的方法,而不用關注ProductServiceImpl里面的實現邏輯,它會遠程請求生產者中controller里的方法.
/**
* 根據主鍵查詢訂單
*
* @param id
* @return
*/
@Override
public Order selectOrderById(Integer id) {
return new Order(id, "order-001", "中國", 22788D,
productService.selectProductList());
}消費者controller中的方法
/**
* 根據主鍵查詢訂單
*
* @param id
* @return
*/
@GetMapping("/{id}")
public Order selectOrderById(@PathVariable("id") Integer id) {
return orderService.selectOrderById(id);
}過postman調用 localhost:9090/order/2 結果,可以看到已經成功使用Feign進行了遠程調用,
并且同一個請求,返回兩個provider的不同結果,由此可知Feign也實現了負載均衡
4.ribbon負載均衡策略
在消費者配置文件中修改ribbon的負載均衡策略
service-provider: ribbon: NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule #配置規(guī)則 隨機 # NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RoundRobinRule #配置規(guī)則 輪詢 # NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RetryRule #配置規(guī)則 重試 # NFLoadBalancerRuleClassName: com.netflix.loadbalancer.WeightedResponseTimeRule #配置規(guī)則 響應時間權重 # NFLoadBalancerRuleClassName: com.netflix.loadbalancer.BestAvailableRule #配置規(guī)則 最空閑連接策略
5.Feign傳參
1.Get方法
使用 @PathVariable 注解或 @RequestParam 注解接收請求參數。
provider接口層ProductService.java
ProductService.java方法
/** * 根據主鍵查詢商品 * * @param id * @return */ Product selectProductById(Integer id); provider實現類ProductServiceImpl.java
ProductServiceImpl.java方法
/**
* 根據主鍵查詢商品
*
* @param id
* @return
*/
@Override
public Product selectProductById(Integer id) {
return new Product(id, "冰箱", 1, 2666D);
}provider的控制類ProductController.java
ProductController.java方法
/**
* 根據主鍵查詢商品
*
* @param id
* @return
*/
@GetMapping("/{id}")
public Product selectProductById(@PathVariable("id") Integer id) {
return productService.selectProductById(id);
}provider服務中，controller使用了(@PathVariable(“id”) Integer id) 進行參數接收
consumer的接口層ProductService.java
@GetMapping("/product/{id}")
Product selectProductById(@PathVariable("id") Integer id);consumer服務中，使用了(@PathVariable(“id”) Integer id) 進行參數接收,寫法類似于在controller中定義請求方法和定義參數
consumer的接口層OrderService.java
Order getOrderById(Integer id);
consumer的接口實現類OrderServiceImpl.java
@Override
public Order getOrderById(Integer id) {
return new Order(id, "order-003", "中國", 2666D,
Arrays.asList(productService.selectProductById(id)));
}consumer的控制類OrderController.java
@GetMapping("selectProductById/{id}")
public Order selectProductById(@PathVariable("id") Integer id) {
return orderService.getOrderById(id);
}訪問localhost:9090/order/selectProductById/888得到結果
Post方法
使用 @RequestBody 注解接收請求參數。
provider的ProductService.java
/** * 新增商品 * * @param product * @return */ Map<Object, Object> createProduct(Product product);
provider的ProductServiceImpl.java
/**
* 新增商品
*
* @param product
* @return
*/
@Override
public Map<Object, Object> createProduct(Product product) {
System.out.println(product.getProductName());
return new HashMap<Object, Object>() {{
put("code", 200);
put("message", "新增成功");
}};
}
provider的ProductController.java
/**
* 新增商品
*
* @param product
* @return
*/
@PostMapping("/save")
public Map<Object, Object> createProduct(@RequestBody Product product) {
return productService.createProduct(product);
}consumer的ProductService.java
/**
* 新增商品
*
* @param product
* @return
*/
@PostMapping("/product/save")
Map<Object, Object> createProduct(Product product);
consumer的OrderService.java
Map<Object, Object> createProduct(Product product);
consumer的OrderServiceImpl.java
@Override
public Map<Object, Object> createProduct(Product product) {
return productService.createProduct(product);
}consumer的OrderController.java
/**
* 新增商品
*
* @param product
* @return
*/
@PostMapping("/save")
public Map<Object, Object> createProduct(Product product) {
return orderService.createProduct(product);
}訪問http://localhost:9090/order/save 參數
id:6
productName:華為
productNum:1
productPrice:6666666
執(zhí)行結果
6.Feign 性能優(yōu)化
1.Gzip 壓縮
gzip 是一種數據格式，采用 deflate 算法壓縮數據；gzip 是一種流行的文件壓縮算法，應用十分廣泛，尤其是在 Linux 平臺。
2.gzip 能力
當 Gzip 壓縮一個純文本文件時，效果是非常明顯的，大約可以減少 70％ 以上的文件大小。
3.gzip 作用
網絡數據經過壓縮后實際上降低了網絡傳輸的字節(jié)數，最明顯的好處就是可以加快網頁加載的速度。網頁加載速度加快的好處不言而喻，除了節(jié)省流量，改善用戶的瀏覽體驗外，另一個潛在的好處是 Gzip 與搜索引擎的抓取工具有著更好的關系。例如 Google 就可以通過直接讀取 gzip 文件來比普通手工抓取更快地檢索網頁。
4.配置HTTP 連接池
4.1HTTP背景
兩臺服務器建立 HTTP 連接的過程是很復雜的一個過程，涉及到多個數據包的交換，很耗時間。
HTTP 連接需要的 3 次握手 4 次揮手開銷很大，這一開銷對于大量的比較小的 HTTP 消息來說更大。
4.2解決方案
采用 HTTP 連接池，可以節(jié)約大量的 3 次握手 4 次揮手，這樣能大大提升吞吐量。
Feign 的 HTTP 客戶端支持 3 種框架：HttpURLConnection、HttpClient、OkHttp；默認是 HttpURLConnection?？梢酝ㄟ^查看源碼 org.springframework.cloud.openfeign.ribbon.FeignRibbonClientAutoConfiguration.java 得知。
傳統(tǒng)的 HttpURLConnection 是 JDK 自帶的，并不支持連接池，如果要實現連接池的機制，還需要自己來管理連接對象。對于網絡請求這種底層相對復雜的操作，如果有可用的其他方案，沒有必要自己去管理連接對象。
HttpClient 相比傳統(tǒng) JDK 自帶的 HttpURLConnection，它封裝了訪問 HTTP 的請求頭，參數，內容體，響應等等；它不僅使客戶端發(fā)送 HTTP 請求變得容易，而且也方便了開發(fā)人員測試接口（基于 HTTP 協議的），既提高了開發(fā)的效率，又提高了代碼的健壯性；另外高并發(fā)大量的請求網絡的時候，也是用“連接池”提升吞吐量。
添加依賴
<dependency>
<groupId>io.github.openfeign</groupId>
<artifactId>feign-httpclient</artifactId>
<version>10.7.4</version>
</dependency>配置開啟連接池
feign:
httpclient:
enabled: true # 開啟 httpclient使用壓測工具檢測單線程 10000次請求網絡響應情況
圖1.未配置httpclient連接池.新建連接和關閉連接占用大量時間,端口被占用無法釋放.導致后來的連接無法被創(chuàng)建,增加程序異常幾率
圖2.配置httpClient連接池開啟,第一次交互會打開連接，交互結束后連接并不關閉，下次交互就省去了建立連接的過程
7.整合gateway網關服務
1.搭建gateway網關服務(略)
2.增加配置
server:
port: 8001 #網關端口
spring:
application:
name: nacos-gateway
cloud:
nacos:
discovery:
server-addr: localhost:8848 #注冊中心地址
config:
server-addr: localhost:8848 #配置中心地址 TODO配置中心讀取不到 需要調查原因
file-extension: yaml
gateway:
discovery:
locator:
enabled: true
lower-case-service-id: true
routes:
- id: nacos-gateway-provider
uri: lb://service-consumer #目標服務地址
predicates: #斷言
- Path=/**3.測試8001端口轉發(fā)是否正常
到此這篇關于springboot中使用Feign整合nacos,gateway進行微服務之間的調用方法的文章就介紹到這了,更多相關springboot Feign微服務調用內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！
相關文章
這篇文章主要介紹了解決使用IDEA時跳轉到.class的問題，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-08-08
MongoDB是一個文檔數據庫（以?JSON?為數據模型）,由C++語言編寫,旨在為WEB應用提供可擴展的高性能數據存儲解決方案,本文就給大家介紹一下詳細介紹一下springboot整合mongodb使用,需要的朋友可以參考下2023-07-07
SpringBoot中的starter是一種非常重要的機制，能夠拋棄以前繁雜的配置，將其統(tǒng)一集成進starter，應用者只需要在maven中引入starter依賴，SpringBoot就能自動掃描到要加載的信息并啟動相應的默認配置。starter讓我們擺脫了各種依賴庫的處理，需要配置各種信息的困擾2022-09-09
elasticsearch 8.2.3 安裝及springboot簡單使用
這篇文章主要介紹了elasticsearch 8.2.3 安裝及springboot簡單使用,本文通過示例代碼給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2023-06-06
項目當中經常需要接口參數是否在一個可選的范圍內,也就是驗證類枚舉參數的需求,所以本文我們將使用SpringBoot實現枚舉類型參數認證,文中有詳細的代碼示例,需要的朋友可以參考下2023-12-12
這篇文章主要介紹了Java使用建造者模式實現辦理手機套餐功能,較為詳細的描述了建造者模式的概念、原理并結合實例形式分析了Java使用建造者模式實現的辦理手機套餐功能具體步驟與相關操作注意事項,需要的朋友可以參考下2018-05-05
Web三大組件之Filter,Listener和Servlet詳解
這篇文章主要為大家詳細介紹了Web三大組件之Filter,Listener和Servlet，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下，希望能夠給你帶來幫助2022-03-03
solr 配置中文分析器/定義業(yè)務域/配置DataImport功能方法(測試用)
下面小編就為大家?guī)硪黄猻olr 配置中文分析器/定義業(yè)務域/配置DataImport功能方法(測試用)。小編覺得挺不錯的，現在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2017-09-09
下面小編就為大家?guī)硪黄赟pring中的線程池和定時任務功能解析。小編覺得挺不錯的，現在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2017-09-09
SpringBoot使用@Scheduled實現定時任務的并行執(zhí)行
在SpringBoot中,如果使用@Scheduled注解來定義多個定時任務,默認情況下這些任務將會被安排在一個單線程的調度器中執(zhí)行,這意味著,這些任務將會串行執(zhí)行,而不是并行執(zhí)行,本文介紹了SpringBoot使用@Scheduled實現定時任務的并行執(zhí)行,需要的朋友可以參考下2024-06-06