Feign如何解决服务之间调用传递token

网友投稿 334 2022-08-20


Feign如何解决服务之间调用传递token

目录解决服务之间调用传递tokenFeign有提供一个接口RequestInterceptor调用方式Feign调用服务各种坑处理编写被调用服务编写调用api编写客户端服务

解决服务之间调用传递token

现在的微服务基本就是SpringSecurity+Oauth2做的授权和认证,假如多个服务直接要通过Fegin来调用,会报错401

a、有做权限处理的服务接口直接调用会造成调用时出现http 401未授权的错误,继而导致最终服务的http 500内部服务器错误b、解决方式:最方便的就是往请求头里加上token,一起带过去;

Feign有提供一个接口RequestInterceptor

只要实现这个接口,简单做一些处理,比如说我们验证请求头的token叫Access-Token,我们就先取出当前请求的token,然后放到feign请求头上;

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));

}

}

调用方式

@FeignClient(name = "qtjuaa", configuration = FeignConfig.class)

public interface UaaClient {

@RequestMapping(value = "/api/test", method= RequestMethod.GET)

String test();

}

Feign调用服务各种坑处理

编写被调用服务

@RefreshScope

@RestController

public class XXXController extends BaseController implements Indicatorhttp://sFeignApi{

@Resource

private XXXService xxx;

@Override

public Wrapper 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文件中添加相关依赖

org.springframework.cloud

spring-cloud-starter-hystrix

org.springframework.cloud

spring-cloud-starter-netflix-hystrix-dashboard

调用Api

@FeignaMzcGUClient(value = "被调用服务名")

public interface IndicatorsFeignApi {

@PostMapping(value = "/api/getXXXX",consumes="application/json", headers = {"Accept=application/json", "Content-Type=application/json"})

Wrapper getXXXX(@RequestBody CommonDto commonDto);

}

Feign调用错误处理,发生相关错误是会跳转至fallback处理

@Component

public class IndicatorsFeignApiHystrix implements IndicatorsFeignApi {

@Override

public Wrapper getXXXX(CommonDto commonDto) {

System.out.println("=====调用服务获数据发生异常======");

return null;

}

}

当启用fallback后,有些报错不会打印在控制台上,这时可以修改配置中的

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"}解决了相关问题.

编写客户端服务

//serviceImp层

@Autowired

private IndicatorsFeignApi api;//声明调用api

@Override

public CommonVo getXXX(CommonDto commonDto) {

Wrapper result = api.getXXXX(commonDto);//服务调用

if(result!=null) {

return result.getResult();

}else {

return new CommonVo();

}

}


版权声明:本文内容由网络用户投稿,版权归原作者所有,本站不拥有其著作权,亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容,请联系我们jiasou666@gmail.com 处理,核实后本网站将在24小时内删除侵权内容。

上一篇:springboot 实现接口灰度发布的实例详解
下一篇:Java的内存区域与内存溢出异常你了解吗
相关文章

 发表评论

暂时没有评论,来抢沙发吧~