NodeJS क्लस्टर-हब। क्लस्टर मैसेजिंग, अनुरोध, इंटरप्रोसेस एक्सक्लूसिव लॉक्स (क्रिटिकल सेक्शन)

क्लस्टर मॉड्यूल के साथ एक बार फिर से काम करना, मुझे वर्कफ़्लोज़ के बीच मैसेजिंग की आवश्यकता का सामना करना पड़ा। दुर्भाग्य से, मॉड्यूल की मानक कार्यक्षमता आपको केवल मास्टर प्रक्रिया से कार्यकर्ता, और विपरीत दिशा में संदेश भेजने की अनुमति देती है। इस मामले में, संदेश के लिए किसी प्रकार की प्रतिक्रिया प्राप्त करने का कोई तरीका नहीं है, लेकिन मैं वास्तव में करना चाहूंगा। इसलिए मैंने एक क्लस्टर-हब मॉड्यूल लिखा। शायद कोई काम आएगा।

मॉड्यूल की अनुमति देता है

• संदेश भेजें मास्टर-> कार्यकर्ता, कार्यकर्ता-> मास्टर, मास्टर-> मास्टर
• अनुरोध भेजें और प्रतिक्रियाएं प्राप्त करें (कॉलबैक के माध्यम से)
• अनन्य कुंजी ताले (महत्वपूर्ण अनुभाग) का उपयोग करें

कौन परवाह करता है - मैं एक बिल्ली के लिए पूछता हूं।

संदेश सेवा

सबसे सरल कार्यक्षमता बस अन्य प्रक्रियाओं को संदेश भेज रही है। मास्टर से कार्यकर्ता तक, कार्यकर्ता से मास्टर तक, मास्टर से मास्टर तक संदेश भेजना संभव है।

var Hub = require('cluster-hub'); var cluster = require('cluster'); var hub = new Hub(cluster); if (cluster.isMaster) { var worker = cluster.fork(); hub.on('master-to-master', function (data) { console.log('master-to-master received'); }); hub.on('worker-to-master', function (data) { console.log('worker-to-master received'); }); hub.sendToMaster('master-to-master', 1); hub.sendToWorker(worker, 'master-to-worker'); } else { hub.on('master-to-worker', function () { console.log('master-to-worker received');; process.exit(); }); hub.sendToMaster('worker-to-master', 2); } 

प्रस्तुत करने का अनुरोध

यह कार्यक्षमता आपको एक प्रक्रिया से दूसरी प्रक्रिया में अनुरोध भेजने और कॉलबैक फ़ंक्शन के अंदर परिणाम प्राप्त करने की अनुमति देती है। उदाहरण खुद के लिए सब कुछ कहेगा:

 var Hub = require('cluster-hub'); var cluster = require('cluster'); var hub = new Hub(cluster); if (cluster.isMaster) { // in master process hub.on('sum', function (data, sender, callback) { callback(null, data.a + data.b); }); var worker = cluster.fork(); } else { //in worker process hub.requestMaster('sum', {a: 1, b:2}, function (err, sum) { console.log('Sum in worker: ' + sum); process.exit(); }); } 

सादृश्य द्वारा, आप मास्टर प्रक्रिया से कार्यकर्ता प्रक्रिया पर विधि को लागू करने के लिए requestWorker विधि का उपयोग कर सकते हैं।

विशिष्ट ताले / महत्वपूर्ण अनुभाग

यह कार्यक्षमता आपको संसाधन में से किसी एक प्रक्रिया के लिए अनन्य उपयोग करने की अनुमति देती है (यह कोई फर्क नहीं पड़ता - मास्टर या कार्यकर्ता में से एक)। यदि कार्यकर्ता प्रक्रिया लॉक किए गए संसाधन के लिए अनलॉक किए बिना अपने काम को रोकती है, तो संसाधन स्वचालित रूप से मुक्त हो जाएगा।

 var Hub = require('cluster-hub'); var cluster = require('cluster'); var hub = new Hub(cluster); if (cluster.isMaster) { var worker = cluster.fork(); hub.lock('foo', function (unlock) { console.log('foo lock in master'); setTimeout(unlock, 1000); }); } else { hub.lock('foo', function (unlock) { console.log('foo lock in worker 1'); setTimeout(unlock, 500); }); hub.lock('bar', function (unlock) { console.log('bar lock in worker'); unlock(); }) hub.lock('foo', function (unlock) { console.log('second foo lock in worker'); unlock(); process.exit(); }) } 

मॉड्यूल स्रोत कोड यहां उपलब्ध हैं: github.com/sirian/node-cluster-hub