已接收数据流但UI无法显示视频流（GoLang+SFU）求助

我们实现了一段代码，用于将服务器接收的视频广播给所有连接的对等端（仅为测试远程流转本地流的初始步骤，非完整实现）。目前观察到onTrack监听器已触发且能看到数据，但UI无法显示视频。

此前我们用React+WebSockets的直接对等连接（无SFU）实现过类似功能，运行正常，切换到GoLang SFU后出现此问题。想了解迁移时需要注意哪些事项？

相关代码 #

Go后端轨道处理代码 #

peerConnection.OnTrack(func(remoteTrack *webrtc.TrackRemote, receiver *webrtc.RTPReceiver) {
        fmt.Printf("Received a remote track: %s\n", remoteTrack.ID())
        
        localTrackHelper, err := webrtc.NewTrackLocalStaticRTP(remoteTrack.Codec().RTPCodecCapability, remoteTrack.ID(), remoteTrack.StreamID())
        if err != nil {
            fmt.Println(err)
        }

        rtpBuf := make([]byte, 1400)
        go func() {
            for {
                i, _, readErr := remoteTrack.Read(rtpBuf)
                if readErr != nil {
                    panic(readErr)
                }

                if _, err = localTrackHelper.Write(rtpBuf[:i]); err != nil && !errors.Is(err, io.ErrClosedPipe) {
                    panic(err)
                }
            }
        }()

        _, err = peerConnection.AddTrack(localTrackHelper)
        if err != nil {
            return
        }
}
// 用于将视频流数据发送回远程对等端

对等端收到的媒体流信息 #

active: true
id: "MmneRfLzGPkLuPkm"
onactive: null
onaddtrack: null
oninactive: null
onremovetrack: null

React前端代码 #

peerConnection.current.ontrack = async(event) => {
    const [remoteStream] = event.streams;
    setRemoteStream(remoteStream);
}

<ReactPlayer
    height="400px"
    width="400px"
    url={remoteStream}
/>
// 能看到流数据，但UI无法显示视频

迁移到SFU架构的关键注意事项及问题排查 #

1. 轨道转发逻辑错误 #

你当前的Go代码犯了核心逻辑错误：在同一个PeerConnection内把收到的远程Track转为本地Track后又加回自身。SFU的核心是将一个Peer的Track分发给其他所有Peer，而非在同一个连接内做回环。

• 正确做法：维护所有在线PeerConnection的列表，收到某个Peer的Track后，遍历列表中除发送方外的所有PeerConnection，为每个Peer创建对应的本地Track并添加到他们的连接中。

2. 媒体流关联缺失 #

SFU转发Track时，默认不会自动为前端创建关联的MediaStream，前端event.streams可能为空或无效：

• 修正前端逻辑，手动创建MediaStream并添加Track：

peerConnection.current.ontrack = async(event) => {
  const remoteStream = new MediaStream();
  remoteStream.addTrack(event.track);
  setRemoteStream(remoteStream);
}

3. RTP包转发与RTCP反馈处理 #

• 仅转发RTP包不足以保证视频正常播放，SFU需要处理RTCP反馈（如NACK请求重传、PLI请求关键帧），否则会出现视频无法解码或卡顿。建议使用Pion库提供的高级转发API（如ForwardTrack），或手动监听并转发RTCP包。
• 确保RTP缓冲区大小适配实际包长度，避免截断数据。

4. Codec兼容性验证 #

确认前后端Codec协商一致，比如是否同时支持VP8/H.264：

• Go端打印remoteTrack.Codec()信息，前端通过peerConnection.getStats()查看解码状态，排查是否存在Codec不匹配导致的解码失败。

5. 前端播放组件兼容性 #

ReactPlayer对MediaStream的支持可能存在限制，先改用原生<video>标签测试：

<video 
  width="400" 
  height="400" 
  autoPlay 
  playsInline 
  ref={videoRef}
/>

// 在ontrack事件中赋值
videoRef.current.srcObject = remoteStream;

6. PeerConnection状态管理 #

SFU中需单独维护每个Peer的连接状态，当Peer断开时及时清理对应的Track和连接，避免无效转发或内存泄漏。

修正后的Go核心转发逻辑示例 #

// 维护全局PeerConnection列表（需加锁保证并发安全）
var peerConnections []*webrtc.PeerConnection
var mu sync.Mutex

peerConnection.OnTrack(func(remoteTrack *webrtc.TrackRemote, receiver *webrtc.RTPReceiver) {
    fmt.Printf("Received a remote track: %s\n", remoteTrack.ID())
    
    mu.Lock()
    defer mu.Unlock()
    // 遍历所有Peer，转发Track给除发送方外的其他节点
    for _, pc := range peerConnections {
        if pc == peerConnection {
            continue
        }
        localTrack, err := webrtc.NewTrackLocalStaticRTP(remoteTrack.Codec().RTPCodecCapability, remoteTrack.ID(), remoteTrack.StreamID())
        if err != nil {
            fmt.Println(err)
            continue
        }

        _, err = pc.AddTrack(localTrack)
        if err != nil {
            fmt.Println(err)
            continue
        }

        // 启动转发协程
        go func(track *webrtc.TrackRemote, local *webrtc.TrackLocalStaticRTP) {
            rtpBuf := make([]byte, 1400)
            for {
                n, _, err := track.Read(rtpBuf)
                if err != nil {
                    fmt.Printf("Read track error: %v\n", err)
                    return
                }
                if _, err := local.Write(rtpBuf[:n]); err != nil && !errors.Is(err, io.ErrClosedPipe) {
                    fmt.Printf("Write track error: %v\n", err)
                    return
                }
            }
        }(remoteTrack, localTrack)
    }
})

内容的提问来源于stack exchange，提问作者ManivishalBurra