解决服务之间调用传递token
现在的微服务基本就是SpringSecurity+Oauth2做的授权和认证,假如多个服务直接要通过Fegin来调用,会报错401
- a、有做权限处理的服务接口直接调用会造成调用时出现http 401未授权的错误,继而导致最终服务的http 500内部服务器错误
- b、解决方式:最方便的就是往请求头里加上token,一起带过去;
Feign有提供一个接口RequestInterceptor
只要实现这个接口,简单做一些处理,比如说我们验证请求头的token叫Access-Token,我们就先取出当前请求的token,然后放到feign请求头上;
1
2
3
4
5
6
7
8
9
|
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)); } } |
调用方式
1
2
3
4
5
|
@FeignClient (name = "qtjuaa" , configuration = FeignConfig. class ) public interface UaaClient { @RequestMapping (value = "/api/test" , method= RequestMethod.GET) String test(); } |
Feign调用服务各种坑处理
编写被调用服务
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
|
@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( "系统异常,请联系管理员!" ); } } } //Service不进行展示,注意参数传递至service层时要加入注解@RequestBody等才能获取参数 |
在配置文件添加feign相关配置
编写调用api
pom文件中添加相关依赖
1
2
3
4
|
org.springframework.cloud spring-cloud-starter-hystrix org.springframework.cloud spring-cloud-starter-netflix-hystrix-dashboard |
调用Api
1
2
3
4
5
6
|
@FeignClient (value = "被调用服务名" ) 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调用错误处理,发生相关错误是会跳转至fallback处理
1
2
3
4
5
6
7
8
|
@Component public class IndicatorsFeignApiHystrix implements IndicatorsFeignApi { @Override public Wrapper<CommonVo> getXXXX(CommonDto commonDto) { System.out.println( "=====调用服务获数据发生异常======" ); return null ; } } |
当启用fallback后,有些报错不会打印在控制台上,这时可以修改配置中的
1
2
3
|
feign: hystrix: enabled: true |
将enabled改为false,错误发生后将不会跳转fallback。
此处有一个坑,当时调用的时候服务是可以调用成功的,但是有一个报错:
Could not extract response: no suitable HttpMessageConverter found for response type [XXXX] and content type [text/html;charset=UTF-8]
貌似是返回数据的编码与接收实体类不一样,导致报错。加上headers = {"Accept=application/json", "Content-Type=application/json"}解决了相关问题.
编写客户端服务
1
2
3
4
5
6
7
8
9
10
11
12
13
|
//serviceImp层 @Autowired private IndicatorsFeignApi api; //声明调用api @Override public CommonVo getXXX(CommonDto commonDto) { Wrapper<CommonVo> result = api.getXXXX(commonDto); //服务调用 if (result!= null ) { return result.getResult(); } else { return new CommonVo(); } } |
以上为个人经验,希望能给大家一个参考,也希望大家多多支持服务器之家。
原文链接:https://dalianpai.blog.csdn.net/article/details/104708854