diff --git a/src/main/java/com/ttstd/signaling/service/WebRTCSignalingServer.java b/src/main/java/com/ttstd/signaling/service/WebRTCSignalingServer.java index 9b424a1..79027b7 100644 --- a/src/main/java/com/ttstd/signaling/service/WebRTCSignalingServer.java +++ b/src/main/java/com/ttstd/signaling/service/WebRTCSignalingServer.java @@ -36,7 +36,7 @@ public class WebRTCSignalingServer { @OnOpen public void onOpen(Session session, @PathParam("userId") String userId) { clients.put(userId, session); - System.out.println("用户连接: " + userId); + logger.info("onOpen: 用户连接: " + userId); } @OnMessage @@ -50,7 +50,7 @@ public class WebRTCSignalingServer { if (targetSession != null && targetSession.isOpen()) { // 转发信令(SDP, ICE, 拒绝/接受) targetSession.getAsyncRemote().sendText(message); - System.out.println("信令类型 [" + signal.getType() + "] 从 " + userId + " 发往 " + toUser); + logger.info("onMessage: 信令类型 [" + signal.getType() + "] 从 " + userId + " 发往 " + toUser); } else { sendErrorMessage(session, "目标用户不在线: " + toUser); } @@ -62,12 +62,13 @@ public class WebRTCSignalingServer { @OnClose public void onClose(@PathParam("userId") String userId) { clients.remove(userId); - System.out.println("用户离开: " + userId); + logger.info("onClose: 用户离开: " + userId); } @OnError public void onError(Session session, Throwable error) { error.printStackTrace(); + logger.info("onError: " + error.getMessage()); } private void sendErrorMessage(Session session, String errorMsg) { diff --git a/src/test/java/com/ttstd/signaling/OneKeyCallWebRtcSignalingApplicationTests.java b/src/test/java/com/ttstd/signaling/OneKeyCallWebRtcSignalingApplicationTests.java index 998da34..c5e7fe3 100644 --- a/src/test/java/com/ttstd/signaling/OneKeyCallWebRtcSignalingApplicationTests.java +++ b/src/test/java/com/ttstd/signaling/OneKeyCallWebRtcSignalingApplicationTests.java @@ -3,7 +3,7 @@ package com.ttstd.signaling; import org.junit.jupiter.api.Test; import org.springframework.boot.test.context.SpringBootTest; -@SpringBootTest +@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT) class OneKeyCallWebRtcSignalingApplicationTests { @Test