From 35d8c09fd1ea3f72684c5921939fa20c92bd330b Mon Sep 17 00:00:00 2001
From: cl <1442464845@qq.com>
Date: 星期二, 12 五月 2026 13:18:29 +0800
Subject: [PATCH] #
---
rsf-http-audit/src/main/java/com/vincent/rsf/httpaudit/props/HttpAuditProperties.java | 39 +++++++++++++++++++++++++++++++++++++++
1 files changed, 39 insertions(+), 0 deletions(-)
diff --git a/rsf-http-audit/src/main/java/com/vincent/rsf/httpaudit/props/HttpAuditProperties.java b/rsf-http-audit/src/main/java/com/vincent/rsf/httpaudit/props/HttpAuditProperties.java
index 912ee46..b744b41 100644
--- a/rsf-http-audit/src/main/java/com/vincent/rsf/httpaudit/props/HttpAuditProperties.java
+++ b/rsf-http-audit/src/main/java/com/vincent/rsf/httpaudit/props/HttpAuditProperties.java
@@ -3,7 +3,9 @@
import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
+import java.time.Duration;
import java.util.ArrayList;
+import java.util.Collections;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
@@ -16,6 +18,15 @@
public class HttpAuditProperties {
private boolean enabled = true;
+
+ /** 1 鏁版嵁搴� 2 OpenSearch 3 鍙屽啓锛涙湭濉垨鍏跺畠鍊煎悓 1 */
+ private int logStorageMode = 1;
+
+ /** 浠� 2銆�3 浣跨敤 */
+ private OpenSearch openSearch = new OpenSearch();
+
+ /** 浠� 1銆�3锛涙棤澶氭暟鎹簮鍙渷鐣� */
+ private String datasource = "primary";
/** 鏄惁娉ㄥ唽 /httpAuditRule銆�/httpAuditLog銆�/httpAuditSysConfig 绛夌鐞嗘帴鍙� */
private boolean adminApiEnabled = true;
@@ -115,6 +126,34 @@
return HttpAuditDbConfigHolder.getPathDescriptions(pathDescriptions);
}
+ public int resolveLogStorageMode() {
+ if (logStorageMode == 2 || logStorageMode == 3) {
+ return logStorageMode;
+ }
+ return 1;
+ }
+
+ public boolean usesMysqlLogStorage() {
+ int m = resolveLogStorageMode();
+ return m == 1 || m == 3;
+ }
+
+ public boolean usesOpenSearchLogStorage() {
+ int m = resolveLogStorageMode();
+ return m == 2 || m == 3;
+ }
+
+ @Data
+ public static class OpenSearch {
+ private List<String> uris = new ArrayList<>(Collections.singletonList("localhost:9200"));
+ private String scheme = "http";
+ private String username = "";
+ private String password = "";
+ private String indexName = "http_audit_log";
+ private Duration connectTimeout = Duration.ofSeconds(5);
+ private Duration socketTimeout = Duration.ofSeconds(30);
+ }
+
private static List<String> defaultExcludes() {
List<String> list = new ArrayList<>();
list.add("/actuator");
--
Gitblit v1.9.1