2_JanusSignaling.zip

package com.example.janussignaling.websocketclient; import com.example.janussignaling.DTO.JanusUserSession; import com.example.janussignaling.manager.JanusSessionManager; import com.example.janussignaling.manager.RoomManager; import com.example.janussignaling.util.JanusUtils; import jdk.jfr.DataAmount; import lombok.extern.slf4j.Slf4j; import org.java_websocket.client.WebSocketClient; import org.java_websocket.handshake.ServerHandshake; import java.net.URI; import java.net.URISyntaxException; import java.util.HashMap; import java.util.Map; import org.json.JSONObject; import org.springframework.web.socket.WebSocketSession; import static com.example.janussignaling.constant.JanusKeyConstant.TRANSACTION_FIELD; import static com.example.janussignaling.constant.JanusRole.PUBLISHER; import static com.example.janussignaling.constant.JanusRole.SUBSCRIBER; import static com.example.janussignaling.constant.JanusStatConstant.*; @Slf4j public class JanusWebSocketClient extends WebSocketClient { private WebSocketSession session; private JanusSessionManager janusSessionManager; private RoomManager roomManager; private Long roomId = 12346L; public JanusWebSocketClient(WebSocketSession session, JanusSessionManager janusSessionManager, RoomManager roomManager) throws URISyntaxException { super(new URI("ws://43.132.171.79:8188"), addCustomHeaders()); // 替换成你的 Janus Videoroom 地址 // super(new URI("wss://43.132.171.79:8989"), addCustomHeaders()); // 替换成你的 Janus Videoroom 地址 this.session = session; this.janusSessionManager = janusSessionManager; this.roomManager = roomManager; } private static Map<String, String> addCustomHeaders() { Map<String, String> headers = new HashMap<>(); // 添加自定义头部字段 headers.put("Sec-WebSocket-Protocol", "janus-protocol"); // 添加其他自定义头部字段 // headers.put("Another-Header", "Another-Value"); return headers; } public void beginJanusSession() { String randomTransaction = JanusUtils.createRandomTransactionId(); sendToJanus(JanusUtils.constructCreateJanusSessionBody(randomTransaction)); JanusUserSession janusUserSession = janusSessionManager.getJanusUserSession(session.getId()); janusUserSession.setState(randomTransaction, CREATE); janusUserSession.setCurrentState(CREATE); } @Override public void onOpen(ServerHandshake handShakeData) { System.out.println("Connected to Janus VideoRoom"); // 在这里可以发送初始化消息或执行其他操作 } @Override public void onMessage(String message) { System.out.println("Received message from Janus: " + message); JSONObject jsonMessage = new JSONObject(message); String stat = null; try { stat = janusSessionManager.getState(session.getId(), jsonMessage.optString(TRANSACTION_FIELD)); } catch (Exception e) { throw new RuntimeException(e); } String randomTransaction; JanusUserSession janusUserSession; switch (stat) { case CREATE -> { // 将janusSessionId写入janusUserSession janusSessionManager.handleCreateState(session.getId(), jsonMessage); //获取插件 randomTransaction = JanusUtils.createRandomTransactionId(); janusUserSession = janusSessionManager.getJanusUserSession(session.getId()); sendToJanus(JanusUtils.constructAttachVideoRoomBody(randomTransaction, janusUserSession.getJanusSessionId())); janusUserSession.setState(randomTransaction, ATTACH); janusUserSession.setCurrentState(ATTACH); } case ATTACH -> { // 将handleId写入janusUserSession janusSessionManager.handleAttachState(session.getId(), jsonMessage); randomTransaction = JanusUtils.createRandomTransactionId(); janusUserSession = janusSessionManager.getJanusUserSession(session.getId()); if (PUBLISHER.equals(janusUserSession.getRole())) { sendToJanus(JanusUtils.constructCreateRoomBody(randomTransaction, janusUserSession.getJanusSessionId(), janusUserSession.getHandleId(), roomId)); janusUserSession.setState(randomTransaction, CREATE_ROOM); janusUserSession.setCurrentState(CREATE_ROOM); } if (SUBSCRIBER.equals(janusUserSession.getRole())) { sendToJanus(JanusUtils.constructPlayerJoinRoomBody(randomTransaction, janusUserSession.getJanusSessionId(), janusUserSession.getHandleId(), roomId, roomManager.getDeviceJanusUserSession(janusUserSession.getDeviceId()).getFeedId())); janusUserSession.setState(randomTransaction, JOIN); janusUserSession.setCurrentState(JOIN); } } // case LIST_PARTICIPANTS -> { // janusSessionManager.han; // randomTransaction = JanusUtils.createRandomTransactionId(); // janusUserSession = janusSessionManager.getJanusUserSession(session.getId()); // } case CREATE_ROOM -> { janusSessionManager.handleCreateRoom(session.getId(), jsonMessage); randomTransaction = JanusUtils.createRandomTransactionId(); janusUserSession = janusSessionManager.getJanusUserSession(session.getId()); sendToJanus(JanusUtils.constructDeviceJoinRoomBody(randomTransaction, janusUserSession.getJanusSessionId(), janusUserSession.getHandleId(), roomId)); janusUserSession.setState(randomTransaction, JOIN); janusUserSession.setCurrentState(JOIN); } case JOIN -> { randomTransaction = JanusUtils.createRandomTransactionId(); janusUserSession = janusSessionManager.getJanusUserSession(session.getId()); if (PUBLISHER.equals(janusUserSession.getRole())) { janusSessionManager.handlePublisherJoin(session.getId(), jsonMessage); if (JOIN.equals(janusUserSession.getCurrentState())) { sendToJanus(JanusUtils.constructConfigureBody(randomTransaction, janusUserSession.getJanusSessionId(), janusUserSession.getHandleId(), janusUserSession.getRemoteSdp())); janusUserSession.setState(randomTransaction, CONFIGURE); janusUserSession.setCurrentState(CONFIGURE); } } if (SUBSCRIBER.equals(janusUserSession.getRole())) { janusSessionManager.handleSubscriberJoin(session.getId(), jsonMessage); if (JOIN.equals(janusUserSession.getCurrentState())) { sendToJanus(JanusUtils.constructStartBody(randomTransaction, janusUserSession.getJanusSessionId(), janusUserSession.getHandleId(), janusUserSession.getRemoteSdp(), roomId)); janusUserSession.setState(randomTransaction, START); janusUserSession.setCurrentState(START); } } } case CONFIGURE -> { janusSessionManager.handleConfigure(session.getId(), jsonMessage); janusUserSession = janusSessionManager.getJanusUserSession(session.getId()); janusUserSession.setCurrentState(COMPLETE); } case COMPLETE -> janusSessionManager.handleComplete(session.getId(), jsonMessage); default -> { } } // 处理来自 Janus 的消息 // 将消息发送回对�