RabbitMQ tutorial - "Hello World!" — RabbitMQ
node receiver.js
node receiver.js
node sender.js
다수의 receiver
가 존재함에도 단일 메세지는 동시에 전달되지 않는다.
먼저 등록된 receiver
부터 차례대로 교차 전달된다. (Round-robin 방식)
#!/usr/bin/env node
var amqp = require("amqplib/callback_api");
amqp.connect(
"amqp://myuser:secret@localhost:5672",
function (error0, connection) {
if (error0) {
throw error0;
}
connection.createChannel(function (error1, channel) {
if (error1) {
throw error1;
}
var queue = "hello";
channel.assertQueue(queue, {
durable: false,
});
console.log(
" [*] Waiting for messages in %s. To exit press CTRL+C",
queue
);
channel.consume(
queue,
function (msg) {
console.log(" [x] Received %s", msg.content.toString());
},
{
noAck: true,
}
);
});
}
);
#!/usr/bin/env node
var amqp = require("amqplib/callback_api");
amqp.connect(
"amqp://myuser:secret@localhost:5672",
function (error0, connection) {
if (error0) {
throw error0;
}
connection.createChannel(function (error1, channel) {
if (error1) {
throw error1;
}
var queue = "hello";
var msg = "Hello World!";
channel.assertQueue(queue, {
durable: false,
});
channel.sendToQueue(queue, Buffer.from(msg));
console.log(" [x] Sent %s", msg);
});
setTimeout(function () {
connection.close();
process.exit(0);
}, 500);
}
);