如何在nodejs上使用来自RabbitMQ的消息

Question

我是一个尝试在我的nodejs代码上实现RabbitMQ的新用户。我已经提到了使用它的几个例子，但仍然不清楚如何使用它的实时示例。我正尝试使用Rabbit MQ从队列中读取消息。我如何从nodejs的队列中读取消息？

在此先感谢！

Answer 1

Node.js拥有大量的开源社区，对npmjs.org有所贡献。有机会，有人已经建立了一个模块来做你想做的事情。

在你的情况，https://www.npmjs.com/package/amqp

从queue.subscribe的文档（[选项]听众）：

q.subscribe(function (message, headers, deliveryInfo, messageObject) { 
    console.log('Got a message with routing key ' + deliveryInfo.routingKey); 
}); 

Answer 2

官方的RabbitMQ教程提供基本的例子场景，使用代码，使用Node.js和amqp.node库（又名“amqplib”）。我建议开始有：

https://www.rabbitmq.com/tutorials/tutorial-one-javascript.html

我也有一个完整的培训指导，从地面往上走，用的RabbitMQ和Node.js的重点是推动“微服务”，但材料的核心是学习RabbitMQ，第一个：https://sub.watchmecode.net/guides/microservices-with-rabbitmq/

Answer 3

如果你仍然在研究这个，我们刚刚在Node：BunnyBus（www。 github.com/xogroup/bunnybus）

这是一个超级简单的外观，在幕后利用amqplib。

const BunnyBus = require('bunnybus'); 
const bunnyBus = new BunnyBus({ 
    protocol : process.env.RABBIT_PROTOCOL, 
    user  : process.env.RABBIT_USER, 
    password : process.env.RABBIT_PASSWORD, 
    server : process.env.RABBIT_SERVER, 
    port  : process.env.RABBIT_PORT, 
    vhost : process.env.RABBIT_V_HOST 
}); 

const messageHandler = { 
    'event-name': (message, acknowledge, reject, requeue) => { 
     // do your work with the message here 

     return acknowledge(); 
    } 
}; 

// This will auto-connect and create the queue and bindings if they do not exist 
bunnyBus.subscribe('queueName', messageHandler) 
    .then(() => { 
     const myMessage = {/*your contents here*/}; 
     return bunnyBus.publish(myMessage, { routeKey: 'event-name' }); 
    });