node.js使用rabbitmq

在Node.js中使用RabbitMQ，您可以使用amqp.node包。首先，您需要安装amqp.node包并引入它。然后，您可以使用amqp.connect方法创建与RabbitMQ服务器的连接，指定连接URL。在连接回调函数中，您可以通过调用conn.createChannel方法创建一个通道。接下来，您可以使用通道的方法来声明队列、发送消息和接收消息。例如，使用assertQueue方法声明一个队列，使用sendToQueue方法发送消息，使用consume方法接收消息。下面是一个使用amqp.node包的例子：

get.js:

var amqp = require('amqplib/callback_api');
amqp.connect('amqp://localhost', function(err, conn) {
  // 创建连接
  conn.createChannel(function(err, ch) {
    var q = 'test';
    ch.assertQueue(q, {durable: false});
    ch.consume(q, function(msg) {
      // 接收消息
      console.log("get Message", msg.content.toString());
    }, {noAck: true});
  });
});

push.js:

var amqp = require('amqplib/callback_api');
amqp.connect('amqp://localhost', function(err, conn) {
  // 创建连接
  conn.createChannel(function(err, ch) {
    var q = 'test';
    var msg = 'Hello World!';
    ch.assertQueue(q, {durable: false});
    ch.sendToQueue(q, new Buffer(msg));
    // 发送消息
    console.log("Send message:", msg);
  });
  setTimeout(function() { conn.close(); process.exit(0) }, 500);
});

以上是一个简单的使用amqp.node包在Node.js中使用RabbitMQ的示例。您可以根据自己的需求进行更改和扩展。<span class="em">1</span><span class="em">2</span><span class="em">3</span>
#### 引用[.reference_title]
- *1* *2* *3* [Node.js使用rabbitMQ(一)](https://blog.csdn.net/weixin_34402090/article/details/85850603)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v92^chatsearchT0_1"}}] [.reference_item style="max-width: 100%"]
[ .reference_list ]