nodejs + mqlight 连接错误

Question

我将 nodejs 与 mqlight 一起用于运行 https://www.npmjs.com/package/mqlight 提供的示例代码。

我使用的是 nodejs 5.5.0，npm 版本是 3.3.12。

我使用

npm install mqlight

安装了 mqlight。


    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)

请帮忙解决这个问题。我正在使用 window 7 64 位 os.

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)

nodejs + mqlight 连接错误

nodejs + mqlight connection error

javascript

node.js

ibm-mq