0

早晨。我最近开始进入 NODE.JS 的奇迹，并拥有一个节点，它通过 stomp 从 Active MQ 数据馈送中提取信息，并使用 prettyjson 呈现它并输出到控制台。

var prettyjson = require('prettyjson'),
    StompClient = require('stomp-client').StompClient;

var destination = '/topic/(topic)',
    client = new StompClient('datafeeds.(datafeedlocation)', 61618, '(email.address)', '(password)', '1.0');

client.connect(function(sessionId) {
    console.log('Trying to connect...');
    client.subscribe(destination, function(body, headers) {
        console.log(prettyjson.render(JSON.parse(body)));
    });
});

并且提要在控制台上非常愉快地搅动。

现在我已经阅读了很多示例，其中大多数总是输出到控制台。但是我想获取这些数据并对其进行处理。

那么我如何获取控制台输出并存储它，或者只是跳过控制台输出并存储在信息中.. 现在任何方法都可以，在 json 文件中或数据库中.. 地狱.. 甚至是文本文件。好的清晰指南很好，不要指望任何人为我编写代码。

提前感谢任何好的指示。

4

1 回答 1

0

呸，像往常一样张贴寻求帮助..我得到它的工作..这是最终代码

var prettyjson = require('prettyjson'),
    fs = require('fs'),
    StompClient = require('stomp-client').StompClient;

var destination = '/topic/(topic)',
    client = new StompClient('datafeeds.(datafeed)', 61618, '(email.address)', '(password)', '1.0');

client.connect(function(sessionId) {
    console.log('Trying to connect...');
    client.subscribe(destination, function(body, headers) {
        fs.writeFile("./output", prettyjson.render(JSON.parse(body)), function(err) {
    if(err) {
        console.log(err);
    } else {
        console.log("The file was saved!");
    }
}); 
    });
});
于 2013-03-13T11:26:45.513 回答