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

這篇“Feign怎么解決服務(wù)之間調(diào)用傳遞token”文章的知識(shí)點(diǎn)大部分人都不太理解，所以小編給大家總結(jié)了以下內(nèi)容，內(nèi)容詳細(xì)，步驟清晰，具有一定的借鑒價(jià)值，希望大家閱讀完這篇文章能有所收獲，下面我們一起來(lái)看看這篇“Feign怎么解決服務(wù)之間調(diào)用傳遞token”文章吧。

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

現(xiàn)在的微服務(wù)基本就是SpringSecurity+Oauth3做的授權(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ù)各種坑處理

編寫(xiě)被調(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)配置

編寫(xiě)調(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)題.

編寫(xiě)客戶端服務(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();
        }
    }

以上就是關(guān)于“Feign怎么解決服務(wù)之間調(diào)用傳遞token”這篇文章的內(nèi)容，相信大家都有了一定的了解，希望小編分享的內(nèi)容對(duì)大家有幫助，若想了解更多相關(guān)的知識(shí)內(nèi)容，請(qǐng)關(guān)注億速云行業(yè)資訊頻道。