aiortc中在DataChannel消息处理函数内调用addTrack无响应问题排查

基于aiortc的server示例修改仅音频功能，流程如下：

• 浏览器初始仅发送音频，服务器暂不添加远端轨道
• 点击“Stop”按钮，通过DataChannel向服务器发送“trackended”消息
• 服务器收到消息后初始化播放器，调用addTrack添加音频轨道
• 预期浏览器触发track事件并播放传输的WAV音频，但该步骤未生效

注：因浏览器端track.on("ended")事件在关闭轨道时未触发，才采用DataChannel通知的方案，已附带server.py和client.js代码截图。

排查与解决方向 #

1. 确认DataChannel消息接收与流程触发 #

在服务器端trackended消息的处理逻辑处添加日志，验证服务器是否确实收到消息并进入轨道添加分支：

# server.py 中对应处理位置
@datachannel.on("message")
async def on_message(message):
    if message == "trackended":
        print("Received trackended trigger")
        # 后续播放器初始化与addTrack逻辑

2. 检查addTrack的调用有效性 #

• 确保调用addTrack时，对应客户端的RTCPeerConnection处于稳定连接状态，可通过pc.connectionState或pc.iceConnectionState确认状态为connected
• 验证播放器与音频轨道初始化是否成功：

player = MediaPlayer("your-audio.wav")
if player.audio:
    print("Audio track loaded successfully")
    pc.addTrack(player.audio)
else:
    print("Failed to load audio track from WAV file")

• 确认addTrack调用的是当前客户端对应的RTCPeerConnection实例，而非其他连接对象

3. 修复浏览器端track事件监听逻辑 #

确保浏览器端正确监听track事件并处理音频播放，注意浏览器自动播放的交互限制：

// client.js 中RTCPeerConnection的track事件处理
pc.ontrack = (event) => {
    console.log("Received remote audio track:", event.track);
    if (event.track.kind === 'audio') {
        const audioElement = document.createElement('audio');
        audioElement.srcObject = event.streams[0];
        // 利用之前的Stop按钮点击满足用户交互要求，开启自动播放
        audioElement.autoplay = true;
        audioElement.muted = false;
        document.body.appendChild(audioElement);
    }
};

4. 验证WAV文件兼容性 #

确保使用的WAV文件为浏览器支持的编码格式（如PCM 16位、采样率44.1kHz/48kHz），避免因编码不兼容导致无法解码播放。可替换为标准测试WAV文件验证。

5. 强制触发媒体协商更新 #

服务器调用addTrack后，需触发新的会话协商，确保浏览器收到更新后的媒体描述：

# server.py 添加轨道后触发协商
await pc.setLocalDescription(await pc.createOffer())
# 确保信令通道将新的本地描述发送至浏览器

浏览器端需正确处理远端描述更新，完成协商：

// client.js 处理服务器发送的远端描述
socket.on('message', async (message) => {
    if (message.type === 'offer') {
        await pc.setRemoteDescription(new RTCSessionDescription(message));
        const answer = await pc.createAnswer();
        await pc.setLocalDescription(answer);
        // 发送answer至服务器
    }
});

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