Download as PDF, PPTX
![1 const express = require('express'); 2 const bodyParser = require('body-parser'); 3 4 const app = express(); 5 app.use(bodyParser.json()); 6 7 app.listen(3000, () => { 8 console.log(' [x] Awaiting for requests'); 9 }); 10 11 app.get('/:id', (request, response) => { 12 const id = request.params.id; 13 14 console.log(` [.] ID ${id}`); 15 16 response.status(200).json({ 17 data: { 18 name: 'Ada Lovelace', 19 occupation: 'Programmer' 20 } 21 }); 22 });](https://image.slidesharecdn.com/braziljs-170828184953/75/Microservices-using-Node-js-and-RabbitMQ-46-2048.jpg)
![1 app.listen(3000, () => { 2 console.log(' [x] Awaiting for requests'); 3 }); 4 5 app.get('/:id', (request, response) => { 6 const id = request.params.id; 7 8 console.log(` [.] ID ${id}`); 9 10 response.status(200).json({ 11 data: { 12 name: 'Ada Lovelace', 13 occupation: 'Programmer' 14 } 15 }); 16 });](https://image.slidesharecdn.com/braziljs-170828184953/75/Microservices-using-Node-js-and-RabbitMQ-47-2048.jpg)
![1 const express = require('express'); 2 const request = require('request-promise'); 3 4 const id = process.argv.slice(2); 5 6 const app = express(); 7 8 app.listen(3005, () => { 9 console.log(` [x] Requesting user ${id}`); 10 11 request(`http://localhost:3000/${id}`) 12 .then((res) => { 13 return console.log(` [.] Got ${res}`) 14 }); 15 });](https://image.slidesharecdn.com/braziljs-170828184953/75/Microservices-using-Node-js-and-RabbitMQ-49-2048.jpg)
![1 const id = process.argv.slice(2); 2 3 app.listen(3005, () => { 4 console.log(` [x] Requesting user ${id}`); 5 6 request(`http://localhost:3000/${id}`) 7 .then((res) => { 8 return console.log(` [.] Got ${res}`) 9 }); 10 });](https://image.slidesharecdn.com/braziljs-170828184953/75/Microservices-using-Node-js-and-RabbitMQ-50-2048.jpg)
![1 const amqp = require('amqplib/callback_api'); 2 3 amqp.connect('amqp://localhost', (err, conn) => { 4 conn.createChannel((err, ch) => { 5 const q = 'rpc_queue'; 6 7 ch.assertQueue(q, { durable: false }); 8 ch.prefetch(1); 9 10 console.log(' [x] Awaiting RPC requests'); 11 12 ch.consume(q, function reply(msg) { 13 const id = parseInt(msg.content.toString(), 10); 14 15 console.log(` [.] ID ${id}`); 16 17 ch.sendToQueue(msg.properties.replyTo, 18 new Buffer('name: Ada Lovelace, occupation: programmer'), 19 { correlationId: msg.properties.correlationId }); 20 21 ch.ack(msg); 22 }); 23 }); 24 });](https://image.slidesharecdn.com/braziljs-170828184953/75/Microservices-using-Node-js-and-RabbitMQ-65-2048.jpg)
![Retrieve message from rpc_queue 12 ch.consume(q, function reply(msg) { 13 const id = parseInt(msg.content.toString(), 10); 14 15 console.log(` [.] ID ${id}`);](https://image.slidesharecdn.com/braziljs-170828184953/75/Microservices-using-Node-js-and-RabbitMQ-67-2048.jpg)
![1 const amqp = require('amqplib/callback_api'); 2 const uuid = require('uuid'); 3 4 const id = process.argv.slice(2); 5 6 amqp.connect('amqp://localhost', (err, conn) => { 7 conn.createChannel((err, ch) => { 8 ch.assertQueue('', { exclusive: true }, (err, q) => { 9 10 const corr = uuid(); 11 console.log(` [x] Requesting user ${id}`); 12 13 ch.consume(q.queue, (msg) => { 14 if (msg.properties.correlationId === corr) { 15 console.log(` [.] Got ${msg.content.toString()}`); 16 setTimeout(function() { conn.close(); process.exit(0) }, 500); 17 } 18 }, {noAck: true}); 19 20 ch.sendToQueue('rpc_queue', 21 new Buffer(id.toString()), 22 { correlationId: corr, replyTo: q.queue }); 23 }); 24 }); 25 });](https://image.slidesharecdn.com/braziljs-170828184953/75/Microservices-using-Node-js-and-RabbitMQ-70-2048.jpg)
![Retrieve response from callback queue 13 ch.consume(q.queue, (msg) => { 14 if (msg.properties.correlationId === corr) { 15 console.log(` [.] Got ${msg.content.toString()}`); 16 setTimeout(function() { conn.close(); process.exit(0) }, 500); 17 } 18 }, {noAck: true});](https://image.slidesharecdn.com/braziljs-170828184953/75/Microservices-using-Node-js-and-RabbitMQ-73-2048.jpg)
Uploaded byCarolina Pascale Campos
Microservices using Node.js and RabbitMQ
This document discusses using microservices with Node.js and RabbitMQ. It outlines reasons for adopting a microservices architecture like team structure and scalability. It also describes positives like new technologies and minimum effort/impact. Negatives include the shotgun effect, unstable interfaces, slow integration tests, and user-service dependencies. The document shows examples of using RabbitMQ for messaging between microservices and RPC calls. It concludes that any system's structure will reflect the organization's communication structure.
Microservices using Node.js and RabbitMQ
- 1.
- 3.
- 4. Share your location withyour friends
- 6.
- 7.
- 8.
- 9.
- 10.
- 11.
- 12.
- 13.
- 14.
- 15.
- 16.
- 17.
- 18.
- 19.
- 20.
- 21. Startup 5 back-end developers 7micro-services
- 22.
- 23.
- 24.
- 25.
- 26.
- 27.
- 28.
- 29.
- 30.
- 32.
- 33.
- 34.
- 35.
- 36.
- 37.
- 38.
- 39.
- 40.
- 41.
- 42.
- 44.
- 45.
- 46. 1 const express= require('express'); 2 const bodyParser = require('body-parser'); 3 4 const app = express(); 5 app.use(bodyParser.json()); 6 7 app.listen(3000, () => { 8 console.log(' [x] Awaiting for requests'); 9 }); 10 11 app.get('/:id', (request, response) => { 12 const id = request.params.id; 13 14 console.log(` [.] ID ${id}`); 15 16 response.status(200).json({ 17 data: { 18 name: 'Ada Lovelace', 19 occupation: 'Programmer' 20 } 21 }); 22 });
- 47. 1 app.listen(3000, ()=> { 2 console.log(' [x] Awaiting for requests'); 3 }); 4 5 app.get('/:id', (request, response) => { 6 const id = request.params.id; 7 8 console.log(` [.] ID ${id}`); 9 10 response.status(200).json({ 11 data: { 12 name: 'Ada Lovelace', 13 occupation: 'Programmer' 14 } 15 }); 16 });
- 48.
- 49. 1 const express= require('express'); 2 const request = require('request-promise'); 3 4 const id = process.argv.slice(2); 5 6 const app = express(); 7 8 app.listen(3005, () => { 9 console.log(` [x] Requesting user ${id}`); 10 11 request(`http://localhost:3000/${id}`) 12 .then((res) => { 13 return console.log(` [.] Got ${res}`) 14 }); 15 });
- 50. 1 const id= process.argv.slice(2); 2 3 app.listen(3005, () => { 4 console.log(` [x] Requesting user ${id}`); 5 6 request(`http://localhost:3000/${id}`) 7 .then((res) => { 8 return console.log(` [.] Got ${res}`) 9 }); 10 });
- 51.
- 53.
- 54.
- 55.
- 57.
- 58.
- 59.
- 60.
- 62.
- 63.
- 64.
- 65. 1 const amqp= require('amqplib/callback_api'); 2 3 amqp.connect('amqp://localhost', (err, conn) => { 4 conn.createChannel((err, ch) => { 5 const q = 'rpc_queue'; 6 7 ch.assertQueue(q, { durable: false }); 8 ch.prefetch(1); 9 10 console.log(' [x] Awaiting RPC requests'); 11 12 ch.consume(q, function reply(msg) { 13 const id = parseInt(msg.content.toString(), 10); 14 15 console.log(` [.] ID ${id}`); 16 17 ch.sendToQueue(msg.properties.replyTo, 18 new Buffer('name: Ada Lovelace, occupation: programmer'), 19 { correlationId: msg.properties.correlationId }); 20 21 ch.ack(msg); 22 }); 23 }); 24 });
- 66. rpc_queue Response Channel 3 amqp.connect('amqp://localhost', (err,conn) => { 4 conn.createChannel((err, ch) => { 5 const q = 'rpc_queue';
- 67. Retrieve message from rpc_queue 12ch.consume(q, function reply(msg) { 13 const id = parseInt(msg.content.toString(), 10); 14 15 console.log(` [.] ID ${id}`);
- 68. Send response to callbackqueue 17 ch.sendToQueue(msg.properties.replyTo, 18 new Buffer('name: Ada Lovelace, occupation: programmer’), 19 { correlationId: msg.properties.correlationId });
- 69.
- 70. 1 const amqp= require('amqplib/callback_api'); 2 const uuid = require('uuid'); 3 4 const id = process.argv.slice(2); 5 6 amqp.connect('amqp://localhost', (err, conn) => { 7 conn.createChannel((err, ch) => { 8 ch.assertQueue('', { exclusive: true }, (err, q) => { 9 10 const corr = uuid(); 11 console.log(` [x] Requesting user ${id}`); 12 13 ch.consume(q.queue, (msg) => { 14 if (msg.properties.correlationId === corr) { 15 console.log(` [.] Got ${msg.content.toString()}`); 16 setTimeout(function() { conn.close(); process.exit(0) }, 500); 17 } 18 }, {noAck: true}); 19 20 ch.sendToQueue('rpc_queue', 21 new Buffer(id.toString()), 22 { correlationId: corr, replyTo: q.queue }); 23 }); 24 }); 25 });
- 71. Callback Queue Request Channel 6 amqp.connect('amqp://localhost',(err, conn) => { 7 conn.createChannel((err, ch) => { 8 ch.assertQueue('', { exclusive: true }, (err, q) => {
- 72. Request to rpc_queue 10const corr = uuid(); 20 ch.sendToQueue('rpc_queue', 21 new Buffer(id.toString()), 22 { correlationId: corr, replyTo: q.queue });
- 73. Retrieve response from callbackqueue 13 ch.consume(q.queue, (msg) => { 14 if (msg.properties.correlationId === corr) { 15 console.log(` [.] Got ${msg.content.toString()}`); 16 setTimeout(function() { conn.close(); process.exit(0) }, 500); 17 } 18 }, {noAck: true});
- 74.
- 76.
- 77.
- 78.
- 79.
- 81. Any organization thatdesigns a system (defined broadly) will produce a design whose structure is a copy of the organization's communication structure. Conway's Law
- 82.
- 83.
- 84. How to solve myteam problems?
- 85. Shotgun effect Unstable interfaces Integrationtests User-service dependency
- 86.
- 87.
- 88.
- 89.
- 90. Shotgun effect Unstable interfaces Integrationtests User-service dependency
- 91.
- 98.
- 99.
- 100.