MongoDB
 sql >> डेटाबेस >  >> NoSQL >> MongoDB

Nodejs - वेबसोकेट-नोड मॉड्यूल:मल्टी-क्लाइंट सॉकेट-सर्वर कैसे काम करता है?

आप सर्वर साइड पर कनेक्शन स्टोर नहीं कर रहे हैं। आप सर्वर पर सीधे आगे और पीछे संचार करने के लिए उन्हें सर्वर पर स्थापित कर रहे हैं। यदि आप चाहते हैं कि सर्वर पर जाने वाले संदेशों को सभी को वापस भेजा जाए, तो आपको .on('message', ...) सेट करना होगा। सर्वर पर प्रत्येक कनेक्शन के लिए उस व्यवहार के लिए कार्य करता है। ऐसा करने के लिए, आपको कनेक्शन बनाए जाने के साथ ही उन्हें संग्रहीत करने की आवश्यकता होगी। इसे आजमाएं:

var WebSocketServer = require('websocket').server;
var http = require('http');

var server = http.createServer(function(request, response) {
    console.log((new Date()) + ' Received request for ' + request.url);
    response.writeHead(404);
    response.end();
});
server.listen(5050, function() {
    console.log((new Date()) + ' Server is listening on port 5050');
});

wsServer = new WebSocketServer({
    httpServer: server,
    // You should not use autoAcceptConnections for production 
    // applications, as it defeats all standard cross-origin protection 
    // facilities built into the protocol and the browser.  You should 
    // *always* verify the connection's origin and decide whether or not 
    // to accept it. 
    autoAcceptConnections: false
});

function originIsAllowed(origin) {
  // put logic here to detect whether the specified origin is allowed. 
  return true;
}

//create an array to hold your connections
var connections = [];

wsServer.on('request', function(request) {
    if (!originIsAllowed(request.origin)) {
      // Make sure we only accept requests from an allowed origin 
      request.reject();
      console.log((new Date()) + ' Connection from origin ' + request.origin + ' rejected.');
      return;
    }
    var connection = request.accept('echo-protocol', request.origin);

    //store the new connection in your array of connections
    connections.push(connection);
    
    console.log((new Date()) + ' Connection accepted.');
    connection.on('message', function(message) {
        if (message.type === 'utf8') {
            console.log('Received Message: ' + message.utf8Data);

            //send the received message to all of the 
            //connections in the connection array
            for(var i = 0; i < connections.length; i++) {
                connections[i].sendUTF(message.utf8Data);
            }
        }
        else if (message.type === 'binary') {
            console.log('Received Binary Message of ' + message.binaryData.length + ' bytes');
            connection.sendBytes(message.binaryData);
        }
    });
    connection.on('close', function(reasonCode, description) {
        console.log((new Date()) + ' Peer ' + connection.remoteAddress + ' disconnected.');
    });
});



  1. Redis
  2.   
  3. MongoDB
  4.   
  5. Memcached
  6.   
  7. HBase
  8.   
  9. CouchDB
  1. MongoDB - सॉकेट के लिए अनुमति अस्वीकृत:/tmp/mongodb-27017.sock

  2. नेवला में जुड़ने और फ़िल्टर के साथ क्वेरी करना

  3. नेवला में ऑटो वेतन वृद्धि आईडी

  4. क्वेरी MongoDB केवल विशिष्ट घंटों में खोजें

  5. MongoDB कई सरणियों को खोल देता है