From 2101d76b083fbf0ee72f1cd29277ffe4ecc37aa5 Mon Sep 17 00:00:00 2001
From: tongtongstudio <tongtongstudio@outlook.com>
Date: Thu, 22 Jan 2026 14:20:00 +0800
Subject: [PATCH] =?UTF-8?q?=E8=A7=A3=E5=86=B3=E6=89=93=E5=8C=85=E5=A4=B1?=
 =?UTF-8?q?=E8=B4=A5=E9=97=AE=E9=A2=98=EF=BC=8C=E5=8E=BB=E6=8E=89print?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../ttstd/signaling/WebRtcSignalingApplication.java  |  6 +++++-
 .../ttstd/signaling/handler/WebRtcSignalHandler.java | 12 ++++++++----
 src/main/resources/application.properties            |  2 +-
 3 files changed, 14 insertions(+), 6 deletions(-)

diff --git a/src/main/java/com/ttstd/signaling/WebRtcSignalingApplication.java b/src/main/java/com/ttstd/signaling/WebRtcSignalingApplication.java
index b23f0d5..dc8fc99 100644
--- a/src/main/java/com/ttstd/signaling/WebRtcSignalingApplication.java
+++ b/src/main/java/com/ttstd/signaling/WebRtcSignalingApplication.java
@@ -1,14 +1,18 @@
 package com.ttstd.signaling;
 
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 
 @SpringBootApplication
 public class WebRtcSignalingApplication {
 
+    static Logger logger = LoggerFactory.getLogger(WebRtcSignalingApplication.class);
+
     public static void main(String[] args) {
         SpringApplication.run(WebRtcSignalingApplication.class, args);
-        System.out.println("✅ WebRTC信令服务器启动成功！WebSocket连接地址：ws://localhost:2310/ws/rtc?userId=xxx");
+        logger.info("✅ WebRTC信令服务器启动成功！WebSocket连接地址：ws://localhost:2310/ws/rtc?userId=xxx");
     }
 
 }
diff --git a/src/main/java/com/ttstd/signaling/handler/WebRtcSignalHandler.java b/src/main/java/com/ttstd/signaling/handler/WebRtcSignalHandler.java
index 6ad2b49..cafff94 100644
--- a/src/main/java/com/ttstd/signaling/handler/WebRtcSignalHandler.java
+++ b/src/main/java/com/ttstd/signaling/handler/WebRtcSignalHandler.java
@@ -2,6 +2,8 @@ package com.ttstd.signaling.handler;
 
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.ttstd.signaling.entity.RtcSignalMessage;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.stereotype.Component;
 import org.springframework.web.socket.CloseStatus;
 import org.springframework.web.socket.TextMessage;
@@ -19,6 +21,8 @@ import java.util.concurrent.ConcurrentHashMap;
 @Component
 public class WebRtcSignalHandler extends TextWebSocketHandler {
 
+    Logger logger = LoggerFactory.getLogger(WebRtcSignalHandler.class);
+
     /**
      * 核心：维护在线用户的WebSocket会话映射
      * key: 用户ID（userId）
@@ -41,7 +45,7 @@ public class WebRtcSignalHandler extends TextWebSocketHandler {
         if (userId != null && !userId.isEmpty()) {
             // 将用户会话存入在线列表
             ONLINE_USER_SESSIONS.put(userId, session);
-            System.out.println("用户[" + userId + "] 上线，当前在线人数：" + ONLINE_USER_SESSIONS.size());
+            logger.info("用户[" + userId + "] 上线，当前在线人数：" + ONLINE_USER_SESSIONS.size());
         }
     }
 
@@ -67,7 +71,7 @@ public class WebRtcSignalHandler extends TextWebSocketHandler {
         if (targetSession != null && targetSession.isOpen()) {
             // 将信令消息原样转发给目标用户
             targetSession.sendMessage(new TextMessage(objectMapper.writeValueAsString(signalMessage)));
-            System.out.println("信令中转成功：[" + fromUserId + "] -> [" + toUserId + "] 类型：" + signalType);
+            logger.info("信令中转成功：[" + fromUserId + "] -> [" + toUserId + "] 类型：" + signalType);
         } else {
             // 目标用户不在线/连接已关闭
             sendErrorMessage(session, "目标用户[" + toUserId + "] 不在线或连接已断开");
@@ -82,7 +86,7 @@ public class WebRtcSignalHandler extends TextWebSocketHandler {
         String userId = getUserIdFromSession(session);
         if (userId != null) {
             ONLINE_USER_SESSIONS.remove(userId);
-            System.out.println("用户[" + userId + "] 下线，当前在线人数：" + ONLINE_USER_SESSIONS.size());
+            logger.info("用户[" + userId + "] 下线，当前在线人数：" + ONLINE_USER_SESSIONS.size());
         }
     }
 
@@ -94,7 +98,7 @@ public class WebRtcSignalHandler extends TextWebSocketHandler {
         String userId = getUserIdFromSession(session);
         if (userId != null) {
             ONLINE_USER_SESSIONS.remove(userId);
-            System.out.println("用户[" + userId + "] 连接异常，已移除会话，异常信息：" + exception.getMessage());
+            logger.error("用户[" + userId + "] 连接异常，已移除会话，异常信息：" + exception.getMessage());
         }
     }
 
diff --git a/src/main/resources/application.properties b/src/main/resources/application.properties
index af81fad..38a5e71 100644
--- a/src/main/resources/application.properties
+++ b/src/main/resources/application.properties
@@ -1,2 +1,2 @@
 spring.application.name=WebRTCSignaling
-server.port=2310
\ No newline at end of file
+server.port=5156
\ No newline at end of file