package com.kidgrow.zuul.filter;
|
|
import com.netflix.zuul.ZuulFilter;
|
import com.netflix.zuul.context.RequestContext;
|
import com.netflix.zuul.exception.ZuulException;
|
import com.kidgrow.zuul.service.AccessLogService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.cloud.netflix.zuul.filters.support.FilterConstants;
|
|
import javax.servlet.http.HttpServletRequest;
|
import javax.servlet.http.HttpServletResponse;
|
|
/**
|
* 石家庄喜高科技有限责任公司 版权所有 © Copyright 2020<br>
|
*
|
* @Description: zuul代理后响应处理器<br>
|
* @Project: <br>
|
* @CreateDate: Created in 2020/2/4 14:49 <br>
|
* @Author: <a href="4345453@kidgrow.com">liuke</a>
|
*/
|
@Slf4j
|
public class ZuulResponseFilter extends ZuulFilter {
|
|
private AccessLogService accessLogService;
|
|
public ZuulResponseFilter(AccessLogService accessLogService) {
|
this.accessLogService = accessLogService;
|
}
|
|
/**
|
* 过滤器类型
|
* 顺序: pre ->routing -> post ,以上3个顺序出现异常时都可以触发error类型的filter
|
*/
|
@Override
|
public String filterType() {
|
return FilterConstants.POST_TYPE;
|
}
|
|
/**
|
* 同filterType类型中,order值越大,优先级越低
|
*/
|
@Override
|
public int filterOrder() {
|
return FilterConstants.SEND_RESPONSE_FILTER_ORDER + 2;
|
}
|
|
|
/**
|
* 是否应该执行该过滤器,如果是false,则不执行该filter
|
*/
|
@Override
|
public boolean shouldFilter() {
|
return true;
|
}
|
|
@Override
|
public Object run() throws ZuulException {
|
// 代理后响应日志处理
|
RequestContext ctx = RequestContext.getCurrentContext();
|
HttpServletRequest request = ctx.getRequest();
|
HttpServletResponse response = ctx.getResponse();
|
// 把路由的serviceId放入作用域
|
request.setAttribute(FilterConstants.SERVICE_ID_KEY, ctx.get(FilterConstants.SERVICE_ID_KEY));
|
accessLogService.sendLog(request, response,null);
|
return null;
|
}
|
}
|