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

यह " हम RabbitMQ के माध्यम से संचार के साथ Node.js पर पहला माइक्रोसेवा लिख ​​रहे हैं " लेख की एक निरंतरता है, जिसे हेबर के उपयोगकर्ताओं द्वारा अच्छी तरह से प्राप्त किया गया था।

इस लेख में मैं इस बारे में बात करूंगा कि माइक्रोसर्विस के बीच सही तरीके से कैसे संवाद किया जाए ताकि माइक्रोसॉर्क्स अलग-थलग रहें।

कैसे नहीं करना है

आपको माइक्रोसिस्टर्स के बीच संवाद करने की आवश्यकता क्यों है? एक डेटाबेस का उपयोग करें, वहां से पढ़ें जो आप चाहते हैं - कुछ व्यापार!

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

रोधन लाभ

विश्वसनीयता

मान लीजिए कि एक अखंड अनुप्रयोग है जिसमें कई नियंत्रक हैं:

1. माल
2. छूट
3. ब्लॉग
4. उपयोगकर्ताओं

एक दिन ठीक है, हमारा डेटाबेस गिर रहा है: अब हमें कोई उत्पाद, कोई छूट, कोई ब्लॉग पोस्ट, कोई उपयोगकर्ता नहीं मिल सकता है। साइट पूरी तरह से अनुपलब्ध है, ग्राहक लॉग इन नहीं कर सकते, व्यवसाय लाभ खो रहा है।

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

किसी अन्य ब्रह्मांड में, उसी दिन उपयोगकर्ता माइक्रोसॉरेस डेटाबेस गिर जाता है, यह दुर्गम हो जाता है: उपयोगकर्ता लॉग आउट नहीं कर सकते हैं, पंजीकरण और लॉगिन कर सकते हैं। ऐसा लगता है कि सब कुछ खराब है और व्यवसाय भी लाभ खो रहा है, लेकिन नहीं: संभावित खरीदार उपलब्ध सामानों को देख सकते हैं, कंपनी के ब्लॉग को पढ़ सकते हैं, और छूट पा सकते हैं।

इस तथ्य के कारण कि प्रत्येक microservice का अपना डेटाबेस है, साइड इफेक्ट बहुत कम हो जाते हैं।

इसे क्रमिक गिरावट कहा जाता है ।

मतिहीनता

एक बड़े एप्लिकेशन में, एक कार्य पर ध्यान केंद्रित करना बहुत मुश्किल है, क्योंकि कुछ छोटे मिडलवेयर को बदलने से किसी प्रकार का नियंत्रक टूट सकता है। रेडिस के लिए नए क्लाइंट का उपयोग करना चाहते हैं - नहीं, आप नहीं कर सकते, उस नियंत्रक को जो हमने तीन साल पहले लिखा था, संस्करण 0.1.0 का उपयोग करता है। अंत में Node.js 10 की नई सुविधाओं का लाभ लेना चाहते हैं? या शायद 12? क्षमा करें, लेकिन मोनोलिथ संस्करण 6 का उपयोग करता है।

संवाद कैसे करें

जब से हमने उदाहरण के बारे में बात करना शुरू किया है "एक उपयोगकर्ता ने एक उत्पाद खरीदा, हम विक्रेता को बिक्री का नोटिस भेजते हैं", तो हम इसे लागू करेंगे।

योजना इस प्रकार है:

1. उपयोगकर्ता लिंक / बाजार / खरीदने / खरीदने के लिए microservice बाजार के लिए एक अनुरोध भेजता है: / आईडी
2. ध्वज डेटाबेस में लिखा है कि उत्पाद बेचा जाता है
3. Microservice मार्केट से, microservice नोटिफिकेशन के लिए एक रिक्वेस्ट भेजी जाती है, जिससे क्लाइंट WebSocket के जरिए जुड़े होते हैं
4. Microservice सूचनाएं विक्रेता को चीजों की बिक्री के बारे में संदेश भेजती है

MicroMQ स्थापित करें

$ npm i micromq@1 -S 

गेटवे लिखना

 const Gateway = require('micromq/gateway'); //   const gateway = new Gateway({ microservices: ['market'], rabbit: { url: process.env.RABBIT_URL, }, }); //        market gateway.post('/market/buy/:id', (req, res) => res.delegate('market')); //      gateway.listen(process.env.PORT); 

हमारे प्रवेश द्वार में केवल एक समापन बिंदु है, लेकिन यह उदाहरण और प्रशिक्षण के लिए पर्याप्त है।

एक microservice सूचनाएं लिखना

 const MicroMQ = require('micromq'); const WebSocket = require('ws'); //   const app = new MicroMQ({ name: 'notifications', rabbit: { url: process.env.RABBIT_URL, }, }); //        const ws = new WebSocket.Server({ port: process.env.PORT, }); //     const clients = new Map(); //    ws.on('connection', (connection) => { //     connection.on('message', (message) => { //  ,       . //      try/catch,    json! const { event, data } = JSON.parse(message); //   'authorize'         if (event === 'authorize' && data.userId) { //         clients.set(data.userId, connection); } }); }); //       , //    ! ws.on('close', ...); //   notify,      app.action('notify', (meta) => { //      ,    400 if (!meta.userId || !meta.text) { return [400, { error: 'Bad data' }]; } //     const connection = clients.get(meta.userId); //     ,    404 if (!connection) { return [404, { error: 'User not found' }]; } //    connection.send(meta.text); //  200   return { ok: true }; }); //   app.start(); 

यहाँ हम एक ही समय में वेब सॉकेट सर्वर और microservice बढ़ाते हैं, ताकि दोनों वेब सॉकेट और RabbitMQ के लिए अनुरोध प्राप्त हो सकें।

योजना इस प्रकार है:

1. एक उपयोगकर्ता हमारे वेब सॉकेट सर्वर से जुड़ता है
2. उपयोगकर्ता को अपने उपयोगकर्ता आईडी के साथ एक authorize घटना भेजकर authorize किया जाता है
3. हम उपयोगकर्ता का कनेक्शन रखते हैं ताकि आप उसे भविष्य में सूचनाएं भेज सकें
4. एक घटना RabbitMQ पर आती है जिसे आपको उपयोगकर्ता को एक अधिसूचना भेजने की आवश्यकता होती है
5. आने वाले डेटा की वैधता की जाँच करना
6. उपयोगकर्ता कनेक्शन प्राप्त करें
7. अधिसूचना भेजें

एक microservice बाजार लेखन

 const MicroMQ = require('micromq'); const { Items } = require('./api/mongodb'); //   const app = new MicroMQ({ name: 'market', rabbit: { url: process.env.RABBIT_URL, }, }); //      app.post('/market/buy/:id', async (req, res) => { const { id } = req.params; //      const item = await Items.findOne({ id, isSold: false }); //   ,  404 if (!item) { res.status(404).json({ error: 'Item not found', }); return; } //  ,    ,    await Items.updateOne({ id, }, { $set: { isSold: true, }, }); //     ,    req.app.ask('notifications', { server: { action: 'notify', meta: { userId: item.sellerId, text: JSON.stringify({ event: 'notification', data: { text: `Item #${id} was sold!`, }, }), }, }, }) //  ,      .catch(err => console.log('Cannot send message via notifications microservice', err)); //    ,     res.json({ ok: true, }); }); //   app.start(); 

योजना इस प्रकार है:

1. हमें एक आइटम की खरीद के लिए एक उपयोगकर्ता अनुरोध प्राप्त होता है
2. हम सही आईडी के साथ आइटम की तलाश कर रहे हैं और सुनिश्चित करें कि यह अभी तक बेचा नहीं गया है
3. बेचा के रूप में मार्क आइटम
4. हम विक्रेता को पृष्ठभूमि में बिक्री के बारे में एक सूचना भेजते हैं
5. हम क्लाइंट को जवाब देते हैं

चेक

1. हम 3 प्रक्रियाएं शुरू करते हैं
2. हम पोस्ट / बाजार / खरीद / 1 भेजेंगे
3. हमें प्रतिक्रिया मिलती है { ok: true }
4. विक्रेता अधिसूचना प्राप्त करता है

 $ PORT=9000 node ./src/gateway.js $ PORT=9001 node ./src/notifications.js $ MONGODB_URL=mongodb://localhost:27017/my-super-microservice node ./src/market.js 

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