- 思考: 使用RestTemplate+ribbon已經可以完成服務間的呼叫，為什么還要使用feign？
String restTemplateForObject = restTemplate.getForObject("http://服務名/url?引數" + name, String.class);
存在問題:
- 1.每次呼叫服務都需要寫這些代碼,存在大量的代碼冗余
- 2.服務地址如果修改,維護成本增高
- 3.使用時不夠靈活
說明
- https://cloud.spring.io/spring-cloud-openfeign/reference/html/
- Feign是一個宣告式的偽Http客戶端，它使得寫Http客戶端變得更簡單，使用Feign，只需要創建一個介面并注解，它具有可插拔的注解特性(可以使用springmvc的注解)，可使用Feign 注解和JAX-RS注解，Feign支持可插拔的編碼器和解碼器，Feign默認集成了Ribbon，默認實作了負載均衡的效果并且springcloud為feign添加了springmvc注解的支持，
1.openFeign 服務呼叫
還是在上一個專案的基礎之上，在users專案中
1.服務呼叫方法引入依賴OpenFeign依賴
<!--Open Feign依賴-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
2.入口類加入注解開啟OpenFeign支持
@SpringBootApplication
@EnableFeignClients //開啟openfeign支持
public class Users9999Application {
public static void main(String[] args) {
SpringApplication.run(Users9999Application.class, args);
}
}
3.創建一個客戶端呼叫介面
// 此時的product專案中的方法
@RestController
@Slf4j
public class ProductController {
@Value("${server.port}")
private int port;
@GetMapping("/product/findAll")
public Map<String, Object> findAll(){
log.info("商品服務呼叫成功，當前的服務埠：[{}]",port);
HashMap<String, Object> map = new HashMap<>();
map.put("msg","服務呼叫成功，服務提供的埠為："+port);
map.put("status",true);
return map;
}
}
//--------------------------------------------------------------------
package com.md.clients;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
/**
* @author md
* @Desc 呼叫商品服務的組件
* @date 2020/12/9 15:30
*/
// 指定當前的介面是openfeign組件，value是呼叫的服務名
@FeignClient("products")
public interface ProductClient {
@GetMapping("/product/findAll")
String findAll();
}
4.使用feignClient客戶端物件呼叫服務
@RestController
@Slf4j
public class UserController {
//注入客戶端物件
@Autowired
private ProductClient productClient;
@GetMapping("/user/findAllFeignClient")
public String findAllFeignClient(){
log.info("通過使用OpenFeign組件呼叫商品服務...");
String msg = productClient.findAll();
return msg;
}
}
5.訪問并測驗服務
- http://localhost:9999/user/findAllFeignClient
2.呼叫服務并傳參
- 服務和服務之間通信,不僅僅是呼叫,往往在呼叫程序中還伴隨著引數傳遞,接下來重點來看看OpenFeign在呼叫服務時如何傳遞引數
3.GET方式呼叫服務傳遞引數
- 在商品服務中加入需要傳遞引數的服務方法來進行測驗
- 在用戶服務中進行呼叫商品服務中需要傳遞引數的服務方法進行測驗
1.商品服務中添加如下方法
@GetMapping("/product/findOne")
public Map<String,Object> findOne(String productId){
log.info("商品服務查詢商品資訊呼叫成功,當前服務埠:[{}]",port);
log.info("當前接收商品資訊的id:[{}]",productId);
Map<String, Object> map = new HashMap<String,Object>();
map.put("msg","商品服務查詢商品資訊呼叫成功,當前服務埠: "+port);
map.put("status",true);
map.put("productId",productId);
return map;
}
2.用戶服務中在product客戶端中宣告方法
//
@FeignClient("products")
public interface ProductClient {
@GetMapping("/product/findOne")
Map<String, Object> findOne(@RequestParam("productId") String productId);
}
注意：使用openfeign的get方式傳遞引數，引數變數必須通過@RequestParam注解進行修飾
3.用戶服務中呼叫并傳遞引數
//
//注入客戶端物件
@RestController
@Slf4j
public class UserController {
@Autowired
private ProductClient productClient;
@GetMapping("/user/findOne")
public Map<String, Object> findOne(String productId){
log.info("用來測驗Openfiegn的GET方式引數傳遞");
Map<String, Object> msg = productClient.findOne(productId);
log.info("呼叫回傳資訊:[{}]",msg);
return msg;
}
}
4.測驗訪問
4.post方式呼叫服務傳遞引數
- 在商品服務中加入需要傳遞引數的服務方法來進行測驗
- 在用戶服務中進行呼叫商品服務中需要傳遞引數的服務方法進行測驗
1.商品服務加入post方式請求并接受name
@PostMapping("/product/save")
public Map<String,Object> save(String name){
log.info("商品服務保存商品呼叫成功,當前服務埠:[{}]",port);
log.info("當前接收商品名稱:[{}]",name);
Map<String, Object> map = new HashMap<String,Object>();
map.put("msg","商品查詢服務完成當前服務埠: "+port);
map.put("status",true);
map.put("name",name);
return map;
}
2.用戶服務中在product客戶端中宣告方法
//value屬性用來指定:呼叫服務名稱
@FeignClient("products")
public interface ProductClient {
@PostMapping("/product/save")
String save(@RequestParam("name") String name);
}
3.用戶服務中呼叫并傳遞引數
@Autowired
private ProductClient productClient;
@PostMapping("/user/save")
public Map<String, Object> save(String productName){
log.info("接收到的商品資訊名稱:[{}]",productName);
Map<String, Object> map = productClient.save(productName);
log.info("呼叫成功回傳結果: "+map);
return map;
}
4.測驗訪問
5.傳遞物件型別引數
- 商品服務定義物件
- 商品服務定義物件接收方法
- 用戶服務呼叫商品服務定義物件引數方法進行引數傳遞
//1.商品服務定義物件
@Data
public class Product {
private Integer id;
private String name;
private Date bir;
}
//2.商品服務定義接收物件的方法
@PostMapping("/product/saveProduct")
public Map<String,Object> saveProduct(@RequestBody Product product){
log.info("商品服務保存商品資訊呼叫成功,當前服務埠:[{}]",port);
log.info("當前接收商品名稱:[{}]",product);
Map<String, Object> map = new HashMap<String,Object>();
map.put("msg","商品服務查詢商品資訊呼叫成功,當前服務埠: "+port);
map.put("status",true);
map.put("product",product);
return map;
}
//3.將商品物件復制到用戶服務中
// 先階段先這樣用著
//4.用戶服務中在product客戶端中宣告方法
@FeignClient("products")
public interface ProductClient {
@PostMapping("/product/saveProduct")
String saveProduct(@RequestBody Product product);
}
//注意:服務提供方和呼叫方一定要加入@RequestBody注解
注意:服務提供方和呼叫方一定要加入@RequestBody注解
// 5.在用戶服務中呼叫保存商品資訊服務
//注入客戶端物件
@Autowired
private ProductClient productClient;
@PostMapping("/user/saveProduct")
public Map<String, Object> saveProduct(Product product){
log.info("接收到的商品資訊:[{}]",product);
Map<String, Object> map = productClient.saveProduct(product);
log.info("呼叫成功回傳結果: "+map);
return map;
}
測驗
5.OpenFeign超時設定
1.超時說明
- 默認情況下,openFiegn在進行服務呼叫時,要求服務提供方處理業務邏輯時間必須在1S內回傳,如果超過1S沒有回傳則OpenFeign會直接報錯,不會等待服務執行,但是往往在處理復雜業務邏輯是可能會超過1S,因此需要修改OpenFeign的默認服務呼叫超時時間，
2.模擬超時
- 服務提供方加入執行緒等待阻塞
3.進行客戶端呼叫
4.修改OpenFeign默認超時時間
# 這里的PRODUCTS使用的是大寫的方法
feign.client.config.PRODUCTS.connectTimeout=5000 #配置指定服務連接超時
feign.client.config.PRODUCTS.readTimeout=5000 #配置指定服務等待超時
#feign.client.config.default.connectTimeout=5000 #配置所有服務連接超時
#feign.client.config.default.readTimeout=5000 #配置所有服務等待超時
6.OpenFeign呼叫詳細日志展示
0.說明
- 往往在服務呼叫時我們需要詳細展示feign的日志,默認feign在呼叫是并不是最詳細日志輸出,因此在除錯程式時應該開啟feign的詳細日志展示，feign對日志的處理非常靈活可為每個feign客戶端指定日志記錄策略，每個客戶端都會創建一個logger默認情況下logger的名稱是feign的全限定名需要注意的是，feign日志的列印只會DEBUG級別做出回應，
- 我們可以為feign客戶端配置各自的logger.level物件，告訴feign記錄那些日志logger.lever有以下的幾種值
NONE 不記錄任何日志BASIC 僅僅記錄請求方法，url，回應狀態代碼及執行時間
HEADERS 記錄Basic級別的基礎上，記錄請求和回應的headerFULL 記錄請求和回應的header，body和元資料
1.開啟日志展示
# 這里的PRODUCTS使用的是大寫的方法
feign.client.config.PRODUCTS.loggerLevel=full #開啟指定服務日志展示
#feign.client.config.default.loggerLevel=full #全域開啟服務日志展示
logging.level.com.baizhi.feignclients=debug #指定feign呼叫客戶端物件所在包,必須是debug級別
2.測驗服務呼叫查看日志
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/232283.html
標籤：Java
下一篇：關閉 IDEA 自動更新