Python aiortc脚本间ICE连接无法建立，求排查解决方法

一、移植时遗漏的关键步骤 #

1. 显式指定SDP语义
   JS版本明确配置了sdpSemantics: 'unified-plan'，虽然aiortc 1.3+默认使用该语义，但显式配置可避免潜在兼容问题。修改PeerConnection初始化代码：

config = RTCConfiguration(
    sdpSemantics="unified-plan",
    iceServers=[RTCIceServer(urls=["stun:stun.l.google.com:19302"])]
)
pc = RTCPeerConnection(config)

2. 移除错误的Track回添逻辑
   你的客户端设置为recvonly方向，仅需接收流即可，但代码中在收到track后调用pc.addTrack()将处理后的track回传给服务端，这会导致SDP协商出现额外媒体流，干扰连接建立。删除该部分代码：

@pc.on("track")
def on_track(track):
    logger.info("Track %s received" % track)
    # 仅订阅并处理track，无需添加回PeerConnection
    transformed_track = VideoTransformTrack(relay.subscribe(track))
    
    @track.on("ended")
    async def on_ended():
        logger.info("Track ended: %s" % track)

3. 修复ICE收集的等待逻辑
   Python代码中while True + time.sleep()会阻塞asyncio事件循环，导致ICE收集过程异常。改用事件监听的方式等待收集完成，和JS逻辑对齐：

await pc.setLocalDescription(offer)

# 正确等待ICE收集完成
if pc.iceGatheringState != "complete":
    gather_complete = asyncio.Future()
    def on_ice_gathering_change():
        if pc.iceGatheringState == "complete":
            gather_complete.set_result(None)
    pc.on("icegatheringstatechange", on_ice_gathering_change)
    await gather_complete

4. 解决SDP中0.0.0.0的问题
   aiortc默认绑定0.0.0.0会导致SDP出现无效地址，可通过两种方式修复：

• 启动webcam.py时指定真实IP：python webcam.py --host 192.168.x.x（替换为你的本地IP），客户端请求地址同步改为该IP；
• 在RTCConfiguration中显式设置ICE传输策略，并确保机器有可用的非回环IP：

  config = RTCConfiguration(
      sdpSemantics="unified-plan",
      iceServers=[RTCIceServer(urls=["stun:stun.l.google.com:19302"])],
      iceTransportPolicy="all"
  )
  

二、WebRTC连接问题的调试方法 #

• 开启详细日志
  配置loguru为DEBUG级别，查看ICE候选收集、SDP交换的完整过程：

from loguru import logger
import sys
logger.add(sys.stderr, level="DEBUG")

• 对比SDP内容
  分别打印Python和JS生成的offer，逐行对比：

  • 检查媒体流方向是否一致（均为recvonly）；
  • 检查ICE候选地址是否为有效IP（而非0.0.0.0）；
  • 确认SDP语义为unified-plan。

• 监听细粒度状态事件
  除connectionState外，监听iceConnectionState和signalingState，获取更精准的状态变化：

@pc.on("iceconnectionstatechange")
def on_ice_connection_state_change():
    logger.info("ICE连接状态: %s" % pc.iceConnectionState)
    
@pc.on("signalingstatechange")
def on_signaling_state_change():
    logger.info("信令状态: %s" % pc.signalingState)

• 抓包分析网络交互
  用Wireshark抓取UDP包，过滤stun或ice协议，查看ICE候选交换、STUN请求响应是否正常，排查网络阻塞问题。

• 简化测试流程
  先移除所有自定义Track处理逻辑，仅保留PeerConnection创建、offer/answer交换的基础代码，验证连接是否能建立。若成功，再逐步添加Track处理逻辑定位问题点。

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