【发布时间】:2018-06-26 12:13:36
【问题描述】:
我是 RabbitMQ 的新手,我正在尝试 Nodejs 中的简单示例。
const amqp = require('amqplib/callback_api');
amqp.connect('amqp://guest:guest@localhost:15672',function(err,
conn) {
console.log("Enter in callback",conn);
if (err) {
console.error("[AMQP]", err.message);
return err;
}
conn.on("error", function(err) {
if (err.message !== "Connection closing") {
console.error("[AMQP] conn error", err.message);
}
});
conn.on("close", function() {
console.error("[AMQP] reconnecting");
return;
});
console.log("[AMQP] connected");
amqpConn = conn;
callback(null,"Success");
});
我看到“连接错误连接 ECONNREFUSED 127.0.0.1:15672”错误。请让我知道我在哪里做错了,我可以使用http://localhost:15672 从网络访问它。
谢谢
【问题讨论】:
-
你启动rabbitmq服务器了吗?
-
是的,我确实在 Ubuntu 上使用了“invoke-rc.d rabbitmq-server start”命令,甚至多次使用“sudo service rabbitmq-server restart”命令重新启动了服务器。
标签: node.js rabbitmq node-amqplib