- 定义一个业务的过滤器
public class AuthFilter implements GlobalFilter, Ordered {
private static final Logger log = LoggerFactory.getLogger(AuthFilter.class);
@Override
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
exchange.getAttributes().put("start_time",System.currentTimeMillis());
....
@Override
public int getorder() {
return NettyWriteResponseFilter.WRITE_RESPONSE_FILTER_ORDER-2;
}
- 定义一个日志过滤器
Route route =(Route) exchange.getAttributes().get(ServerWebExchangeUtils.GATEWAY_ROUTE_ATTR);
//路由ID
String routeId = route.getId();
Long startTime = exchange.getAttribute("start_time");
//获取耗时时长
final long duration = System.currentTimeMillis() - (Objects.isNull(startTime)?0L:startTime);
ServerHttpRequest request = exchange.getRequest();
ServerHttpResponse response = exchange.getResponse();
//请求路径
String requestUri = request.getURI().getPath();
//请求方法
String method = request.getmethodValue();
//请求的url参数
String param = MapUtil.join(request.getQueryParams(), "&", "=");
//响应码
int respStatusCode= Objects.requireNonNull(response.getStatusCode()).value();
//respStatusCode|Method|Host|Path|Query|Time|server_id
log.info("{}|{}|{}|{}|{}|{}ms|{}",respStatusCode,method, request.getURI().getHost(),
requestUri,param,duration,routeId);
return chain.filter(exchange.mutate().request(request).build());
}
@Override
public int getorder() {
return NettyWriteResponseFilter.WRITE_RESPONSE_FILTER_ORDER-1;
}
- 打印样例
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 [email protected] 举报,一经查实,本站将立刻删除。