nodejs rabbitjs簡單的pub pub rabbitmq

Question

NodeJS和RabbitMQ的新手。我試圖做一個簡單的pub和sub，並在從pub接收消息時存儲sub的輸出。

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'); 

    }) 

這工作得很好，我在控制檯上運行得到的stdout消息（從sub.pipe（process.stdout）） sub.js，但是我的問題是我該如何使用這個對象？是否可以將該輸出存儲到變量中並將其傳遞到另一個函數中？

Answer 1

套接字是node streams。因此，不要將它們傳輸到標準輸出，您可以從中讀取：

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