Kri*_*ish 7 spring-mvc spring-boot microservices netflix-eureka netflix-zuul
我使用Spring boot zuul和eureka服务配置了我的微服务.现在我需要验证所有路由/ REST API调用.我的意思是,对于所有API客户端发送一个accessToken.在zuul服务上,在路由到特定服务之前,我必须使用accessToken调用微服务(auth-service),并且auth-service将检查用户是否存在以便发送accessToken.如果accessToken有效,则只应进行路由.
请帮我用Spring Boot服务实现这个.
谢谢.
您需要编写一个过滤器。zuul 预过滤器是您所需要的。您可以在过滤器中访问身份验证服务器,如果令牌无效,则不调用微服务并立即返回响应。如果有效,则让该请求进入微服务。
一个示例过滤器类:
public class AuthFilter extends ZuulFilter {
@Autowired
RestTemplate restTemplate;
@Override
public String filterType() {
return "pre";
}
@Override
public int filterOrder() {
return 1;
}
@Override
public boolean shouldFilter() {
return true;
}
@Override
public Object run() {
RequestContext ctx = RequestContext.getCurrentContext();
//get your token from request context and send it to auth service via rest template
boolean validToken = restTemplate.exchange(or getForObject or other methods of restTemplate which you find suitable for method and return type of your auth service controller method)
if(!validToken) {
ctx.setSendZuulResponse(false); //This makes request not forwarding to micro services
ctx.setResponseStatusCode(HttpStatus.UNAUTHORIZED.value());
ValidationResponse validationResponse = new ValidationResponse();
validationResponse.setSuccess(false);
validationResponse.setMessage("Invalid Access...");
ObjectMapper mapper = new ObjectMapper();
String responseBody = mapper.writeValueAsString(validationResponse);
ctx.setResponseBody(validationResponse);
ctx.getResponse().setContentType("application/json");
//If you want to do any thing else like logging etc, you can do it.
}
return null;
}
}
Run Code Online (Sandbox Code Playgroud)
| 归档时间: |
|
| 查看次数: |
2406 次 |
| 最近记录: |