ContiNew/continew-starter
1
1
Fork 0
mirror of https://github.com/continew-org/continew-starter.git synced 2025-09-09 20:57:23 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(log/httptrace-pro): 修复 IP 配置解析错误，并缩小日志异常影响范围

Browse Source
This commit is contained in:
Charles7c
2023-12-21 20:57:33 +08:00
parent e0e5944b45
commit 2a70a9a252
3 changed files with 26 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
continew-starter-core/src/main/java/top/charles7c/continew/starter/core/autoconfigure/project/ProjectProperties.java
View File

@@ -82,8 +82,8 @@ public class ProjectProperties {
public static final boolean IP_ADDR_LOCAL_PARSE_ENABLED; public static final boolean IP_ADDR_LOCAL_PARSE_ENABLED;
static { static {
String underlineCaseProperty = SpringUtil.getProperty("ip-addr-local-parse-enabled"); String underlineCaseProperty = SpringUtil.getProperty("project.ip-addr-local-parse-enabled");
String camelCaseProperty = SpringUtil.getProperty("ipAddrLocalParseEnabled"); String camelCaseProperty = SpringUtil.getProperty("project.ipAddrLocalParseEnabled");
IP_ADDR_LOCAL_PARSE_ENABLED = Convert.toBool(underlineCaseProperty, false) || Convert.toBool(camelCaseProperty, false); IP_ADDR_LOCAL_PARSE_ENABLED = Convert.toBool(underlineCaseProperty, false) || Convert.toBool(camelCaseProperty, false);
} }

9
continew-starter-core/src/main/java/top/charles7c/continew/starter/core/util/IpUtils.java
View File

@@ -16,7 +16,9 @@
package top.charles7c.continew.starter.core.util; package top.charles7c.continew.starter.core.util;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.net.NetUtil; import cn.hutool.core.net.NetUtil;
import cn.hutool.core.util.StrUtil;
import cn.hutool.extra.spring.SpringUtil; import cn.hutool.extra.spring.SpringUtil;
import cn.hutool.http.HtmlUtil; import cn.hutool.http.HtmlUtil;
import cn.hutool.http.HttpUtil; import cn.hutool.http.HttpUtil;
@@ -28,6 +30,9 @@ import lombok.extern.slf4j.Slf4j;
import net.dreamlu.mica.ip2region.core.Ip2regionSearcher; import net.dreamlu.mica.ip2region.core.Ip2regionSearcher;
import net.dreamlu.mica.ip2region.core.IpInfo; import net.dreamlu.mica.ip2region.core.IpInfo;
import top.charles7c.continew.starter.core.autoconfigure.project.ProjectProperties; import top.charles7c.continew.starter.core.autoconfigure.project.ProjectProperties;
import top.charles7c.continew.starter.core.constant.StringConstants;
import java.util.Set;
/** /**
* IP 工具类 * IP 工具类
@@ -86,7 +91,9 @@ public class IpUtils {
Ip2regionSearcher ip2regionSearcher = SpringUtil.getBean(Ip2regionSearcher.class); Ip2regionSearcher ip2regionSearcher = SpringUtil.getBean(Ip2regionSearcher.class);
IpInfo ipInfo = ip2regionSearcher.memorySearch(ip); IpInfo ipInfo = ip2regionSearcher.memorySearch(ip);
if (null != ipInfo) { if (null != ipInfo) {
return ipInfo.getAddress(); Set<String> regionSet = CollUtil.newLinkedHashSet(ipInfo.getAddress(), ipInfo.getIsp());
regionSet.removeIf(StrUtil::isBlank);
return String.join(StringConstants.SPACE, regionSet);
} }
return null; return null;
} }

28
continew-starter-log/continew-starter-log-httptrace-pro/src/main/java/top/charles7c/continew/starter/log/httptracepro/handler/LogInterceptor.java
View File

@@ -69,19 +69,23 @@ public class LogInterceptor implements HandlerInterceptor {
timestampTtl.remove(); timestampTtl.remove();
Set<Include> includeSet = properties.getInclude(); Set<Include> includeSet = properties.getInclude();
RecordableServletHttpRequest sourceRequest = new RecordableServletHttpRequest(request); RecordableServletHttpRequest sourceRequest = new RecordableServletHttpRequest(request);
LogRecord.Started startedLogRecord = LogRecord.start(timestamp, sourceRequest); try {
RecordableServletHttpResponse sourceResponse = new RecordableServletHttpResponse(response, response.getStatus()); LogRecord.Started startedLogRecord = LogRecord.start(timestamp, sourceRequest);
LogRecord finishedLogRecord = startedLogRecord.finish(sourceResponse, includeSet); RecordableServletHttpResponse sourceResponse = new RecordableServletHttpResponse(response, response.getStatus());
HandlerMethod handlerMethod = (HandlerMethod) handler; LogRecord finishedLogRecord = startedLogRecord.finish(sourceResponse, includeSet);
if (includeSet.contains(Include.DESCRIPTION)) { HandlerMethod handlerMethod = (HandlerMethod) handler;
// 记录日志描述 if (includeSet.contains(Include.DESCRIPTION)) {
this.logDescription(finishedLogRecord, handlerMethod); // 记录日志描述
this.logDescription(finishedLogRecord, handlerMethod);
}
if (includeSet.contains(Include.MODULE)) {
// 记录所属模块
this.logModule(finishedLogRecord, handlerMethod);
}
dao.add(finishedLogRecord);
} catch (Exception ex) {
log.error("Logging http log occurred an error: {}.", ex.getMessage(), ex);
} }
if (includeSet.contains(Include.MODULE)) {
// 记录所属模块
this.logModule(finishedLogRecord, handlerMethod);
}
dao.add(finishedLogRecord);
} }
/** /**