समय के साथ, प्रत्येक परियोजना बढ़ती है और एक मौजूदा मोनोलिथ में नई कार्यक्षमता को लागू करना व्यापार के लिए अधिक कठिन, लंबा और अधिक महंगा हो जाता है।

इस समस्या के समाधानों में से एक है माइक्रोसैसवर्क आर्किटेक्चर का उपयोग। शुरुआती लोगों के लिए या जो पहली बार इस वास्तुकला में नए हैं, उनके लिए यह पता लगाना मुश्किल हो सकता है कि कहां से शुरू करें, क्या करना है, और क्या करने लायक नहीं है।

यह लेख Nodejs और RabbitMQ पर सबसे सरल माइक्रोसेवा लिखेगा, और एक मोनोलिथ को माइक्रोसर्विस में स्थानांतरित करने की प्रक्रिया को भी दर्शाता है।

माइक्रोसर्विस आर्किटेक्चर में क्या है?

1. गेटवे। मुख्य सर्वर जो अनुरोध प्राप्त करता है और उन्हें वांछित माइक्रोसिस्टवर्क पर पुनर्निर्देशित करता है। अधिक बार नहीं, गेटवे में कोई व्यावसायिक तर्क नहीं है।
2. Microservice। स्वयं माइक्रोसेवर, जो स्पष्ट रूप से परिभाषित व्यावसायिक तर्क के साथ उपयोगकर्ता के अनुरोधों को संसाधित करता है।
3. परिवहन। यह वह हिस्सा है जिसके माध्यम से गेटवे और माइक्रोसेवा संवाद करेंगे। परिवहन HTTP, gRPC, RabbitMQ, आदि हो सकता है।

क्यों RabbitMQ?

बेशक, आप RabbitMQ का उपयोग नहीं कर सकते हैं, माइक्रोसर्विस के बीच संचार के लिए अन्य विकल्प हैं। सबसे सरल HTTP है, Google से gRPC है।

मैं RabbitMQ का उपयोग करता हूं क्योंकि मुझे यह बहुत आसान लगता है कि मैं माइक्रोसॉर्फ़िस लिखना शुरू करूं, विश्वसनीय और सुविधाजनक इस में कि आप यह सुनिश्चित कर सकते हैं कि कतार में एक संदेश भेजने से संदेश माइक्रोसिस्टवर्क तक पहुंच जाएगा (भले ही वह इस समय बंद हो और फिर चालू हो )। इन फायदों के लिए धन्यवाद, आप विश्वसनीय माइक्रोसर्विसेज लिख सकते हैं और एक सहज तैनाती का उपयोग कर सकते हैं।

शुरुआत

सबसे पहले, हम एक साधारण गेटवे लागू करते हैं जो एक विशिष्ट पोर्ट को सुनते हुए HTTP अनुरोध प्राप्त करेगा।

हम RabbitMQ को तैनात करते हैं (इसके माध्यम से हमारे माइक्रोसर्विसेज और गेटवे संवाद करेंगे):

$ docker run -d -p 5672:5672 rabbitmq 

हम इस परियोजना को शुरू करते हैं और micromq NPM पैकेज स्थापित करते हैं:

 $ npm init -y $ npm i micromq -S 

गेटवे लिखना

 //   Gateway     micromq const Gateway = require('micromq/gateway'); //    Gateway const app = new Gateway({ //  ,      microservices: ['users'], //  rabbitmq rabbit: { //     rabbitmq (default: amqp://guest:guest@localhost:5672) url: process.env.RABBIT_URL, }, }); //    /friends & /status   GET app.get(['/friends', '/status'], async (req, res) => { //     users await res.delegate('users'); }); //    app.listen(process.env.PORT); 

यह कैसे काम करेगा:

1. सर्वर शुरू होता है, यह पोर्ट को सुनना और अनुरोध प्राप्त करना शुरू कर देता है
2. उपयोगकर्ता https://mysite.com/friends पर एक अनुरोध भेजता है
3. गेटवे, हमारे द्वारा वर्णित तर्क के अनुसार, अनुरोध को दर्शाता है:
   3.1 एक संदेश भेजा जा रहा है (अनुरोध पैरामीटर, हेडर, कनेक्शन जानकारी, आदि) RabbitMQ कतार में
   3.2। माइक्रोसॉर्स्ट इस कतार को सुनता है, एक नया अनुरोध करता है
   3.3। Microservice कतार के लिए एक प्रतिक्रिया भेजता है
   3.4। गेटवे एक प्रतिक्रिया कतार के लिए सुनता है, एक microservice से प्रतिक्रिया प्राप्त करता है
   3.5। गेटवे ग्राहक को एक प्रतिक्रिया भेजता है
4. उपयोगकर्ता को एक प्रतिक्रिया मिलती है।

हम एक microservice लिखते हैं

 //   MicroService     micromq const MicroMQ = require('micromq'); //    MicroService const app = new MicroMQ({ //   (    ,    Gateway) name: 'users', //  rabbitmq rabbit: { //     rabbitmq (default: amqp://guest:guest@localhost:5672) url: process.env.RABBIT_URL, }, }); //   /friends   GET app.get('/friends', (req, res) => { //  json  res.json([ { id: 1, name: 'Mikhail Semin', }, { id: 2, name: 'Ivan Ivanov', }, ]); }); //   /status   GET app.get('/status', (req, res) => { //  json  res.json({ text: 'Thinking...', }); }); //     app.start(); 

यह कैसे काम करेगा:

1. माइक्रोसर्विस शुरू होता है, गेटवे लिखेगा अनुरोध कतार को सुनना शुरू करता है।
2. माइक्रोसर्विस अनुरोध को प्राप्त करता है, इसे संसाधित करता है, सभी उपलब्ध मिडलवेयर के माध्यम से चल रहा है
3. माइक्रोवेस्ट गेटवे के लिए एक प्रतिक्रिया भेजता है
   3.1। संदेश भेजा जा रहा है (हेडर, HTTP कोड प्रतिक्रिया निकाय) RabbitMQ कतार में
   3.2। गेटवे इस कतार को सुनता है, एक संदेश प्राप्त करता है, एक ग्राहक को पाता है जिसे उसे प्रतिक्रिया भेजने की आवश्यकता होती है
   3.3 गेटवे क्लाइंट को एक प्रतिक्रिया भेजता है

माइक्रोलेस्ट आर्किटेक्चर के लिए मोनोलिथ माइग्रेशन

मान लें कि हमारे पास पहले से ही एक एक्सप्रेस एप्लिकेशन है, और हम इसे माइक्रोसिस्टर्स के लिए पोर्ट करना शुरू करना चाहते हैं।

यह इस तरह दिखता है:

 const express = require('express'); const app = express(); app.get('/balance', (req, res) => { res.json({ amount: 500, }); }); app.get('/friends', (req, res) => { res.json([ { id: 1, name: 'Mikhail Semin', }, { id: 2, name: 'Ivan Ivanov', }, ]); }); app.get('/status', (req, res) => { res.json({ text: 'Thinking...', }); }); app.listen(process.env.PORT); 

हम इसमें से 2 समापन बिंदु प्राप्त करना चाहते हैं: / मित्र और / स्थिति। इसके लिए हमें क्या करने की आवश्यकता है?

1. एक माइक्रोसेवा में व्यावसायिक तर्क खींचो
2. इन दो समापन बिंदुओं के लिए अनुरोधों के प्रतिनिधिमंडल को माइक्रो सर्विस पर लागू करें
3. Microservice से प्रतिक्रिया प्राप्त करें
4. ग्राहक को प्रतिक्रिया भेजें

ऊपर दिए गए उदाहरण में, जब हमने उपयोगकर्ताओं को माइक्रो-सर्विस बनाया, तो हमने दो तरीके / मित्र और / स्थिति को लागू किया, जो कि हमारे मोनोलिथ करता है।

गेटवे से microservice के लिए प्रॉक्सी अनुरोधों के लिए, हम मिडवेवेयर को हमारे एक्सप्रेस एप्लिकेशन से जोड़कर उसी पैकेज का उपयोग करेंगे:

 const express = require('express'); //   Gateway     micromq const Gateway = require('micromq/gateway'); const app = express(); //    Gateway const gateway = new Gateway({ //   (    ,    Gateway) microservices: ['users'], //  rabbitmq rabbit: { //     rabbitmq (default: amqp://guest:guest@localhost:5672) url: process.env.RABBIT_URL, }, }); //  middleware  ,      app.use(gateway.middleware()); //    ,          app.get('/balance', (req, res) => { res.json({ amount: 500, }); }); //    /friends & /status   GET app.get(['/friends', '/status'], async (req, res) => { //     users //  res.delegate   middleware,     await res.delegate('users'); }); //   app.listen(process.env.PORT); 

यह उसी तरह काम करता है जैसे ऊपर के उदाहरण में, जहां हमने एक साफ गेटवे लिखा था। इस उदाहरण में, केवल अंतर यह है कि यह गेटवे नहीं है जो अनुरोधों को स्वीकार करता है, लेकिन एक मोनोलिथ जिसे व्यक्त किया गया है।

आगे क्या है

1. एक microservice से एक मोनोलिथ / गेटवे के लिए RPC (रिमोट एक्शन कॉल) (उदाहरण के लिए, प्राधिकरण के लिए)
2. अधिक जानकारी के लिए RabbitMQ कतारों के माध्यम से माइक्रोसर्विसेज के बीच संवाद स्थापित करें, क्योंकि प्रत्येक माइक्रोसेवा का अपना डेटाबेस होता है

मैंने पहले ही इस लेख में कहा था "RabbitMQ के माध्यम से Node.js पर माइक्रोसर्विसेज के बीच संवाद करना सीखना" ।

• पुस्तकालय के स्रोत कोड से लिंक करें
• एनपीएम-रजिस्ट्री में पैकेज का लिंक
• लेख में कोड उदाहरण