在RabbitMQ中，assertQueue和sendToQueue有何区别？

Question

我已经找到了有关在RabbitMQ中发送字符串示例并从队列中接收的代码，但我对以下方法不是很清楚：assertQueue和sendToQueue。 send.js

var amqp = require('amqplib/callback_api');

amqp.connect('amqp://localhost', function(err, conn) {
  conn.createChannel(function(err, ch) {

              var q = 'hello';
                var msg = 'Hello World! - '+i;

                ch.assertQueue(q, {durable: false});                    
                ch.sendToQueue(q, new Buffer(msg));
                console.log(" [x] Sent %s", msg);
  });
  setTimeout(function() { conn.close(); process.exit(0) }, 1000);
});

receive.js

var amqp = require('amqplib/callback_api');

amqp.connect('amqp://localhost', function(err, conn) {          //amqp://localhost
  conn.createChannel(function(err, ch) {
    var q = 'hello';

    ch.assertQueue(q, {durable: false});
    console.log(" [*] Waiting for messages in %s. To exit press CTRL+C", q);
    ch.consume(q, function(msg) {
      console.log(" [x] Received %s", msg.content.toString());
    }, {noAck: true});
  });
});

- Harry

Answer 1

根据你的例子，assertQueue 会检查 "hello" 队列是否存在，如果不存在就会创建它。

sendToQueue 将消息放入 "hello" 队列。

- user2768407

---

谢谢。文档中没有说明如果队列不存在则会创建一个。很奇怪... - Abdallah

Answer 2

assertQueue 是一个队列声明的方法，sendToQueue 则是将你的消息推送到队列中的方法。

需要注意的是：声明队列是幂等的 - 只有当队列不存在时才会被创建。

- venky07