5

最初に私の悪い英語を申し訳ありません。WebRTC でビデオ通話をしようとしていますが、うまくいきません。サーバーには node.js+socket.io+express を使用しています。あなたが私に与えることができる助けや提案に感謝します。どうもありがとうございました。これは私のコードです。

サーバ

var express = require('express')
  , io = require('socket.io')
  , app = express()
  , server = require('http').createServer(app)
  , io = io.listen(server);

server.listen(8080);

app.get('/', function (req, res) {
  res.sendfile(__dirname + '/index.html');
});

var usuarios = [];

io.sockets.on('connection', function (socket) {
    usuarios.push(socket);
    console.log('Nuevo usuario conectado - ' + usuarios.length + ' en total');

    socket.on('message', function (mensaje) { 
        usuarios.forEach(function (usuario) {
            if (usuario != socket) {
                usuario.send(mensaje);
            }
        });
    });

    socket.on('disconnect', function () { 
        console.log("Usuario desconectado");
        // ...
    });
});

クライアント

<html>
    <head>
        <title>Cliente</title>
    </head>
    <body>
        <video id='videolocal' autoplay style='width: 200px; height: 150px; border: 1px solid black;'></video>
        <video id='videoremoto' autoplay style='width: 200px; height: 150px; border: 1px solid black;'></video>
        <button type="button" onclick="iniciarCamara();">Iniciar Camara</button>
        <button type="button" onclick="pararCamara();">Parar Camara</button>
        <button type="button" onclick="conectar();">Conectar</button>
        <button type="button" onclick="desconectar();">Desconectar</button>

        <script src="/socket.io/socket.io.js"></script>
        <script>
            var socket = io.connect('http://localhost:8080');
            var videolocal = document.getElementById('videolocal');
            var videoremoto = document.getElementById('videoremoto');
            var streamlocal = null;
            var pc = null;
            var conectado = false;
            window.URL = window.URL || window.webkitURL;
            navigator.getUserMedia = navigator.getUserMedia || navigator.webkitGetUserMedia || navigator.mozGetUserMedia || navigator.msGetUserMedia;

            socket.on('message', function (mensaje) {
                var msg = JSON.parse(mensaje);

                if (msg.type === 'oferta') {
                    pc.setRemoteDescription(pc.SDP_OFFER, new SessionDescription(msg.sdp));
                    responder();
                } else if (msg.type === 'respuesta' && conectado) {
                    pc.setRemoteDescription(pc.SDP_ANSWER, new SessionDescription(msg.sdp));
                } else if (msg.type === 'candidate' && conectado) {
                    var candidate = new IceCandidate(msg.label, msg.candidate);
                    pc.processIceMessage(candidate);
                } else if (msg.type === 'desconectar' && conectado) {
                    //...
                }
            });

            function responder() {
                var oferta = pc.remoteDescription;
                var respuesta = pc.createAnswer(oferta.toSdp(), {has_audio:true, has_video:true});
                pc.setLocalDescription(pc.SDP_ANSWER, respuesta);
                socket.send({type: 'respuesta', sdp: respuesta.toSdp()});
                pc.startIce();
            }

            function crearPeerConnection() {
                pc = new webkitPeerConnection00(null, iceCallback);
                pc.addEventListener("addstream", anadirStreamRemoto, false);
                pc.addEventListener("removestream", eliminarStreamRemoto, false);

                function anadirStreamRemoto(event) {
                    videoremoto.src = window.webkitURL.createObjectURL(event.stream);
                }

                function eliminarStreamRemoto(event) {
                    videoremoto.src = "";
                }
            }

            function iniciarCamara() {
                navigator.getUserMedia({video: true, audio: true}, okCallback, errorCallback);

                function okCallback(stream) {
                    videolocal.src = window.URL.createObjectURL(stream);
                    streamlocal = stream;
                }

                function errorCallback(error) {
                    alert("Error");
                    return;
                }
            }

            function pararCamara() {
                videolocal.src = "";
            }

            function iceCallback(candidate, bMore) {
                if(candidate) {
                    socket.send({type: 'candidate', label: candidate.label, candidate: candidate.toSdp()});
                }
            }

            function conectar() {
                if (!conectado && streamlocal) {
                    crearPeerConnection();
                    conectado = true;
                    var oferta = pc.createOffer({has_audio:true, has_video:true});
                    pc.setLocalDescription(pc.SDP_OFFER, oferta);
                    socket.send({type: 'oferta', sdp: oferta.toSdp()});
                    pc.startIce();
                } else {
                    alert("No se ha iniciado el stream local");
                }
            }

            function desconectar() {
                pc.close();
                pc = null;
                conectado = false;
            }

    </script>
</body>

エラー

Uncaught SyntaxError: Unexpected token o localhost:25
(anonymous function) localhost:25
EventEmitter.emit socket.io.js:633
SocketNamespace.onPacket socket.io.js:2239
Socket.onPacket socket.io.js:1930
Transport.onPacket socket.io.js:1332
Transport.onData socket.io.js:1303
websocket.onmessage

よろしく。

4

1 に答える 1

2

socket.ioメソッド.send（）がメッセージを送信している間にjsObjectsを送信する必要があります。データを提供するには、.emit（）メソッドを使用する必要があるため、すべてを置き換える必要があります。

socket.send({...});

と：

socket.emit('message', {...})

したがって、次の行を削除する必要があります。

var msg = JSON.parse(mensaje);
于 2013-01-22T15:05:11.857 に答える