تعلم التواصل بين microservices على Node.js من خلال RabbitMQ

هذا هو استمرار لمقال " نحن نكتب أول خدمة microservice على Node.js مع التواصل من خلال RabbitMQ " ، والتي لقيت استقبالا حسنا من قبل مستخدمي Habr.

في هذه المقالة سأتحدث عن كيفية التواصل بشكل صحيح بين الخدمات الصغيرة بحيث تظل الخدمات الصغيرة معزولة.

كيف لا تفعل ذلك

لماذا تحتاج إلى التواصل بين الخدمات الصغيرة؟ استخدم قاعدة بيانات واحدة ، واقرأ ما تريد - عمل شيء!

لا ، لا يمكنك فعل ذلك. مفهوم الخدمات الصغيرة هو أنها معزولة عن بعضها البعض ، لا أحد يعرف أي شيء عن أي شخص (عمليا). على الأرجح ، في المستقبل ، عندما يبدأ النظام في النمو ، سترغب في توسيع الوظيفة وتحتاج إلى التواصل بين الخدمات الصغيرة: على سبيل المثال ، اشترى المستخدم منتجًا ، لذلك تحتاج إلى إرسال إشعار حول البيع إلى البائع.

فوائد العزل

دقة

لنفترض أن هناك تطبيقًا مترابطًا به عدة وحدات تحكم:

1. بضائع
2. تخفيض
3. المدونة
4. المستخدمين

يوم واحد على ما يرام ، قاعدة بياناتنا تتساقط: الآن لا يمكننا الحصول على أي منتجات ، لا خصومات ، لا مشاركات مدونة ، لا مستخدمين. الموقع غير متاح تمامًا ، لا يمكن للعملاء تسجيل الدخول ، والأعمال تفقد الأرباح.

ماذا سيحدث في العمارة microservice؟

في عالم آخر ، في نفس اليوم الذي تسقط فيه قاعدة بيانات microservice للمستخدم ، يصبح الوصول إليها غير ممكن: لا يمكن للمستخدمين تسجيل الخروج والتسجيل وتسجيل الدخول. يبدو أن كل شيء سيئ وأن الشركة تفقد أيضًا الأرباح ، ولكن لا: يمكن للمشترين المحتملين إلقاء نظرة على السلع المتاحة ، وقراءة مدونة الشركة ، والعثور على خصومات.

نظرًا لحقيقة أن كل خدمة microservice لها قاعدة بيانات خاصة بها ، فإن الآثار الجانبية تصبح أقل بكثير.

وهذا ما يسمى التدهور التدريجي .

التجريد

في تطبيق كبير ، من الصعب جدًا التركيز على مهمة واحدة ، لأن تغيير بعض البرامج الوسيطة الصغيرة يمكن أن يكسر نوعًا من وحدة التحكم. تريد استخدام العميل الجديد لـ redis - لا ، لا يمكنك ، وحدة التحكم التي كتبناها قبل ثلاث سنوات تستخدم الإصدار 0.1.0. هل تريد أخيرًا الاستفادة من الميزات الجديدة لـ Node.js 10؟ أو ربما 12؟ عذرا ، ولكن يستخدم متراصة الإصدار 6.

كيفية التواصل

نظرًا لأننا بدأنا الحديث عن المثال "اشترى المستخدم منتجًا ، فإننا نرسل إشعارًا بالبيع إلى البائع" ، ثم سنقوم بتنفيذه.

المخطط كما يلي:

1. يرسل المستخدم طلبًا إلى سوق الخدمات الصغيرة لشراء الأشياء على الرابط / السوق / شراء /: الهوية
2. يتم كتابة العلم في قاعدة البيانات التي يتم بيع المنتج
3. من سوق الخدمات المصغرة ، يتم إرسال طلب إلى إخطارات الخدمات الصغيرة ، التي يتصل بها العملاء عبر 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(); 

نحن هنا نرفع خادم مقبس الويب والخدمات الصغيرة في نفس الوقت لتلقي الطلبات لكل من مآخذ الويب و RabbitMQ.

المخطط كما يلي:

1. مستخدم يتصل بخادم مقبس الويب الخاص بنا
2. يُصرح للمستخدم بإرسال حدث authorize مع userId داخله
3. نحتفظ باتصال المستخدم حتى تتمكن من إرسال إعلامات إليه في المستقبل
4. يصل حدث ما على RabbitMQ تحتاج إلى إرسال إشعار إلى المستخدم
5. التحقق من صحة البيانات الواردة
6. الحصول على اتصال المستخدم
7. إرسال إشعار

كتابة سوق الخدمات

 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 

• رابط إلى شفرة المصدر للمكتبة
• رابط إلى الحزمة في NPM التسجيل