socket.io

Question

का उपयोग कर कनेक्टेड क्लाइंट की एक सूची बनाएं यहां 2 संबंधित प्रश्न हैं। उन्हें एक साथ पोस्ट करना और अधिक समझ में आता है।

प्रश्न 1

मैं जो सभी ग्राहकों के लिए बाहर एक घटना का उत्सर्जन करता है एक Node.js एप्लिकेशन है, और सभी मौजूदा ग्राहकों को एक ready फेंकना के साथ जवाब देंगे। मैं उन सभी ग्राहकों की एक सूची कैसे बना सकता हूं जो प्रारंभिक उत्सर्जन का उत्तर देते हैं, और ग्राहकों को अलग करने के लिए किस प्रकार की पहचान का उपयोग किया जा सकता है?

Question2:

मैं के बाद क्या करना जुड़ा ग्राहकों की सूची एकत्रित कोशिश कर रहा हूँ क्या है, तो पंक्तियों की N संख्या का एक MySQL डेटाबेस तालिका को एक्सेस और प्रत्येक ग्राहक X पंक्तियों प्रत्येक आवंटित करने के लिए है। ये पंक्तियां अपने संबंधित ग्राहकों को वापस भेज दी जाएंगी। यह कैसे किया जा सकता है?

वर्तमान कोड Qn 1

नोड कोड

setInterval(function() { 
    util.log('Checking for new jobs...'); 
    dbCheckQueue(function(results) { // checks if there are new rows to "distribute" to clients 
     if (results.length) { 
      util.log(results.length + ' new jobs found.'); 
      io.sockets.emit('job_available'); 
     } 
    }); 
}, 10*1000); 

क्लाइंट-साइड जे एस कोड

socket.on('job_available', function() { 
       console.log('Job Available.. Responding with Ready!'); 
       socket.emit('ready'); 
      }); 

io.sockets.on('connection', function(socket) { 
    socket.on('ready', function() { 
     // UPDATE N rows with client_id in column checkout. 
     // Then SELECTS * from table where checkout = client_id 
     getListings(client_id, function(listings) { 
      socket.emit('job', listings); // send jobs 
     }); 
    }); 
}); 

वर्तमान कोड Qn 2 के लिए ०१२३५१६४१०६ के लिएकोड एक क्लाइंट के लिए काम करता है, लेकिन मैं सभी कनेक्टेड क्लाइंट्स के माध्यम से कैसे लूप करता हूं और कॉलम का वही अद्यतन करता हूं और पंक्तियों का चयन करता हूं?

io.sockets.on('connection', function(socket) { 
    socket.on('ready', function() { 
     // UPDATE N rows with client_id in column checkout. 
     // Then SELECTS * from table where checkout = client_id 
     getListings(client_id, function(listings) { 
      socket.emit('job', listings); // send jobs 
     }); 
    }); 
}); 

Answer 1

आप कनेक्ट किए गए ग्राहकों खुद का ट्रैक रखने की जरूरत होगी। अपने ready ईवेंट हैंडलर या जो कुछ भी में

var clients = []; 

io.sockets.on('connect', function(client) { 
    clients.push(client); 

    client.on('disconnect', function() { 
     clients.splice(clients.indexOf(client), 1); 
    }); 
}); 

तो फिर तुम कर सकते हैं संदर्भ है कि सर्वर पर clients सरणी भी आप की जरूरत है,: ऐसा करने के लिए आसान तरीका एक सरणी का उपयोग करने के लिए होगा। कुछ की तरह:

io.sockets.on('connection', function(socket) { 
    socket.on('ready', function() { 
     // UPDATE N rows with client_id in column checkout. 
     // Then SELECTS * from table where checkout = client_id 
     clients.forEach(function(client, index) { 
      var client_id = index; // Just use the index in the clients array for now 
      getListings(client_id, function(listings) { 
       socket.emit('job', listings); // send jobs 
      }); 
     }); 
    }); 
}); 

Answer 2

Socket.io कि के लिए एक सार्वजनिक एपीआई प्रदान करता है, इसलिए बजाय ब्रायन की तरह कुछ ऊपर हैकिंग के सुझाव है कि आप उपयोग कर सकते हैं:

io.sockets.clients() 

सभी जुड़े हुए की एक सरणी देता होगा कि ग्राहकों।

आप एक निश्चित नाम स्थान से जुड़े सभी ग्राहकों चाहते हैं:

io.of('/namespace').clients() 

लेकिन आप भी .. यह और भी अधिक फ़िल्टर अगर आप एक कमरे में सब सॉकेट करना चाहते हैं कर सकते हैं:

io.sockets.clients('room name here as first argument') 

कमरे के लिए जुड़ा सॉकेट की एक सरणी वापस आ जाएगी room name here as first argument