Feign服务间调用传递token

时间:2022-05-28 dalianpai 人气:2

解决服务之间调用传递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 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文件中添加相关依赖

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

调用Api

@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处理

@Component
public class IndicatorsFeignApiHystrix implements IndicatorsFeignApi {
	@Override
	public Wrapper<CommonVo> 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<CommonVo> result =   api.getXXXX(commonDto);//服务调用
        if(result!=null) {
            return result.getResult();
        }else {
            return new CommonVo();
        }
    }

以上为个人经验，希望能给大家一个参考，也希望大家多多支持。

加载全部内容