Komunikacja pracowników sieci za pomocą MessageChannel HTML5

Oto czysty przykład w czystym javascript, jak skonfigurować to między dwoma robotami:

W głównym wątku:

function setup(){
    var channel = new MessageChannel();
    var worker1 = new Worker("worker1.js");
    var worker2 = new Worker("worker2.js");

    // Setup the connection: Port 1 is for worker 1
    worker1.postMessage({
        command : "connect",
    },[ channel.port1 ]);

    // Setup the connection: Port 2 is for worker 2
    worker2.postMessage({
        command : "connect",
    },[ channel.port2 ]);

    worker1.postMessage({
        command: "forward",
        message: "this message is forwarded to worker 2"
    });
}

W worker1.js:

var worker2port;
var onMessageFromWorker2 = function( event ){
    console.log("Worker 1 received a message from worker 2: " + event.data);

    //To send something back to worker 2
    //worker2port.postMessage("");
};

self.onmessage = function( event ) {
    switch( event.data.command )
    {
        // Setup connection to worker 2
        case "connect":
            worker2port = event.ports[0];
            worker2port.onmessage = onMessageFromWorker2;
            break;

        // Forward messages to worker 2
        case "forward":
            // Forward messages to worker 2
            worker2port.postMessage( event.data.message );
            break;

        //handle other messages from main
        default:
            console.log( event.data );
    }
};

W worker2.js

var worker1port;
var onMessageFromWorker1 = function( event ){
    console.log("Worker 2 received a message from worker 1: " + event.data);

    //To send something back to worker 1
    //worker1port.postMessage("");
};

    self.onmessage = function( event ) {
    switch( event.data.command )
    {
        // Setup connection to worker 1
        case "connect":
            worker1port = event.ports[0];
            worker1port.onmessage = onMessageFromWorker1;
            break;

        // Forward messages to worker 1
        case "forward":
            // Forward messages to worker 1
            worker1port.postMessage( event.data.message );
            break;

        //handle other messages from main
        default:
            console.log( event.data );
    }
};

To pokazuje, jak obsługiwać wiadomości z głównego wątku, jak możesz przekazywać wiadomości z głównego wątku do drugiego pracownika i jak komunikować się między pracownikami bezpośrednio bez udziału głównego wątku.

Twoje demo faktycznie działa dla mnie (Chrome 23.0.1271.101). Dostaję DATA_CLONE_ERR tylko wtedy, gdy nacisnę drugi przycisk "Wyślij do subworker". Prawdopodobnie tego się oczekuje. Wysłałeś już port2 swojego MessageChannel do pracownika z pierwszym postMessage wywołaniem zaraz po utworzeniu kanału. To prawdopodobnie nielegalne, aby wysłać go ponownie, choć nie mogę znaleźć żadnej wyraźnej dokumentacji na ten temat.

To, co prawdopodobnie chcesz zrobić, to ustawić onmessage na porcie odbieranym w workerze, wtedy możesz obsłużyć wiadomości wysyłane przez port w przyszłości. Coś w stylu:

onmessage = getMessage;

function getMessage(e){
  if(e.ports[0]) {
    var receivedPort = e.ports[0];
    receivedPort.postMessage("msg from sub worker 1 "+ e.data);
    receivedPort.onmessage = getPortMessage
  }
  else
    postMessage("msg from sub worker 1 "+ e.data);
}

function getPortMessage(e) {
  // Messages sent through the port will be handled here
}