diff --git a/go-gost/gost b/go-gost/gost index 185f095..c0434d7 100755 Binary files a/go-gost/gost and b/go-gost/gost differ diff --git a/go-gost/x/config/parsing/service/parse.go b/go-gost/x/config/parsing/service/parse.go index afe5325..5738a43 100644 --- a/go-gost/x/config/parsing/service/parse.go +++ b/go-gost/x/config/parsing/service/parse.go @@ -346,16 +346,20 @@ func ParseService(cfg *config.ServiceConfig) (service.Service, error) { handlerLogger.Error("init: ", err) return nil, err } - + fmt.Println("开始注册观察器") var observer observer.Observer // 如果服务名以_tls结尾,则不启用观察器 if strings.HasSuffix(cfg.Name, "_tls") { observer = nil fmt.Println("服务名以_tls结尾,跳过观察器启用") } else if cfg.Observer != "" { + fmt.Println("def") observer = registry.ObserverRegistry().Get(cfg.Observer) } else if pStats != nil { + fmt.Println("console") observer = registry.ObserverRegistry().Get("console") + } else { + fmt.Println("err") } s := xservice.NewService(cfg.Name, ln, h, diff --git a/go-gost/x/service/service.go b/go-gost/x/service/service.go index 0ae44d4..637dd6b 100644 --- a/go-gost/x/service/service.go +++ b/go-gost/x/service/service.go @@ -353,6 +353,7 @@ func (s *defaultService) observeStats(ctx context.Context) { } isUpdated := st.IsUpdated() + fmt.Println("isUpdated", isUpdated) if isUpdated { inputBytes := st.Get(stats.KindInputBytes) outputBytes := st.Get(stats.KindOutputBytes) diff --git a/springboot-backend/src/main/java/com/admin/common/utils/WebSocketServer.java b/springboot-backend/src/main/java/com/admin/common/utils/WebSocketServer.java index 282cdab..ed55321 100644 --- a/springboot-backend/src/main/java/com/admin/common/utils/WebSocketServer.java +++ b/springboot-backend/src/main/java/com/admin/common/utils/WebSocketServer.java @@ -161,7 +161,6 @@ public class WebSocketServer extends TextWebSocketHandler { // 解密数据 String decryptedData = crypto.decryptString(encryptedMessage.getData()); - log.info("🔓 WebSocket消息解密成功"); return decryptedData; } } catch (Exception e) { @@ -191,7 +190,6 @@ public class WebSocketServer extends TextWebSocketHandler { encryptedMessage.put("data", encryptedData); encryptedMessage.put("timestamp", System.currentTimeMillis()); - log.info("🔐 WebSocket消息加密成功"); return encryptedMessage.toJSONString(); } } catch (Exception e) { diff --git a/springboot-backend/src/main/java/com/admin/controller/FlowController.java b/springboot-backend/src/main/java/com/admin/controller/FlowController.java index a4c7ad0..ee7b9a8 100644 --- a/springboot-backend/src/main/java/com/admin/controller/FlowController.java +++ b/springboot-backend/src/main/java/com/admin/controller/FlowController.java @@ -154,8 +154,7 @@ public class FlowController extends BaseController { } // 记录日志 - log.info("🔓 节点流量数据接收成功{}", isEncryptedMessage(rawData) ? "(已解密)" : ""); - + log.info("节点上报流量数据{}", flowDataList); // 4. 处理流量数据 return processFlowData(flowDataList); @@ -199,7 +198,6 @@ public class FlowController extends BaseController { // 解密数据 String decryptedData = crypto.decryptString(encryptedMessage.getData()); - log.info("🔓 数据解密成功"); return decryptedData; } } catch (Exception e) {