nodejs+mqlight连接错误

Question

我使用nodejs和mqlight来运行https://www.npmjs.com/package/mqlight提供的示例代码。

我使用的是NodeJS5.5.0和npm版本是3.3.12。

我使用

npm install mqlight

null

    var mqlight = require('mqlight');
    var recvClient = mqlight.createClient({service: 'amqp://localhost'});
    var topicPattern = 'public';
    recvClient.on('started', function() {
      recvClient.subscribe(topicPattern);
      recvClient.on('message', function(data, delivery) {
        console.log('Recv: %s', data);
      });
    });

    var sendClient = mqlight.createClient({service: 'amqp://localhost'});

    var topic = 'public';
    sendClient.on('started', function() {
      sendClient.send(topic, 'Hello World!', function (err, data) {
        console.log('Sent: %s', data);
        sendClient.stop();
      });
    });

当我运行上面的代码时，我得到了下面的错误。

     E:\nodejs>node mqtest.js

    events.js:154
          throw er; // Unhandled 'error' event
          ^
     NetworkError: CONNECTION ERROR (localhost:5672): Connect failure: The remote co
    mputer refused the network connection.
        at Socket.connError (E:\nodejs\node_modules\mqlight\mqlight.js:1437:19)
        at emitOne (events.js:90:13)
        at Socket.emit (events.js:182:7)
        at emitErrorNT (net.js:1255:8)
        at nextTickCallbackWith2Args (node.js:474:9)
        at process._tickCallback (node.js:388:17)

请帮助解决这个问题。我使用的是Windows 7 64位操作系统。

Answer 1

您确定服务amqp正在运行吗？您可以按照下面的脚本启动amqp服务。

START SERVICE(SYSTEM.AMQP.SERVICE)
START CHANNEL(SYSTEM.DEF.AMQP) 
REFRESH SECURITY TYPE(CONNAUTH)
DISPLAY CHSTATUS(SYSTEM.DEF.AMQP) CHLTYPE(AMQP)