Garder objet de connexion NodeJS dans la base de données partagée/mémoire

Question

sous Debian 8 avec NodeJS 6 et jouent autour de la plate-forme IBM Watson IdO: https://github.com/ibm-watson-iot/iot-nodejs

J'ai créé une passerelle IBM, et sont en mesure pour se connecter et publier des données avec le code suivant:

var gatewayClient = new iotf.IotfGateway(config); 

gatewayClient.connect(); 

gatewayClient.on('connect', function(){ 
    gatewayClient.publishGatewayEvent("status","json",'{"d" : { "cpu" : 60, "mem" : 50 }}'); 

}); 

La configuration contient des informations uniques concernant ma passerelle unique.

Mon défi est maintenant, que je voudrais être en mesure de réutiliser ce gatewayClient dans d'autres instances de NodeJS. Donc, je pense à quelque chose comme ce qui suit (pseudo-code):

var gatewayClient = new iotf.IotfGateway(config); 
gatewayClient.connect(); 

sharedDatabase-perhaps-Redis[unique-gatewayClient-ID].push(gatewayClient); 

Et puis je peux appeler tout NodeJS sur le même serveur:

sharedDatabase-perhaps-Redis[unique-gatewayClient-ID].publishGatewayEvent("status","json",'{"d" : { "cpu" : 60, "mem" : 50 }}'); 

J'espère que ce sens, mais Je suis un peu confus si c'est archivable et comment, et si Redis pourrait être une solution ou une autre base de données-genre-de-chose. L'idée est de pouvoir garder la connexion active/persistante et de faire en sorte que les clients de différentes instances NodeJS transmettent des données via celle-ci, sans créer de nouvelles connexions.

Answer 1

Les connexions réseau ne sont pas sérialisables et ne peuvent pas être facilement partagées entre les processus. Au lieu de cela, vous devriez envisager de créer un seul processus «maître» qui maintient la connexion avec le backend IBM et les clients communiqueront avec ce maître plutôt qu'avec IBM directement (pour les objets IoT, une méthode de communication commune utilise MQTT).

En outre, qu'est-ce qui vous empêche d'exécuter le code qui sera exécuté dans ces processus Node.js distincts en un seul processus? Cela résoudrait aussi le problème, car chaque pièce pourrait utiliser directement la connexion. D'après ce que je comprends, vous avez déjà un seul processus serveur qui accepte les messages client et devrait relayer ces messages au backend IBM. Pour chaque client unique, vous souhaitez créer une nouvelle connexion au backend ou réutiliser une connexion créée précédemment.

Vous pouvez utiliser quelque chose comme ça (gestion des erreurs retenu par souci de concision):

// Function to get the connection for a particular client id, 
// or, if one doesn't exist yet, create a new one. 

let clients = {}; 
function connectionForClient(uniqueGatewayClientID) { 
    // Check if we already have a connection for this client. 
    if (! clients[uniqueGatewayClientID]) 

    // No, create a new one, represented by a promise. 
    clients[uniqueGatewayClientID] = new Promise(function(resolve) { 
     let client = new iotf.IotfGateway(config); 

     client.connect(); 

     client.on('connect', function() { 
     resolve(client); 
     }); 
    }); 

    } 
    return clients[uniqueGatewayClientID]; 
} 

Pour utiliser:

connectionForClient(uniqueGatewayClientID).then(function(client) { 
    client.publishGatewayEvent("status","json",'{"d" : { "cpu" : 60, "mem" : 50 }}'); 
});