快捷導(dǎo)航

Feign如何解決服務(wù)之間調(diào)用傳遞token

更新時(shí)間：2022年03月15日 14:44:58 作者：dalianpai

這篇文章主要介紹了Feign如何解決服務(wù)之間調(diào)用傳遞token，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教

解決服務(wù)之間調(diào)用傳遞token

現(xiàn)在的微服務(wù)基本就是SpringSecurity+Oauth2做的授權(quán)和認(rèn)證，假如多個(gè)服務(wù)直接要通過(guò)Fegin來(lái)調(diào)用，會(huì)報(bào)錯(cuò)401

a、有做權(quán)限處理的服務(wù)接口直接調(diào)用會(huì)造成調(diào)用時(shí)出現(xiàn)http 401未授權(quán)的錯(cuò)誤，繼而導(dǎo)致最終服務(wù)的http 500內(nèi)部服務(wù)器錯(cuò)誤
b、解決方式：最方便的就是往請(qǐng)求頭里加上token，一起帶過(guò)去；

Feign有提供一個(gè)接口RequestInterceptor

只要實(shí)現(xiàn)這個(gè)接口，簡(jiǎn)單做一些處理，比如說(shuō)我們驗(yàn)證請(qǐng)求頭的token叫Access-Token，我們就先取出當(dāng)前請(qǐng)求的token，然后放到feign請(qǐng)求頭上；

public class FeignConfig implements RequestInterceptor {
? ? ? ? @Override
? ? ? ? public void apply(RequestTemplate requestTemplate) {
? ? ? ? ? ? ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
? ? ? ? ? ? HttpServletRequest request = attributes.getRequest();
? ? ? ? ? ? //添加token
? ? ? ? ? ? requestTemplate.header(HttpHeaders.AUTHORIZATION, request.getHeader(HttpHeaders.AUTHORIZATION));
? ? ? ? }
? ? }

調(diào)用方式

? ? @FeignClient(name = "qtjuaa", configuration = FeignConfig.class)
? ? public interface UaaClient {
? ? ? ? @RequestMapping(value = "/api/test", method= RequestMethod.GET)
? ? ? ? String test();
? ? }

Feign調(diào)用服務(wù)各種坑處理

編寫被調(diào)用服務(wù)

@RefreshScope
@RestController
public class XXXController extends BaseController implements IndicatorsFeignApi{
	@Resource
	private XXXService xxx;
	@Override
	public Wrapper<CommonVo> getXXXX(@RequestBody CommonDto commonDto) {
		try {
			CommonVo vo = xxx.getdata(commonDto);
			return WrapMapper.ok(vo);
		}catch(Exception e) {
			e.printStackTrace();
			return WrapMapper.error("系統(tǒng)異常,請(qǐng)聯(lián)系管理員!");
		}
	}
}
//Service不進(jìn)行展示，注意參數(shù)傳遞至service層時(shí)要加入注解@RequestBody等才能獲取參數(shù)

在配置文件添加feign相關(guān)配置

編寫調(diào)用api

pom文件中添加相關(guān)依賴

org.springframework.cloud
spring-cloud-starter-hystrix
org.springframework.cloud
spring-cloud-starter-netflix-hystrix-dashboard

調(diào)用Api

@FeignClient(value = "被調(diào)用服務(wù)名")
public interface IndicatorsFeignApi {
	
	@PostMapping(value = "/api/getXXXX",consumes="application/json", headers = {"Accept=application/json", "Content-Type=application/json"})
	Wrapper<CommonVo> getXXXX(@RequestBody CommonDto commonDto);	
}

Feign調(diào)用錯(cuò)誤處理，發(fā)生相關(guān)錯(cuò)誤是會(huì)跳轉(zhuǎn)至fallback處理

@Component
public class IndicatorsFeignApiHystrix implements IndicatorsFeignApi {
	@Override
	public Wrapper<CommonVo> getXXXX(CommonDto commonDto) {
		System.out.println("=====調(diào)用服務(wù)獲數(shù)據(jù)發(fā)生異常======");
		return null;
	}
}

當(dāng)啟用fallback后，有些報(bào)錯(cuò)不會(huì)打印在控制臺(tái)上，這時(shí)可以修改配置中的

feign:
? hystrix:
? ? enabled: true

將enabled改為false，錯(cuò)誤發(fā)生后將不會(huì)跳轉(zhuǎn)fallback。

此處有一個(gè)坑，當(dāng)時(shí)調(diào)用的時(shí)候服務(wù)是可以調(diào)用成功的，但是有一個(gè)報(bào)錯(cuò)：

Could not extract response: no suitable HttpMessageConverter found for response type [XXXX] and content type [text/html;charset=UTF-8]

貌似是返回?cái)?shù)據(jù)的編碼與接收實(shí)體類不一樣，導(dǎo)致報(bào)錯(cuò)。加上headers = {"Accept=application/json", "Content-Type=application/json"}解決了相關(guān)問(wèn)題.

編寫客戶端服務(wù)

//serviceImp層
? ?@Autowired
?? ?private IndicatorsFeignApi api;//聲明調(diào)用api
?? ?
?? ?@Override
?? ?public CommonVo getXXX(CommonDto commonDto) {
?? ??? ?Wrapper<CommonVo> result = ? api.getXXXX(commonDto);//服務(wù)調(diào)用
?? ??? ?if(result!=null) {
?? ??? ??? ?return result.getResult();
?? ??? ?}else {
?? ??? ??? ?return new CommonVo();
?? ??? ?}
?? ?}

以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。

您可能感興趣的文章: