Geekly articles weekly

Belajar berkomunikasi antar microservices di Node.js melalui RabbitMQ

Ini adalah kelanjutan dari artikel " Kami menulis microservice pertama di Node.js dengan komunikasi melalui RabbitMQ ", yang diterima dengan baik oleh pengguna Habr.


Pada artikel ini saya akan berbicara tentang bagaimana berkomunikasi dengan benar antara layanan microser sehingga layanan microser tetap terisolasi.


Bagaimana tidak melakukannya


Mengapa Anda perlu berkomunikasi di antara layanan microser? Gunakan satu database, baca dari sana apa yang Anda inginkan - bisnis sesuatu!


Tidak, Anda tidak bisa melakukannya. Konsep layanan mikro adalah bahwa mereka terisolasi satu sama lain, tidak ada yang tahu apa-apa tentang siapa pun (secara praktis). Kemungkinan besar, di masa depan, ketika sistem mulai tumbuh, Anda akan ingin memperluas fungsionalitas dan Anda perlu berkomunikasi antara layanan microser: misalnya, pengguna membeli produk, jadi Anda perlu mengirim pemberitahuan tentang penjualan kepada penjual.


Manfaat isolasi


Keandalan


Misalkan ada aplikasi monolitik di mana ada beberapa pengontrol:


  1. Produk
  2. Diskon
  3. Blog
  4. Pengguna

Suatu hari, database kami menurun: sekarang kami tidak bisa mendapatkan produk, tidak ada diskon, tidak ada posting blog, tidak ada pengguna. Situs ini sama sekali tidak tersedia, pelanggan tidak bisa masuk, bisnis kehilangan keuntungan.


Apa yang akan terjadi dalam arsitektur layanan mikro?


Di alam semesta lain, pada hari yang sama basis data layanan pengguna mikro jatuh, menjadi tidak dapat diakses: pengguna tidak dapat keluar, mendaftar dan masuk. Tampaknya semuanya buruk dan bisnisnya juga merugi, tetapi tidak: pembeli potensial dapat melihat barang yang tersedia, membaca blog perusahaan, dan menemukan diskon.


Karena setiap microservice memiliki database sendiri, efek samping menjadi jauh lebih sedikit.


Ini disebut degradasi bertahap .


Abstraksi


Dalam aplikasi besar, sangat sulit untuk berkonsentrasi pada satu tugas, karena mengubah beberapa middleware kecil dapat merusak beberapa jenis pengontrol. Ingin menggunakan klien baru untuk redis - tidak, Anda tidak bisa, pengontrol yang kami tulis tiga tahun lalu menggunakan versi 0.1.0. Ingin akhirnya memanfaatkan fitur baru Node.js 10? Atau mungkin 12? Maaf, tetapi monolith menggunakan versi 6.


Bagaimana cara berkomunikasi


Karena kami mulai berbicara tentang contoh "pengguna membeli produk, kami mengirimkan pemberitahuan penjualan kepada penjual", maka kami akan menerapkannya.


Skemanya adalah sebagai berikut:


  1. Pengguna mengirimkan permintaan ke pasar layanan-mikro untuk membeli barang-barang di tautan / pasar / beli /: id
  2. Bendera ditulis dalam database bahwa produk itu dijual
  3. Dari pasar microservice, permintaan dikirim ke pemberitahuan microservice, di mana klien terhubung melalui WebSocket
  4. Notifikasi Microservice mengirimkan pesan kepada penjual tentang penjualan barang

Instal MicroMQ


$ npm i micromq@1 -S

Menulis gateway


 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);

Gateway kami hanya terdiri dari satu titik akhir, tetapi ini sudah cukup untuk contoh dan pelatihan.


Menulis pemberitahuan layanan mikro


 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();

Di sini kita meningkatkan server soket web dan layanan microser pada saat yang sama untuk menerima permintaan untuk soket web dan RabbitMQ.


Skemanya adalah sebagai berikut:


  1. Seorang pengguna terhubung ke server soket web kami
  2. Pengguna diotorisasi dengan mengirimkan acara authorize dengan userId di dalamnya
  3. Kami menjaga koneksi pengguna sehingga Anda dapat mengirim pemberitahuan kepadanya di masa mendatang
  4. Suatu acara tiba di RabbitMQ bahwa Anda harus mengirim pemberitahuan kepada pengguna
  5. Memeriksa validitas data yang masuk
  6. Dapatkan koneksi pengguna
  7. Kirim pemberitahuan

Menulis pasar layanan-mikro


 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();

Skemanya adalah sebagai berikut:


  1. Kami menerima permintaan pengguna untuk pembelian suatu barang
  2. Kami sedang mencari item dengan id yang tepat dan memastikan bahwa itu belum dijual
  3. Tandai item sebagai terjual
  4. Kami mengirim pemberitahuan kepada penjual tentang penjualan di latar belakang
  5. Kami menanggapi klien

Periksa


  1. Kami memulai 3 proses
  2. Kami akan mengirim POST / pasar / beli / 1
  3. Kami mendapat respons { ok: true }
  4. Penjual menerima pemberitahuan

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


Source: https://habr.com/ru/post/id447250/

More articles:


All Articles