RabbitMQ Publish/Comsumer 예제(node.js)

node.js에서 RabbitMQ를 사용하기 위해서 amqp를 설치한다. 

COMMAND NPM INSTALL  

npm install amqp

cumsumer.js

var amqp = require('amqp'); 
var connection = amqp.createConnection({host: 'localhost'}); 
var queueToReceiveFrom = "testMessageQueue"; 
connection.on('ready',function(){connection.queue(queueToReceiveFrom,{autoDelete: false}, function(queue){ console.log('Waiting messages...'); 
queue.subscribe(function(messageReceived){ console.log("Received message: "+ messageReceived.data.toString()); 
}); }); }); 

publish.js

var amqp = require('amqp');
var connection = amqp.createConnection({host: 'localhost', port:5672});
connection.on('ready', function(){
		var messageToSend = "Hello, MessageQueue!";
		var queueToSendTo = "testMessageQueue";

		connection.publish(queueToSendTo, messageToSend);

		console.log("Sent message: "+ messageToSend);
	}
);

 간단하게 RabbitMQ를 이용하여 메시지 전달하는 기능이다.  
 Web Admin에서 메시지가 전달되는 과정도 확인할 수 있다. 

COMMAND node custmer.js  

 

COMMAND node publish.js  

Browser