<dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-websocket</artifactId>
        </dependency>

@Data
public class WebRTCSignalingMessage extends IMCommand {

    private String type;// 消息類型

    private Object offer;  // offer內(nèi)容

    private Object iceCandidate; // iceCandidate信息

    private Object answer; // answer數(shù)據(jù)

    private String fromUserId; //用戶id

    private String targetUserId; // 目標(biāo)用戶ID


}

public class RtpPacketDecoder extends ReplayingDecoder<Void> {

    @Override
    protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception {
        int header = in.readUnsignedByte();
        int version = (header >> 6) & 0x3;
        int padding = (header >> 5) & 0x1;
        int extension = (header >> 4) & 0x1;
        int cc = header & 0xf;

        header = in.readUnsignedByte();
        int marker = (header >> 7) & 0x1;
        int payloadType = header & 0x7f;

        int sequenceNumber = in.readUnsignedShort();
        int timestamp = in.readInt();
        int ssrc = in.readInt();

        int payloadLength = in.readableBytes();
        byte[] payload = new byte[payloadLength];
        in.readBytes(payload);

        out.add(new RtpPacket(version, padding, extension, cc, marker, payloadType, sequenceNumber, timestamp, ssrc, payload));
    }
}

// RTP數(shù)據(jù)包編碼器
public class RtpPacketEncoder extends MessageToByteEncoder<RtpPacket> {
    /**
     * 編碼方法，將RtpPacket對象編碼為字節(jié)流
     *
     * @param ctx           上下文對象，包含通道信息
     * @param packet        待編碼的RtpPacket對象
     * @param out           ByteBuf對象，用于存儲(chǔ)編碼后的字節(jié)流
     * @throws Exception    編碼過程中可能拋出的異常
     */
    @Override
    protected void encode(ChannelHandlerContext ctx, RtpPacket packet, ByteBuf out) throws Exception {
        // 構(gòu)造RTP頭的第一個(gè)字節(jié)
        byte header = (byte) ((packet.getVersion() << 6) | (packet.getPadding() << 5) |
                (packet.getExtension() << 4) | packet.getCc());
        out.writeByte(header);

        // 構(gòu)造RTP頭的第二個(gè)字節(jié)
        header = (byte) ((packet.getMarker() << 7) | packet.getPayloadType());
        out.writeByte(header);

        // 寫入序列號(hào)
        out.writeShort(packet.getSequenceNumber());
        // 寫入時(shí)間戳
        out.writeInt(packet.getTimestamp());
        // 寫入SSRC
        out.writeInt(packet.getSsrc());

        // 如果有效載荷不為空，則寫入有效載荷
        if (packet.getPayload()!= null) {
            out.writeBytes(packet.getPayload());
        }
    }
}

@Slf4j
public class MediaStreamForwarder extends SimpleChannelInboundHandler<RtpPacket> {
    @Override
    protected void channelRead0(ChannelHandlerContext ctx, RtpPacket packet) throws Exception {
        // 這里簡單地將RTP數(shù)據(jù)包轉(zhuǎn)發(fā)給所有其他客戶端，實(shí)際應(yīng)用中需要更智能的轉(zhuǎn)發(fā)邏輯
        for (ChannelHandlerContext targetCtx : IMServer.USERS.values()) {
            if (targetCtx!= ctx) {
                targetCtx.writeAndFlush(packet);
            }
        }
    }

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
        log.error("Media stream forwarding error", cause);
        ctx.close();
    }
}