nodejs rabbitjs 简单的 pub sub rabbitmq答案

【问题标题】：nodejs rabbitjs simple pub sub rabbitmqnodejs rabbitjs 简单的 pub sub rabbitmq
【发布时间】：2016-10-02 08:05:01
【问题描述】：

NodeJS 和 RabbitMQ 的新手。我正在尝试做一个简单的 pub 和 sub 并在 sub 接收到来自 pub 的消息时存储它的输出。

sub.js:

var context = require('rabbit.js').createContext();
var sub = context.socket('SUB');
context.on('ready', function() {
  sub.pipe(process.stdout);
  sub.connect('events', function() {

    });
  });

pub.js：

var context = require('rabbit.js').createContext();

var pub = context.socket('PUB')
  pub.connect('events', function() {

    pub.write(JSON.stringify({welcome: 'rabbit.js'}), 'utf8');

  })

这工作正常，我在运行 sub.js 的控制台上收到标准输出消息（来自 sub.pipe(process.stdout)），但是我的问题是如何使用这个对象？是否可以将该输出存储到变量中并将其传递给另一个函数？

【问题讨论】：

标签： javascript node.js rabbitmq

【解决方案1】：

套接字是node streams。因此，您可以从它们中读取，而不是将它们通过管道传输到标准输出：

sub.on('data', function(message) { /** Do something with message */ });

【讨论】：