👩‍🎨 ⏫ 👰🏻 मोलेक्यूलर माइक्रोसवर्क फ्रेमवर्क को जानें 🕺🏻 🚷 🥤

ह% हबनस%!

आज मैं आपको एक उत्कृष्ट के बारे में बताना चाहता हूं, मेरी राय में, मोलेक्यूलर माइक्रोसवर्क सेवा।

प्रारंभ में, यह रूपरेखा Node.js में लिखी गई थी, लेकिन बाद में यह जावा, गो, पायथन और .NET जैसी अन्य भाषाओं में बंदरगाहों पर दिखाई दी और, सबसे अधिक संभावना है, अन्य कार्यान्वयन निकट भविष्य में दिखाई देंगे । हम लगभग एक वर्ष से कई उत्पादों में इसका उपयोग कर रहे हैं और यह शब्दों के साथ वर्णन करना कठिन है कि सीनेका और हमारी बाइक का उपयोग करने के बाद वह हमें कितना धन्य लगता था। हमें वह सब कुछ चाहिए जो हमें बॉक्स से बाहर चाहिए: मेट्रिक्स, कैशिंग, बैलेंसिंग, फॉल्ट-टॉलरेंस, सेलेक्ट ट्रांसपोर्ट, पैरामीटर वेरिफिकेशन, लॉगिंग, संक्षिप्त विधि घोषणाएँ, कई तरह के चौराहों के इंटरैक्शन, मिक्सिन्स और बहुत कुछ। और अब क्रम में।

परिचय

फ्रेमवर्क, वास्तव में, तीन घटक होते हैं (वास्तव में, नहीं, लेकिन आप नीचे इस बारे में अधिक जानेंगे)।

ट्रांसपोर्टर

उनके बीच सेवाओं और संचार की खोज के लिए जिम्मेदार। यह एक इंटरफ़ेस है जो एक बड़ी इच्छा के साथ, आप खुद को लागू कर सकते हैं, या आप तैयार किए गए कार्यान्वयन का उपयोग कर सकते हैं जो कि फ्रेमवर्क का हिस्सा हैं। बॉक्स से 7 ट्रांसपोर्ट उपलब्ध हैं: टीसीपी, रेडिस, एएमक्यूपी, एमक्यूटीटी, एनएटीएस, एनएटीएस स्ट्रीमिंग, काफ्का। यहाँ आप अधिक देख सकते हैं। हम Redis परिवहन का उपयोग करते हैं, लेकिन हम प्रयोगात्मक राज्य से बाहर निकलने के साथ टीसीपी पर स्विच करने की योजना बनाते हैं।

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

// ./moleculer.config.js module.exports = { transporter: 'redis://:pa$$w0rd@127.0.0.1:6379', // ...   }

डेटा, डिफ़ॉल्ट रूप से, JSON प्रारूप में आता है। लेकिन आप कुछ भी उपयोग कर सकते हैं: एवरो, MsgPack, Notepack, ProtoBuf, Thrift, आदि।

सेवा

वह वर्ग जिसे हम अपने माइक्रोसर्विसेज लिखते समय विरासत में लेते हैं।

यहाँ विधियों के बिना सबसे सरल सेवा है, जो, हालांकि, अन्य सेवाओं द्वारा पता लगाया जाएगा:

 // ./services/telemetry/telemetry.service.js const { Service } = require('moleculer'); module.exports = class TelemetryService extends Service { constructor(broker) { super(broker); this.parseServiceSchema({ name: 'telemetry', }); } };

सेवा दलाल

ढाँचे का मूल।

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

ब्रोकर होने से हमें एक बहुत ही सुविधाजनक चीज मिलती है। अब मैं समझाने की कोशिश करूँगा, लेकिन मुझे थोड़ा अलग हटना होगा। ढांचे के संदर्भ में नोड जैसी कोई चीज है। सरल शब्दों में, एक नोड ऑपरेटिंग सिस्टम में एक प्रक्रिया है (जो कि, जब हम कंसोल में "नोड index.js" दर्ज करते हैं, उदाहरण के लिए)। प्रत्येक नोड एक या एक से अधिक microservices का एक सेट के साथ एक ServiceBroker है। जी हां, आपने सही सुना। हम अपनी सेवा स्टैक का निर्माण अपनी दिल की इच्छाओं के रूप में कर सकते हैं। यह सुविधाजनक क्यों है? विकास के लिए, हम एक नोड शुरू करते हैं जिसमें सभी माइक्रोसर्विसेज एक ही बार में लॉन्च किए जाते हैं (प्रत्येक प्रत्येक), सिस्टम में केवल एक प्रक्रिया जिसमें बहुत आसानी से हॉट्रेलोड कनेक्ट करने की क्षमता होती है, उदाहरण के लिए। उत्पादन में - सेवा के प्रत्येक उदाहरण के लिए एक अलग नोड। खैर, या एक मिश्रण, जब एक नोड में सेवाओं का हिस्सा, दूसरे में हिस्सा, और इसी तरह (हालांकि मुझे नहीं पता कि ऐसा क्यों करना है, बस यह समझने के लिए कि आप यह भी कर सकते हैं)।

यह हमारे index.js जैसा दिखता है

 const { resolve } = require('path'); const { ServiceBroker } = require('moleculer'); const config = require('./moleculer.config.js'); const { SERVICES, NODE_ENV, } = process.env; const broker = new ServiceBroker(config); broker.loadServices( resolve(__dirname, 'services'), SERVICES ? `*/@(${SERVICES.split(',').map(i => i.trim()).join('|')}).service.js` : '*/*.service.js', ); broker.start().then(() => { if (NODE_ENV === 'development') { broker.repl(); } });

एक पर्यावरण चर की अनुपस्थिति में, निर्देशिका से सभी सेवाओं को लोड किया जाता है, अन्यथा मुखौटा द्वारा। वैसे, ब्रोकर। क्रेप () फ्रेमवर्क की एक और सुविधाजनक विशेषता है। विकास मोड में शुरू करते समय, हम वहीं, कंसोल में, कॉल करने के तरीकों के लिए एक इंटरफ़ेस रखते हैं (आप जो करते हैं, उदाहरण के लिए, आपके माइक्रोफ़ोन में डाकिया के माध्यम से जो http के माध्यम से संचार करता है), केवल यहाँ यह बहुत अधिक सुविधाजनक है: इंटरफ़ेस उसी कंसोल में है जहाँ उन्होंने npm शुरू किया था।

अंतःक्रिया की सहभागिता

इसे तीन तरीकों से किया जाता है:

कॉल

सबसे अधिक उपयोग किया जाता है। एक अनुरोध किया, एक प्रतिक्रिया (या त्रुटि) प्राप्त की।

 //   "report",     "csv". async getCsvReport({ jobId }) { const rows = []; // ... return this.broker.call('csv.stringify', { rows }); }

जैसा कि ऊपर उल्लेख किया गया है, कॉल स्वचालित रूप से संतुलित हैं। हम केवल आवश्यक सेवा संख्या बढ़ाते हैं, और ढांचा ही संतुलन का काम करेगा।

फेंकना

जब हम किसी घटना के बारे में अन्य सेवाओं को सूचित करना चाहते हैं, तब उपयोग किया जाता है, लेकिन हमें परिणाम की आवश्यकता नहीं होती है।

 //   "user"    . async registerUser({ email, password }) { // ... this.broker.emit('user_registered', { email }); return true; }

अन्य सेवाएं इस ईवेंट को सब्सक्राइब कर सकती हैं, और तदनुसार जवाब दे सकती हैं। वैकल्पिक रूप से, तीसरा तर्क, आप इस घटना को प्राप्त करने के लिए उपलब्ध सेवाओं को स्पष्ट रूप से निर्धारित कर सकते हैं।

महत्वपूर्ण बिंदु यह है कि घटना को प्रत्येक प्रकार की सेवा का केवल एक उदाहरण मिलेगा, अर्थात। अगर हमारे पास 10 "मेल" और 5 "सदस्यता" सेवाएं हैं, जो इस घटना के लिए सदस्यता ली जाती हैं, तो वास्तव में केवल 2 प्रतियां इसे प्राप्त होंगी - एक "मेल" और एक "सदस्यता"। योजनाएं इस तरह दिखती हैं:

प्रसारण

उत्सर्जन के समान, लेकिन प्रतिबंधों के बिना। सभी 10 मेल और 5 सदस्यता सेवाएं इस घटना को पकड़ लेंगी।

मापदंडों का सत्यापन

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

जब हम एक सेवा लिखते हैं, तो हम बेस क्लास सर्विस से विरासत में लेते हैं, इसमें व्यापारिक तर्क के साथ तरीकों की घोषणा करते हैं, लेकिन ये तरीके "निजी" हैं, उन्हें बाहर से (किसी अन्य सेवा से) तब तक नहीं बुलाया जा सकता, जब तक कि हम स्पष्ट रूप से उन्हें घोषित नहीं करना चाहते। सेवा आरम्भिकरण के दौरान विशेष क्रियाएं अनुभाग (ढांचे के संदर्भ में सेवाओं के सार्वजनिक तरीकों को क्रियाएं कहा जाता है)।

सत्यापन के साथ एक विधि घोषणा का उदाहरण

 module.exports = class JobService extends Service { constructor(broker) { super(broker); this.parseServiceSchema({ name: 'job', actions: { update: { params: { id: { type: 'number', convert: true }, name: { type: 'string', empty: false, optional: true }, data: { type: 'object', optional: true }, }, async handler(ctx) { return this.update(ctx.params); }, }, }, }); } async update({ id, name, data }) { // ... } }

hagfish

उदाहरण के लिए, डेटाबेस कनेक्शन को इनिशियलाइज़ करने के लिए उपयोग किया जाता है। सेवा से सेवा में कोड के दोहराव से बचें।

रेडिस से कनेक्शन को इनिशियलाइज़ करने के लिए उदाहरण मिक्सिन

 const Redis = require('ioredis'); module.exports = ({ key = 'redis', options } = {}) => ({ settings: { [key]: options, }, created() { this[key] = new Redis(this.settings[key]); }, async started() { await this[key].connect(); }, stopped() { this[key].disconnect(); }, });

सेवा में मिश्रण का उपयोग करना

 const { Service, Errors } = require('moleculer'); const redis = require('../../mixins/redis'); const server = require('../../mixins/server'); const router = require('./router'); const { REDIS_HOST, REDIS_PORT, REDIS_PASSWORD, } = process.env; const redisOpts = { host: REDIS_HOST, port: REDIS_PORT, password: REDIS_PASSWORD, lazyConnect: true, }; module.exports = class AuthService extends Service { constructor(broker) { super(broker); this.parseServiceSchema({ name: 'auth', mixins: [redis({ options: redisOpts }), server({ router })], }); } }

कैशिंग

एलआरयू, मेमोरी, रेडिस: मेथड कॉल (क्रिया) को कई तरीकों से कैश किया जा सकता है। वैकल्पिक रूप से, आप निर्दिष्ट कर सकते हैं कि कौन सी कॉल को कैश किया जाएगा (डिफ़ॉल्ट रूप से, ऑब्जेक्ट हैश का उपयोग कैशिंग कुंजी के रूप में किया जाता है) और जिसके साथ TTL।

कैश्ड विधि घोषणा उदाहरण

 module.exports = class InventoryService extends Service { constructor(broker) { super(broker); this.parseServiceSchema({ name: 'inventory', actions: { getInventory: { params: { steamId: { type: 'string', pattern: /^76\d{15}$/ }, appId: { type: 'number', integer: true }, contextId: { type: 'number', integer: true }, }, cache: { keys: ['steamId', 'appId', 'contextId'], ttl: 15, }, async handler(ctx) { return true; }, }, }, }); } // ... }

कैशिंग विधि ServiceBroker कॉन्फ़िगरेशन के माध्यम से सेट की गई है।

लॉगिंग

यहाँ, हालांकि, सब कुछ भी काफी सरल है। एक बहुत अच्छा निर्मित लॉगर है जो कंसोल को लिखता है, कस्टम स्वरूपण को निर्दिष्ट करना संभव है। कोई भी अन्य लोकप्रिय लकड़हारा चोरी करने से नहीं रोकता है, चाहे वह विंस्टन हो या बनियन। एक विस्तृत मैनुअल प्रलेखन में है । व्यक्तिगत रूप से, हम बिल्ट-इन लॉगर का उपयोग करते हैं, कोड की कुछ पंक्तियों के लिए कस्टम फॉर्मेटर जो कि JSON कंसोल में स्पैम है, बस ठेस में कटा हुआ है, जिसके बाद वे docker log ड्राइवर का उपयोग करते हुए ग्रेग्लॉग में आ जाते हैं।

मैट्रिक्स

यदि वांछित है, तो आप प्रत्येक विधि के लिए मैट्रिक्स एकत्र कर सकते हैं और इसे सभी कुछ जिपकिन में ट्रेस कर सकते हैं। यहाँ निर्यातकों की पूरी सूची उपलब्ध है। वर्तमान में उनमें से पांच हैं: जिपकिन, जेगर, प्रोमेथियस, इलास्टिक, कंसोल। यह विधि (कार्रवाई) की घोषणा करते समय, कैशिंग की तरह कॉन्फ़िगर किया गया है।

इलास्टिक्स- किबना बंडल के लिए लोचदार- एपम -नोड मॉड्यूल का उपयोग करके विज़ुअलाइज़ेशन उदाहरण गिथब में इस लिंक पर देखे जा सकते हैं।

सबसे आसान तरीका, ज़ाहिर है, कंसोल विकल्प का उपयोग करना है। यह इस तरह दिखता है:

दोष सहिष्णुता

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

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

निष्कर्ष

मेरे लिए इस ढांचे की शुरूआत ताजी हवा की सांस बन गई, जिसने भारी मात्रा में बंट को बचाया (इस तथ्य को छोड़कर कि माइक्रोसेर आर्किटेक्चर एक बड़ी बंट है) और साइकिलिंग, ने अगले माइक्रोसेवा को सरल और पारदर्शी लिखा। इसमें कुछ भी शानदार नहीं है, यह सरल और बहुत लचीला है, और आप दस्तावेज़ को पढ़ने के बाद एक या दो घंटे के भीतर पहली सेवा लिख सकते हैं। मुझे खुशी होगी अगर यह सामग्री आपके लिए उपयोगी है और आपकी अगली परियोजना में आप इस चमत्कार को आज़माना चाहेंगे, जैसा कि हमने किया (और अभी तक इसे पछतावा नहीं है)। सभी को अच्छा!

इसके अलावा, यदि आप इस ढांचे में रुचि रखते हैं, तो टेलीग्राम - @moleculerchat में चैट में शामिल हों

मोलेक्यूलर माइक्रोसवर्क फ्रेमवर्क को जानें