sczx_group/sczx_gateway
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

尝试网关路由打印

Browse Source
This commit is contained in:
zhangli
2025-09-08 18:10:01 +08:00
parent 35b3cbfdc0
commit 884967423f
3 changed files with 38 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/com/sczx/gateway/filter/LoggingGlobalFilter.java
View File

@ -29,7 +29,7 @@ import java.util.UUID;
* 适用于 Spring Boot 2.3.x + Spring Cloud Hoxton.SR12 环境。
*/
@Slf4j
@Component
//@Component
public class LoggingGlobalFilter implements GlobalFilter, Ordered {
@Override

2
src/main/java/com/sczx/gateway/filter/RequestLogGlobalFilter.java
View File

@ -22,7 +22,7 @@ import java.util.LinkedHashSet;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
//@Configuration
@Configuration
@Slf4j
public class RequestLogGlobalFilter implements GlobalFilter, Ordered {

48
src/main/java/com/sczx/gateway/filter/ResponseLogGlobalFilter.java
View File

@ -23,45 +23,54 @@ import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
import java.nio.charset.StandardCharsets;
import java.util.ArrayList;
import java.util.List;
@Slf4j
//@Configuration
@Configuration
public class ResponseLogGlobalFilter implements GlobalFilter, Ordered {
@Override
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
try {
ServerHttpResponse originalResponse = exchange.getResponse();
DataBufferFactory bufferFactory = originalResponse.bufferFactory();
HttpStatus statusCode = originalResponse.getStatusCode();
// 排除特定路径，避免处理Swagger等静态资源
String path = exchange.getRequest().getURI().getPath();
if (path.contains("/v2/api-docs") ||
path.contains("/swagger") ||
path.contains("/webjars")) {
return chain.filter(exchange);
}
if (statusCode != HttpStatus.OK) {
return chain.filter(exchange);//降级处理返回数据
}
ServerHttpResponseDecorator decoratedResponse = new ServerHttpResponseDecorator(originalResponse) {
@Override
public Mono<Void> writeWith(Publisher<? extends DataBuffer> body) {
if (body instanceof Flux) {
Flux<? extends DataBuffer> fluxBody = Flux.from(body);
return super.writeWith(fluxBody.buffer().map(dataBuffers -> {
return super.writeWith(fluxBody.map(dataBuffer -> {
// 复制数据以避免修改原始缓冲区
byte[] content = new byte[dataBuffer.readableByteCount()];
dataBuffer.read(content);
DataBufferUtils.release(dataBuffer);
// 合并多个流集合，解决返回体分段传输
DataBufferFactory dataBufferFactory = new DefaultDataBufferFactory();
DataBuffer buff = dataBufferFactory.join(dataBuffers);
byte[] content = new byte[buff.readableByteCount()];
buff.read(content);
DataBufferUtils.release(buff);//释放掉内存
//排除Excel导出，不是application/json不打印。若请求是上传图片则在最上面判断。
// 排除Excel导出，不是application/json不打印。若请求是上传图片则在最上面判断。
MediaType contentType = originalResponse.getHeaders().getContentType();
if (!MediaType.APPLICATION_JSON.isCompatibleWith(contentType)) {
if (contentType == null || !MediaType.APPLICATION_JSON.isCompatibleWith(contentType)) {
return bufferFactory.wrap(content);
}
// 构建返回日志
String joinData = new String(content);
String joinData = new String(content, StandardCharsets.UTF_8);
String result = modifyBody(joinData);
List<Object> rspArgs = new ArrayList<>();
rspArgs.add(originalResponse.getStatusCode().value());
@ -69,8 +78,8 @@ public class ResponseLogGlobalFilter implements GlobalFilter, Ordered {
rspArgs.add(result);
log.info("<-- {} {}\n{}", rspArgs.toArray());
getDelegate().getHeaders().setContentLength(result.getBytes().length);
return bufferFactory.wrap(result.getBytes());
// 返回处理后的内容
return bufferFactory.wrap(result.getBytes(StandardCharsets.UTF_8));
}));
} else {
log.error("<-- {} 响应code异常", getStatusCode());
@ -88,14 +97,23 @@ public class ResponseLogGlobalFilter implements GlobalFilter, Ordered {
@Override
public int getOrder() {
return Ordered.HIGHEST_PRECEDENCE;
// 设置较低优先级，确保在其他过滤器之后执行
return Ordered.LOWEST_PRECEDENCE - 1;
}
//返回统一的JSON日期数据 2024-02-23 11:00， null转空字符串
private String modifyBody(String jsonStr){
if (jsonStr == null || jsonStr.isEmpty()) {
return jsonStr;
}
try {
JSONObject json = JSON.parseObject(jsonStr, Feature.AllowISO8601DateFormat);
JSONObject.DEFFAULT_DATE_FORMAT = "yyyy-MM-dd HH:mm";
return JSONObject.toJSONString(json, (ValueFilter) (object, name, value) -> value == null ? "" : value, SerializerFeature.WriteDateUseDateFormat);
} catch (Exception e) {
// 如果不是有效的JSON，直接返回原始字符串
return jsonStr;
}
}
}