HTML5 Websocket innerhalb Webworker

Habe ich es geschafft, websockets arbeiten in einem webworker, die Chrome verwenden, aber nur für den Empfang von Daten. Wenn ich versuche, Daten zu senden, bekomme ich eine DOM-Ausnahme, hat jemand geschafft, die Daten zu senden?

Dies ist, was ich habe, für meine web-worker.

self.addEventListener('message', function(e) {
var data = e.data;

switch (data.cmd) {
    case 'init':
        self.postMessage("Initialising Web Workers...");
        testWS();
        break;
    default:
        self.postMessage('Unknown command: ' + data.msg);
    };
}, false);

function testWS() {
    var connectionAddr = "ws://localhost:8003";
    var socket = new WebSocket(connectionAddr);
    socket.onmessage = function(event) {
        self.postMessage('Websocket : ' + event.data);
    };

    socket.onclose = function(event) {
    };

    function send(message) {
        socket.send(message);
    }

    send("hello"); //Here is where the exception is thrown
}
InformationsquelleAutor Jack | 2013-08-01
  1. 22

    Müssen Sie hören für die BeimÖffnen-websocket-event vor dem senden der ersten Nachricht.

    socket.onopen = function(){
    //send some message   
};
    • Ja, Sie sind richtig, dachte nur, dass vor der Suche zurück hier, die Verbindung war nicht offen und das war das problem. Cheers
    InformationsquelleAutor mguimard
  2. 0

    Versuchen Sie dies:

    var WebSocketStateEnum = {CONNECTING: 0, OPEN: 1, CLOSING: 2, CLOSED: 3};

var wsChannel;
var msgQueue = [];

//Using like this:
sendMessage(_ => {
    wsChannel.send('message...'); //This will wait until the connection open, unless it is already opened
});

function sendMessage(task) {
    if (!wsChannel || wsChannel.readyState != WebSocketStateEnum.OPEN) {
        msgQueue.push(task);
    } else {
        task();
    }

    if (!wsChannel) {
        wsChannel = new WebSocket('ws://your-url');
        wsChannel.onopen = function() {
            while (msgQueue.length > 0) {
                msgQueue.shift()();
            }
        }
        wsChannel.onmessage = function(evt) {
            //message received here
        }

        wsChannel.onclose = function(evt) {
            wsChannel = null;
        }

        wsChannel.onerror = function(evt) {
            if (wsChannel.readyState == WebSocketStateEnum.OPEN) {
                wsChannel.close();
            } else {
                wsChannel = null;
            }
        }
    }
}
    InformationsquelleAutor Marco Balieiro
Schreibe einen Kommentar