NodeJS从PHP服务器接收数据

Question

我目前正在开发一个简单的NodeJS客户端，它使用网络类连接到PHP服务器。此外，NodeJS客户端还可以作为Socket.IO服务器，将从PHP服务器接收到的数据发送到与Socket.IO.连接的浏览器。

到目前为止，一切都很好。但是如果我连接另一个客户端到Socket。IO，PHP服务器必须向每个连接的客户端发送通知。因此，它向NodeJS客户机发送一个JSON编码的数组，由客户机处理JSON数据(解码并稍微修改一下)。

现在的问题是，有时PHP服务器发送的两条单独的消息会连接在NodeJS的onData事件处理函数中：

client.on("data", function(data) {

   var msgData = JSON.parse(data.toString("utf8"));
   [...]
}

变量数据现在有时（不是每次！）包含两个 JSON 字符串，例如：

 { "todo":"message", [...] } { "todo":"message", [...] }

这当然会导致JSON.parse函数抛出异常。我预计会调用onData-函数两次，变量data为：

{ "todo":"message", [...] }

在 PHP 服务器端，我必须遍历一个包含当前提供的所有 Socket.IO 连接的数组：

foreach($sockets as $id => $client) {

    $nodeJS->sendData($client, array("todo" => "message", [...]);
}

$nodeJS-

socket_write($nodeClient, json_encode($dataToSend));

$nodeJS-

我现在不知道PHP或NodeJS是连接这两个字符串。我想要的是，NodeJS每次调用$nodeJS-时都会调用onData-handler一次

有没有更容易的方法来实现这一点？

Answer 1

尝试在PHP端的JSON字符串后面添加一行。

Answer 2

重要的是要记住，当您从套接字读取时，数据将以任意块的形式出现，完全取决于您的代码将它们拆分为有意义的处理单元;绝对不能保证每个块将对应于一个有意义的单位。

yannisgu已经为您提供了解决方案的第一部分(用换行符终止每个单元，这样您的代码可以知道它在哪里结束):现在您需要实现第二部分，即缓冲您的传入数据并将其拆分成单元。

在初始化时，执行以下操作

var buf = '';

并将< code>client的编码设置为utf8。

在您的“数据”处理程序中：[更新：合并了 josh3736 的建议]

buf += data;
var idx;
while ((idx = buf.indexOf('\n')) >= 0) {
   // there's at least one complete unit buffered up
   var unit = buf.slice(0, idx);
   // extract it
   if (unit.slice(-1) == '\r') {
     // CRLF delimited
     unit = unit.slice(0, -1);
   }
   if (unit.length) {
     // ignore empty strings
     var msgData = JSON.parse(unit);
     [...]
     // process it
   }
   buf = buf.slice(idx +1);
   // discard it
}
// at this point, buf is either empty or contains an incomplete
// unit which will be processed as soon as the rest of it comes in