5

我正在尝试在使用 aiortc 的 Python 编写的相机服务和没有互联网连接的 javascript 中的 Web 前端之间创建一个 RTCPeerConnection。

camera-service 访问 usb-camera 并为其他两个服务提供流。用于用 javascript 编写的前端和用 python 编写的图像分类服务。所有这些服务都在 localhost 的不同端口上运行。我需要在没有互联网连接的情况下完成此操作。

两个 python 服务之间的 RTCPeerConnection 可以在没有互联网连接的情况下工作，但是前端和摄像头服务之间的连接不起作用。

如果没有互联网连接，相机服务的 ICEConnectionState 永远不会完成仅检查，所以我认为这是某种问题。

要重现此问题，只需尝试使用和不使用 Internet 连接的 aiortc 网络摄像头示例 ( https://github.com/aiortc/aiortc/tree/master/examples/webcam )。

JavaScript中的前端


var pc = new RTCPeerConnection({
    "iceServers": []
});

//start the negotiating process with camera-service(running on localhost:8080)
function negotiate() {
    pc.addTransceiver('video', {direction: 'recvonly'});
    return pc.createOffer().then(function(offer) {
        return pc.setLocalDescription(offer);
    }).then(function() {
        // wait for ICE gathering to complete
        return new Promise(function(resolve) {
            if (pc.iceGatheringState === 'complete') {
                resolve();
            } else {
                function checkState() {
                    if (pc.iceGatheringState === 'complete') {
                        pc.removeEventListener('icegatheringstatechange', checkState);
                        resolve();
                    }
                }
                pc.addEventListener('icegatheringstatechange', checkState);
            }
        });
    }).then(function() {
        var offer = pc.localDescription;
        const url = 'http://localhost:8080/offer';
        return fetch(url, {
        body: JSON.stringify({
            sdp: offer.sdp,
                type: offer.type,
            }),
            headers: {
                'Content-Type': 'application/json'
            },
            method: 'POST'
        });
    }).then(function(response) {
        return response.json();
    }).then(function(answer) {
        return pc.setRemoteDescription(answer);
    }).catch(function(e) {
        alert(e);
    });
}

python中的相机服务

# method gets called on POST request to localhost:8080/offer
async def offer(request):

    params = await request.json()
    offer = RTCSessionDescription(sdp=params["sdp"], type=params["type"])

    pc = RTCPeerConnection(RTCConfiguration(iceServers=[]))
    pcs.add(pc)

    @pc.on("iceconnectionstatechange")
    async def on_iceconnectionstatechange():
        print("ICE connection state is %s" % pc.iceConnectionState)
        if pc.iceConnectionState == "failed":
            await pc.close()
            pcs.discard(pc)

    pc.addTrack(player.video)

    await pc.setRemoteDescription(offer)

    answer = await pc.createAnswer()
    await pc.setLocalDescription(answer)

    response = web.Response(
        content_type="application/json",
        body=json.dumps({
            "sdp": pc.localDescription.sdp,
            "type": pc.localDescription.type}))

    return response

python中的图像分类服务 

async def negotiate(request):
    pc = RTCPeerConnection()
    pcs.add(pc)

    pc.addTransceiver('video',direction='recvonly')

    offer = await pc.createOffer()
    await pc.setLocalDescription(offer)

    data = json.dumps({
            "sdp": pc.localDescription.sdp,
            "type": pc.localDescription.type})

    response = requests.post("http://localhost:8080/offer",data=data).json()


    answer = RTCSessionDescription(sdp=response["sdp"],type=response["type"])

    await pc.setRemoteDescription(answer)

    return web.Response(content_type="text/plain", text="Just text")

图像分类服务的结果： RTC Connection 可以在有或没有连接到互联网的情况下工作。

前端的预期结果相同，但前端 RTC 连接在没有 Internet 连接的情况下无法工作。

4

0 回答 0