流中的NodeJS反序列化

Question

我在从节点中的流（特别是来自比特币GOX交易所的定价提要）进行反序列化时遇到问题。基本上是一个格式良好、完整且经过验证的JSON的块到达。这是代码：

var gox = require('goxstream');
var fs = require('fs');
var options = {
    currency: 'AUD',
    ticker: true,
    depth: false
};
var goxStream = gox.createStream(options);
goxStream.on('data', function(chunk) {
    console.log(JSON.parse(chunk));
});

当试图解析它时，我得到了以下

undefined:0
^
SyntaxError: Unexpected end of input

有什么想法吗？我已经包含了一个样本块：

> {"channel": "eb6aaa11-99d0-4f64-9e8c-1140872a423d", "channel_name":
> "ticker.BTCAUD", "op": "private", "origin": "broadcast", "private":
> "ticker", "ticker": {
>     "high": {
>         "value": "121.51941",
>         "value_int": "12151941",
>         "display": "AU$121.51941",
>         "display_short": "AU$121.52",
>         "currency": "AUD"
>     },
>     "low": {
>         "value": "118.00001",
>         "value_int": "11800001",
>         "display": "AU$118.00001",
>         "display_short": "AU$118.00",
>         "currency": "AUD"
>     },
>     "avg": {
>         "value": "119.58084",
>         "value_int": "11958084",
>         "display": "AU$119.58084",
>         "display_short": "AU$119.58",
>         "currency": "AUD"
>     },
>     "vwap": {
>         "value": "119.80280",
>         "value_int": "11980280",
>         "display": "AU$119.80280",
>         "display_short": "AU$119.80",
>         "currency": "AUD"
>     },
>     "vol": {
>         "value": "249.73550646",
>         "value_int": "24973550646",
>         "display": "249.73550646u00a0BTC",
>         "display_short": "249.74u00a0BTC",
>         "currency": "BTC"
>     },
>     "last_local": {
>         "value": "118.50000",
>         "value_int": "11850000",
>         "display": "AU$118.50000",
>         "display_short": "AU$118.50",
>         "currency": "AUD"
>     },
>     "last_orig": {
>         "value": "108.99500",
>         "value_int": "10899500",
>         "display": "$108.99500",
>         "display_short": "$109.00",
>         "currency": "USD"
>     },
>     "last_all": {
>         "value": "118.79965",
>         "value_int": "11879965",
>         "display": "AU$118.79965",
>         "display_short": "AU$118.80",
>         "currency": "AUD"
>     },
>     "last": {
>         "value": "118.50000",
>         "value_int": "11850000",
>         "display": "AU$118.50000",
>         "display_short": "AU$118.50",
>         "currency": "AUD"
>     },
>     "buy": {
>         "value": "118.50000",
>         "value_int": "11850000",
>         "display": "AU$118.50000",
>         "display_short": "AU$118.50",
>         "currency": "AUD"
>     },
>     "sell": {
>         "value": "119.99939",
>         "value_int": "11999939",
>         "display": "AU$119.99939",
>         "display_short": "AU$120.00",
>         "currency": "AUD"
>     },
>     "item": "BTC",
>     "now": "1376715241731341" }}

您可以在此处验证：http://jsonlint.com

此外，可能值得一提的是，我已经尝试过解析和删除转义字符。还尝试了几个不同的序列化程序，结果相同

Answer 1

您正在逐块获取数据。区块本身可能不是完整的JSON对象。缓冲所有数据，或者使用一些东西为您做这件事（比如request模块），或者如果您需要解析一个长流，请查看JSONparse模块。

Answer 2

您得到了两个独立的块（或者至少：这是我在重新创建问题时得到的）。一个（第一个）是有效的JSON对象，而另一个（第二个）"几乎为空"：它是一个仅包含LF（ASCII 0x0a）的1字节字符串。

当然，第二个解析失败。

阅读我的第一个答案：这正是这样的情况。如果您将这两个块连接在一起，您将获得一个完整的JSON对象，该对象带有一个尾随的LF，很容易传递JSON.parse()。然而，如果您尝试分别解析块，第一个块成功（后面的LF不是强制性的），而第二个块失败（LF本身不是有效的JSON对象）。

对于您的情况，您必须：

1） 要么假设Mt.Gox总是以"这种方式"发送数据，忽略那些"几乎为空"的块，只解析"非空"块。

2） 或者使用JSONparse来解析JSON流。