一、Feign是什么?
OpenFeign是Spring Cloud提供的一個聲明式的偽Hltp客戶端,它使得調(diào)用遠程服務(wù)就像調(diào)用本地服務(wù)一樣簡單,只需要創(chuàng)建一個接口并添加一個注解即可,Nacos很好的兼容了OpenFeign,OpenFeign默認集成了Ribbon,
所以在Nacos下使用OpenFeign默認就實現(xiàn)了負載均衡的效果。
二、使用步驟
1.消費方導(dǎo)入依賴
???c
org.springframework.cloud
spring-cloud-starter-openfeign
???
2.服務(wù)消費方的主程序啟動類添加注解,開啟@EnableFeignClients
@SpringBootApplication @MapperScan("com.csqf.mapper") @Import({ Swagger2Config.class, ControllerExceptionAdvice.class, }) @EnableFeignClients public class springcloud_share_6002 { public static void main(String[] args) { SpringApplication.run(springcloud_share_6002.class,args); } @Bean @LoadBalanced public RestTemplate restTemplate(){ return new RestTemplate(); } }
3.服務(wù)消費方 創(chuàng)建遠程調(diào)用接口
@Service @FeignClient("user-6001") public interface UserFeignService { @GetMapping("/api/user/{id}") public R getUserNameById(@PathVariable("id") Integer id); }
代碼如下(示例):
4.更改代碼后測試
@RestController @RequestMapping("/api/share") public class ShareContoller { @Autowired private ShareServiceImpl shareService; // @Autowired // private RestTemplate restTemplate; // @Autowired // private DiscoveryClient discoveryClient; @Autowired private UserFeignService userFeignService; @GetMapping("/{id}") public R getShareById(@PathVariable("id") Integer id) { Share share = shareService.getShareById(id); R r = userFeignService.getUserNameById(share.getUserId()); String s = r.getData().toString(); ShareDto shareDto = new ShareDto(); BeanUtils.copyProperties(share,shareDto); shareDto.setUserName(s); return new R(ResponseEnum.SUCCESS,shareDto); } }
補充
1.重試機制
1:如果所有的重試完成 還是失敗 要拋出 feign.RetryableException 異常 2: 重試 會產(chǎn)生接口的冪等性問題: 1:查詢的接口 天生是冪等的 2: 增刪改的處理 非冪等的
配置 | 說明 |
---|---|
hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds | 斷路器的超時時間需要大于ribbon的超時時間,不然不會觸發(fā)重試。 |
hello-service.ribbon.ConnectTimeout | 請求連接的超時時間 |
hello-service.ribbon.ReadTimeout | 請求處理的超時時間 |
hello-service.ribbon.OkToRetryOnAllOperations | 是否對所有操作請求都進行重試 |
hello-service.ribbon.MaxAutoRetriesNextServer | 重試負載均衡其他的實例最大重試次數(shù),不包括首次server |
2 遠程調(diào)用的時候出現(xiàn)異常的處理(ControllerExceptionAdvice)
@ExceptionHandler(RetryableException.class) @ResponseBody public R doException(RetryableException ex){ ex.printStackTrace(); // System.out.println("拋出未知異常"); return new R(ResponseEnum.FEIGN_RETRY,null); }
3.Feign的傳遞參數(shù)方式注意事項
如果你傳遞的參數(shù),比較復(fù)雜時,默認會采用POST的請求方式。
- 傳遞單個參數(shù)時,推薦使用@PathVariable,如果傳遞的單個參數(shù)比較多,這里也可以采用@RequestParam,不要省略value屬性
- 傳遞對象信息時,統(tǒng)一采用json的方式,添加@RequestBody。Client接口必須采用@RequestMapping
spring cloud項目使用feign的時候都會發(fā)現(xiàn)一個問題,就是get方式無法解析對象參數(shù)。其實feign是支持對象傳遞的,但是得是Map形式,而且不能為空,與spring在機制上不兼容,因此無法使用。
spring cloud在2.1.x版本中提供了@SpringQueryMap注解,可以傳遞對象參數(shù),框架自動解析。
調(diào)用方feign接口只能是 | 被調(diào)用方接口 |
---|---|
public R f1(User user) 或 public R f1(@RequestBoby User user) | 參數(shù) @RequstBoby 對象 |
public R f1(@SpringQueryMap User user) | 參數(shù) 對象 |
總結(jié)
FEIGN 集成ribbon 和 resttemplate,簡化 服務(wù)之間的調(diào)用
Feign是通過內(nèi)置的Ribbon進行負載均衡,并通過HTTP去訪問被調(diào)用方,所以Feign的重試,其實就是Ribbon的重試。另外,我們在實際工作中使用Feign,用到Hystrix,在這里就順便說一下Hystrix的原理。舉例說明下,假如在沒有Hystrix的情況下,用戶一個下單操作需要調(diào)用訂單、支付、物流三個服務(wù),如果其中物流Service因為種種問題不能提供服務(wù),即便另外兩個服務(wù)都好好的,整個下單操作也會因為物流Service而阻塞住,導(dǎo)致下單服務(wù)崩潰。而Hystrix為每個依賴的服務(wù)配置獨立的線程池并進行隔離,假設(shè)下單服務(wù)有90個線程,沒有Hystrix,則因為物流Service不能提供服務(wù),不停地重試直到90個線程全卡死。而有了Hystrix,三個依賴的服務(wù),每個30個線程,即便物流的30個全部阻塞了,也不影響另外兩個服務(wù)的線程。
到此這篇關(guān)于Java之Springcloud Feign組件詳解的文章就介紹到這了,更多相關(guān)Java之Springcloud Feign內(nèi)容請搜索服務(wù)器之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持服務(wù)器之家!
原文鏈接:https://blog.csdn.net/weixin_56219549/article/details/119512946