Our first message queue
Now that we have a working RabbitMQ server, let's use it to build something. We will create a simple web server that will add a message to a queue on each request. We will also have a worker script that will work the queue.
First, create a new directory named rabbit_first
. Create a package.json
file and add the following code to it:
{ "dependencies": { "amqp": "0.2.0" } }
Then, run npm install
. After this command finishes, create the app.js
file and add the following code to it:
var http = require('http'), amqp = require('amqp'); var rabbit = amqp.createConnection(); rabbit.on('ready', function(){ rabbit.exchange('my-first-exchange', {type: 'direct', autoDelete: false}, function(ex){ startServer(ex); }); }); function startServer(ex) ...
Get Building Scalable Apps with Redis and Node.js now with the O’Reilly learning platform.
O’Reilly members experience books, live events, courses curated by job role, and more from O’Reilly and nearly 200 top publishers.