增加日志输出

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,

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)

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) {

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) {