Socket.io Server zu Server (Senden von Nachrichten an bestimmte Server)

Question

Ich habe eine bestimmte Situation. Ich habe Client (Browser), der eine Verbindung zu Server A herstellt. Server A ist mit Server B und C verbunden. Wenn Client eine Nachricht an Server A sendet, muss ich eine Nachricht an einen bestimmten Server senden, dh an einen der Server B oder C beide. Im Allgemeinen brauche ich getrennte Kommunikation zwischen Servern, aber ich habe nur Kommunikation übertragen. Die Nachricht von Server A an einen anderen Server kann nicht auf allen verbundenen Servern angezeigt werden.

Wie kann ich Nachrichten direkt an einen der Server senden? Hier ist mein Code-Snippet für Server. Ich ändere nur die Ports für jeden Server und verbinde sie.

// Load requirements 
var PORT = process.env.PORT || 8080;//just change port for other servers 
var express = require("express"); 
var app = express(); 
var http = require("http").Server(app); 
var io = require("socket.io")(http); 

app.use(express.static(__dirname + '/public')); 

var client = require('socket.io-client'); 

var socket1 = client.connect('http://localhost:8081', { reconnect: true });//connection to server B 
var socket2 = client.connect('http://localhost:8082', { reconnect: true });//connection to server C 

// Add a connect listener 
io.on('connection', function (socket) { 
    console.log('Client connected.'); 
//when server receive message from client 
    socket.on('message_from_browser', function (message) { 
     console.log("Message from browser broadcasted: " + message.text); 
     var updated_message = { 
      text: message.text, 
      port: PORT 
     }; 

     // send message to server B 
     socket1.emit('server_message', updated_message);//send message to server B 
    }); 

    // Disconnect listener 
    socket.on('disconnect', function() { 
     console.log('Client disconnected.'); 
    }); 
}); 

socket1.on('connect', function() { 
    socket1.on('server_message', function (message) { 
     console.log('RECEIVED MESSAGE FROM ANOTHER SERVER ON PORT '+ message.port + ": " + message.text); 
    }); 
    //change server name 
    console.log('Connected to server B!'); 
}); 

socket2.on('connect', function() { 
    socket2.on('server_message', function (message) { 
     console.log('RECEIVED MESSAGE FROM ANOTHER SERVER ON PORT '+ message.port + ": " + message.text); 
    }); 
    //change server name 
    console.log('Connected to server C!'); 
}); 

http.listen(PORT, function (req, res) { 
    console.log("Server Started on port: " + PORT); 
}); 

Answer 1

Sie haben einen Namenskonflikt mit dem Variablennamen socket. Es ist sowohl als Ihre Verbindung zu Server B als auch als ein Argument in Ihrem .on('connection', function(socket) {...}) Callback definiert.

Um das zu beheben, ändern Sie diese:

var socket = client.connect('http://localhost:8081', { reconnect: true });//connection to server B 
var socket2 = client.connect('http://localhost:8082', { reconnect: true });//connection to server C 

Um dies:

var socket1 = client.connect('http://localhost:8081', { reconnect: true });//connection to server B 
var socket2 = client.connect('http://localhost:8082', { reconnect: true });//connection to server C 

Und dann beziehen sich auf die Server-B-Verbindung als socket1, nicht socket.

Die Variable socket genannt bereits als Argument in dieser definiert ist, so dass Sie nicht die äußere socket Variable erreichen, wenn es einen Konflikt stehenden Namen hat:

// Add a connect listener 
io.on('connection', function (socket) { 
    // socket variable name ^^^^^^ 
    console.log('Client connected.'); 
//when server receive message from client 
    socket.on('message_from_browser', function (message) { 
     console.log("Message from browser broadcasted: " + message.text); 
     var updated_message = { 
      text: message.text, 
      port: PORT 
     }; 

     // send message to server B 
     socket1.emit('server_message', updated_message);//send message to server B 
    }); 

    // Disconnect listener 
    socket.on('disconnect', function() { 
     console.log('Client disconnected.'); 
    }); 
}); 

Und es gab keine Zuhörer für eingehende Server-Nachrichten, so dass Sie benötigen Hinzufügen von Listenern für socket1 und socket2.

io.on('connect', function(socket1){ 
    socket1.on('server_message', function (message) { 
     console.log('RECEIVED MESSAGE FROM ANOTHER SERVER ON PORT '+ message.port + ": " + message.text); 
    }); 
}); 

io.on('connect', function(socket2){ 
    socket2.on('server_message', function (message) { 
     console.log('RECEIVED MESSAGE FROM ANOTHER SERVER ON PORT '+ message.port + ": " + message.text); 
    }); 
}); 

Answer 2

Verwenden Sie eine Variable und configs andere Hosts zu verfolgen, versuchen:

Aktualisiert einige Fehler zu beheben:

// Load requirements 
var PORT = process.env.PORT || 8081;//just change port for other servers 
var express = require("express"); 
var app = express(); 
var http = require("http").Server(app); 
var io = require("socket.io")(http); 
var async = require('async'); // async is optional for this example ... 
var client = require('socket.io-client'); 

app.use(express.static(__dirname + '/public')); 

// save hosts here ... 
var otherServers = { 
    server1: { 
    url: 'http://localhost:8082' 
    }, 
    server2: { 
    url: 'http://localhost:8083' 
    }, 
}; 

// Add a connect listener 
io.on('connection', function (socket) { 
    console.log('Client connected.'); 
    //when server receive message from client 
    socket.on('message_from_browser', function (message) { 
     console.log("Message from browser broadcasted: " + message.text); 
     var updated_message = { 
     text: message.text, 
     port: PORT 
     }; 

     // choice how server will receive this message ... 
     // then send it 
     otherServers.server1.client.broadcast.emit('server_message', updated_message); 
    }); 

    // Disconnect listener 
    socket.on('disconnect', function() { 
     console.log('Client disconnected.'); 
    }); 
}); 

async.each(otherServers, function forEachOtherServer(otherServer, next) { 
    //connect to another server 
    otherServer.client = client.connect(otherServer.url, { reconnect: true }); 
    // to something more if need in every client connection ... 

    otherServer.client.on('connect', function (x) { 

    otherServer.client.on('server_message', function (message) { 
     console.log('RECEIVED MESSAGE FROM ANOTHER SERVER ON PORT '+ message.port + ": " + message.text); 
     //socket.broadcast.emit('message_from_server', message_server); 
    }); 
    console.log('Connected!'); 
    }); 

    next(); 
}, function afterConnectInAllServers(err) { 
    if (err) throw err; 
    // to something after connect in all servers ... 
}); 

http.listen(PORT, function (req, res) { 
    console.log("Server Started on port: " + PORT); 
});