Создание и использование канала данных между двумя пирами с помощью webRTC

Я пытаюсь настроить одноранговую систему обмена файлами с помощью WebRTC. Я могу открыть канал данных на каждой стороне, но я не могу отправлять сообщения от одного пользователя другому. Более того, если один узел закрывает канал, другой - событие onclose запускается только для этого пользователя.

Как правильно настроить и использовать канал данных с webRTC?

Не могли бы вы сказать мне, что не так или нет в моем коде?

//create RTC peer objet.
var RTCPeerConnection = webkitRTCPeerConnection;
var RTCIceCandidate = window.RTCIceCandidate;
var RTCSessionDescription = window.RTCSessionDescription;

var iceServers = {
    iceServers: [{
        url: 'stun:stun.l.google.com:19302'
    }]
};
var p2p_connection = new RTCPeerConnection({
      iceServers: [
        { 'url': (IS_CHROME ? 'stun:stun.l.google.com:19302' : 'stun:23.21.150.121') }
  ]
});

// send offer (only executes in one browser)
function initiateConnection() {
    p2p_connection.createOffer(function (description) {
        p2p_connection.setLocalDescription(description);
        server_socket.emit('p2p request', description,my_username);
    });
};

// receive offer and send answer
server_socket.on('p2p request', function(description,sender){ 
    console.log('received p2p request');

    p2p_connection.setRemoteDescription(new RTCSessionDescription(description));

    p2p_connection.createAnswer(function (description) {
        p2p_connection.setLocalDescription(description);
        server_socket.emit('p2p reply', description,sender);
    });
});

// receive answer
server_socket.on('p2p reply', function(description,sender){
    console.log('received p2p reply');
    p2p_connection.setRemoteDescription(new RTCSessionDescription(description));
});

// ICE candidates
p2p_connection.onicecandidate = onicecandidate; // sent event listener

// locally generated
function onicecandidate(event) {
    if (!p2p_connection || !event || !event.candidate) return;
    var candidate = event.candidate;
    server_socket.emit('add candidate',candidate,my_username);
}

// sent by other peer
server_socket.on('add candidate', function(candidate,my_username){

    p2p_connection.addIceCandidate(new RTCIceCandidate({
            sdpMLineIndex: candidate.sdpMLineIndex,
            candidate: candidate.candidate
    }));
});

// data channel 
var dataChannel = p2p_connection.createDataChannel('label');

dataChannel.onmessage = function (event) {
    var data = event.data;
    console.log("I got data channel message: ", data);
};

dataChannel.onopen = function (event) {
    console.log("Data channel ready");
    dataChannel.send("Hello World!");
};
dataChannel.onclose = function (event) {
    console.log("Data channel closed.");
};
dataChannel.onerror = function (event) {
    console.log("Data channel error!");
}

Обновить:

Нашел решение там: http://www.html5rocks.com/en/tutorials/webrtc/basics/

p2p_connection.ondatachannel = function (event) {
    receiveChannel = event.channel;
    receiveChannel.onmessage = function(event){
    console.log(event.data);
    };
};

1 ответ

Вы можете рассмотреть возможность использования simple-peer библиотека, чтобы избежать решения этих сложностей в будущем. Вызовы API WebRTC вводят в заблуждение, и иногда трудно сделать правильный порядок.

simple-peer поддерживает видео / голосовые потоки, канал данных (текстовые и двоичные данные), и вы даже можете использовать канал данных в качестве дуплексного потока в стиле node.js. Он также поддерживает расширенные параметры, такие как отключение вспомогательных кандидатов ICE (поэтому каждому клиенту нужно отправить только одно сообщение о предложении / ответе, а не многократные повторяющиеся сообщения кандидатов на лед). Это бессмысленно и работает с любым бэкэндом.

https://github.com/feross/simple-peer

Другие вопросы по тегам