Я разрабатываю приложение в стиле конференции (многие-ко-многим) для видеозвонков в этом стиле. Код доступен на GitHub, но у меня мало опыта работы с node.js, поэтому я решил создать свой собственный сервер с использованием PHP.
Я создал сервер с помощью WebSockets. Это просто - он получает сообщения и пересылает их всем другим подключенным клиентам (то есть не клиенту, который отправил сообщение). Только это - не более того; не меньше.
Но моя проблема в том, что эта архитектура не позволяет клиентам подключаться более чем к одному человеку, т.е. когда клиент пытается подключиться к третьему лицу, дополнительные потоки терпят неудачу. Клиенты могут подключаться только один к одному.
Я не знаю, связана ли ошибка с JavaScript или мне нужно улучшить сервер. Что я могу сделать, чтобы он подключился ко всем клиентам, которые присоединяются?
Смотрите мой код:
HTML
<script type="text/javascript" src="http://127.0.0.1/scr/js/jquery.js"></script>
JavaScript
var Server = new WebSocket('ws://127.0.0.1:1805/'),
myStream = null,
peerConn = null,
mediaConstraints = {
'mandatory': {
'OfferToReceiveAudio': true,
'OfferToReceiveVideo': true
}
};
navigator.webkitGetUserMedia({
audio: true,
video: true
}, function(stream) {
myStream = stream;
$("body").append('<video width="320" height="240" muted="muted" autoplay="true" src="' + window.URL.createObjectURL(stream) + '"></video>');
createPeerConnection();
peerConn.addStream(myStream);
peerConn.createOffer(function(sessionDescription) {
peerConn.setLocalDescription(sessionDescription);
console.log("Sending offer description");
Server.send(JSON.stringify(sessionDescription));
}, null, mediaConstraints);
}, function() {
console.error('Error in my stream');
});
function createPeerConnection() {
console.log('Creating peer connection');
peerConn = new webkitRTCPeerConnection({
'iceServers': [{
'url': 'stun:stun.l.google.com:19302'
}, {
'url': 'turn:107.150.19.220:3478',
'credential': 'turnserver',
'username': 'subrosa'
}]
}, {
'optional': [{
'DtlsSrtpKeyAgreement': 'true'
}]
});
peerConn.onicecandidate = function(event) {
if (event.candidate) {
Server.send(JSON.stringify({
type: 'candidate',
label: event.candidate.sdpMLineIndex,
id: event.candidate.sdpMid,
candidate: event.candidate.candidate
}));
} else {
console.error('Candidate denied');
}
};
peerConn.onaddstream = function(event) {
console.log("Adding remote strem");
$("body").append('<video width="320" height="240" autoplay="true" src="' + window.URL.createObjectURL(event.stream) + '"></video>');
};
peerConn.onremovestream = function(event) {
console.log("Removing remote stream");
};
}
Server.addEventListener("message", function(message) {
var msg = JSON.parse(message.data);
if(!myStream) {
console.error('Error in my stream');
}
if (msg.type === 'offer') {
createPeerConnection();
console.log('Adding local stream...');
peerConn.addStream(myStream);
peerConn.setRemoteDescription(new RTCSessionDescription(msg));
console.log("Sending answer to peer.");
peerConn.createAnswer(function(sessionDescription) {
peerConn.setLocalDescription(sessionDescription);
Server.send(JSON.stringify(sessionDescription));
}, null, mediaConstraints);
} else if (msg.type === 'answer') {
peerConn.setRemoteDescription(new RTCSessionDescription(msg));
} else if (msg.type === 'candidate') {
var candidate = new RTCIceCandidate({
sdpMLineIndex: msg.label,
candidate: msg.candidate
});
peerConn.addIceCandidate(candidate);
}
}, false);