在Docker容器中使用RabbitMQ时,可能会出现连接错误的问题。其中包括Error: connect ECONNREFUSED 192.168.80.2:5672。这个错误可能是由于RabbitMQ服务器未正确启动或配置不正确引起的。解决这个问题的方法是确保正确启动了RabbitMQ服务器,并在Docker容器中正确配置了连接参数。以下是可以用于连接RabbitMQ的示例代码:
const amqp = require('amqplib/callback_api');
amqp.connect('amqp://username:password@localhost', function(err, conn) {
conn.createChannel(function(err, ch) {
const 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});
});
});
在这个示例代码中,我们使用amqplib库来连接RabbitMQ服务器,并从队列中读取消息。您应该根据您的具体需求修改此代码。