webtc视频聊天

我正在尝试与webrtc和RTCPeerConnection API建立1对1的视频聊天。我的代码的一个问题是，在初始用户连接到服务器之后，当其他用户通过socket.io发送消息时，它不会从服务器接收消息。客户机只接收它们自己发出的消息。这是我的一些代码。完整的项目在Github上:https://github.com/rashadrussell/webrtc_experiment

客户端

var isInitiator = false;

socket.on('initiatorFound', function(data) {
    isInitiator = data.setInitiator;
    console.log("Is Initiator? " + isInitiator);
});

navigator.getMedia = (
        navigator.getUserMedia ||
        navigator.webkitGetUserMedia ||
        navigator.mozGetUserMedia ||
        navigator.msGetUserMedia
    );
navigator.getMedia(
    {video: true, audio: false},
    function(stream) {
        var video = document.getElementById("localView");
        video.src = window.URL.createObjectURL(stream);
        console.log("Add Stream");
        sendMessage('streamAdd', {streamAdded: 'stream-added'});
        createPeerConnection();
        pc.addStream(stream);
        if(isInitiator)
        {
            callPeer();
        }
    },
    function(err) {
        console.log("The following error occured: ");
        console.dir(err);
    }
);

function sendMessage(type, message)
{
    console.log("Sending Message");
    socket.emit('message',{
        "type": type,
        "message": message
    });
}
function createPeerConnection() {
    pc = new rtcPeerConnection(servers, options);
    console.dir(pc);
    pc.onicecandidate = function(evt) {
        if(evt.candidate == null) return; 
        pc.onicecandidate = null;           
        console.log("Send Ice Candidate");
        sendMessage("iceCandidate", JSON.stringify(evt.candidate));
    };
    pc.onaddstream = function(evt) {
        document.body.append("<video id='remoteVideo' autoplay></video>");
        var remoteVid = document.getElementById("remoteVideo");
        remoteVid.src = window.URL.createObjectURL(evt.stream);
    };
}

function callPeer() {
    pc.createOffer(function (offer) {
            pc.setLocalDescription(offer, function() {
                sendMessage("offer", JSON.stringify(offer));
            });
            console.log("Send Offer");
        }, function(err) { console.log("Offer Error: " + err) },
            videoConstraints
        );
}
function answerPeer() {
    pc.createAnswer(function(answer) {
        pc.setLocalDescription(answer);
        sendMessage("answerswer", JSON.stringify(answer))
    }, function(err) { console.log("Sending Answer Error: " + err) },
        videoConstraints
    );
}
socket.on('message', function(message) {
    console.log("CONSOLE MESSAGE:");
    console.dir(message);
    if(message.type == 'streamAdd') {
        console.log('Stream was added');
        createPeerConnection();
        if(isInitiator) {
            callPeer();
        }
    } else if(message.type == 'offer') {
        pc.setRemoteDescription( new rtcSessionDescription(JSON.parse(message.message)));
        if(!isInitiator)
        {
            console.log("Sending Answer");
            answerPeer();
        }

    } else if(message.type == 'answer') {
        pc.setRemoteDescription( new rtcSessionDescription(JSON.parse(message.message)));
    } else if(message.type == 'iceCandidate') {
        console.log("Get Ice Candidate");
        pc.addIceCandidate(new rtcIceCandidate(JSON.parse(message.message)) );
    }
});

端

var isInitiator = false;
io.sockets.on('connection', function(socket) {
    if (!isInitiator) {
      isInitiator = true;
      socket.emit('initiatorFound', {setInitiator: isInitiator});
    } else {
      socket.emit('initiatorFound', {setInitiator: !isInitiator});
    }
    // Signaling Channel
    socket.on('message', function(message) {
      if (message.type == 'streamAdd') {
        console.log('Got message: ' + message);
      }
      //socket.emit('message' ,message);
      // Should be:
      socket.broadcast.emit('message', message);
    });
});