Почему Peer. js отключается после того, как я вызываю connection.send ()? - PullRequest
0 голосов
/ 30 марта 2020

Я работаю над простым сайтом двусторонней связи. Он использует Peer. js для одноранговой связи через браузер. Я взял много кода из этой демонстрации: https://jmcker.github.io/Peer-to-Peer-Cue-System/. Проблема в том, что после того, как я вызываю sendMessage () для отправки данных между браузерами, они отключаются. Я полагаю, что данные отправляются, но они никогда не принимаются, так как соединение прерывается, как только я пытаюсь его отправить. Вот код для хост-устройства :

var peer;
var lastPeerId;
var conn;

function initialize() {
    // Create own peer object with connection to shared PeerJS server
    peer = new Peer(null, {
        debug: 0
    });

    peer.on('open', function (id) {
        // Workaround for peer.reconnect deleting previous id
        if (peer.id === null) {
            console.log('Received null id from peer open');
            peer.id = lastPeerId;
        } else {
            lastPeerId = peer.id;
        }

        console.log("ID: " + peer.id);
        console.log("Awaiting connection.")
    });
    peer.on('connection', function (c) {
        // Allow only a single connection
        if (conn) {
            c.on('open', function () {
                c.send("Already connected to another client");
                setTimeout(function () {
                    c.close();
                }, 500);
            });
            return;
        }

        conn = c;
        console.log("Connected to: " + conn.peer);
        ready();
    });
    peer.on('disconnected', function () {
        console.log('Connection lost. Please reconnect');

        // Workaround for peer.reconnect deleting previous id
        peer.id = lastPeerId;
        peer._lastServerId = lastPeerId;
        peer.reconnect();
    });
    peer.on('close', function () {
        conn = null;
        console.log('Connection destroyed');
    });
    peer.on('error', function (err) {
        console.log(err);
    });
};

function ready() {
    conn.on('data', function (data) {
        console.log("Data recieved");
        console.log("Received: " + data);
    });
    conn.on('close', function () {
        console.log("Connection reset. Awaiting connection...");
        conn = null;
        //start(true);
    });
}

function sendMessage(message) {
    if (conn && conn.open) {
        conn.send(message);
        console.log("Sent: " + message);
    } else {
        console.log('Connection is closed');
    }
}

initialize();

А это код для подключающего устройства (не хоста) :

var peer;
var lastPeerId;
var conn;
//Get the ID specified in the address after the "?" sign
var idToConnectTo = window.location.href.split("?")[1];

function initialize() {
    // Create own peer object with connection to shared PeerJS server
    peer = new Peer(null, {
        debug: 0
    });

    peer.on('open', function (id) {
        // Workaround for peer.reconnect deleting previous id
        if (peer.id === null) {
            console.log('Received null id from peer open');
            peer.id = lastPeerId;
        } else {
            lastPeerId = peer.id;
        }

        console.log('ID: ' + peer.id);
        join();
    });
    peer.on('disconnected', function () {
        console.log('Connection lost. Please reconnect');

        // Workaround for peer.reconnect deleting previous id
        peer.id = lastPeerId;
        peer._lastServerId = lastPeerId;
        peer.reconnect();
    });
    peer.on('close', function () {
        conn = null;
        console.log('Connection destroyed');
    });
    peer.on('error', function (err) {
        console.log(err);
    });
};

function join() {
    // Close old connection
    if (conn) {
        conn.close();
    }

    // Create connection to destination peer specified in the input field
    conn = peer.connect(idToConnectTo, {
        reliable: true
    });

    conn.on('open', function () {
        console.log("Connected to: " + conn.peer);
    });

    // Handle incoming data
    conn.on('data', function (data) {
        console.log("Received: " + data);
    });
    conn.on('close', function () {
        console.log("Connection closed");
    });
};

function sendMessage(message) {
    if (conn && conn.open) {
        conn.send(message);
        console.log("Sent: " + message);
    } else {
        console.log('Connection is closed');
    }
}

initialize();

Любая помощь будет оценена. Спасибо!

1 Ответ

0 голосов
/ 30 марта 2020

Мне кажется, проблема в том, что я пытался установить связь между двумя вкладками одного и того же браузера. При использовании двух разных браузеров все работало корректно.

...