解析TCPJSONStream并通过Socket.io发出每个对象-ParseTCPJSONStreamandemiteachobjectviaSocket.io

I am working with a data feed that sends a JSON stream over a TCP socket and I'm using node.js/socket.io to emit the stream to a browser client.

我正在使用通过TCP套接字发送JSON流的数据馈送,我正在使用node.js / socket.io将流发送到浏览器客户端。

Everything is working except I need each JSON object to emitted as a separate message from the socket.io server. In the client the messages are received like this:

一切正常,但我需要将每个JSON对象作为来自socket.io服务器的单独消息发出。在客户端中,收到的消息如下:

//Message 1:
{"type":"TYPE_1","odds":[{"eventId":"foo","odds":[{"oddId":foo,"oddType":"LIVE","source":"foo"}]}]}
//Message 2:
{"type":"TYPE_2","odds":[{"eventId":"foo","odds":[{"oddId":foo,"oddType":"LIVE","source":"foo"}]}]}
{"type":"TYPE_3","odds":[{"eventId":"foo","odds":[{"oddId":foo,"oddType":"LIVE","source":"foo"}]}]}
//Message 3:
{"type":"TYPE_4","odds":[{"eventId":"foo","od
//Message 4:
ds":[{"oddId":foo,"oddType":"LIVE","source":"foo"}]}]}

The data feed docs state: "All messages sending to your application will form a JSON stream (no delimiter between messages), so you may need a decoder that support JSON stream."

数据馈送文档声明:“发送到您的应用程序的所有消息将形成JSON流(消息之间没有分隔符),因此您可能需要一个支持JSON流的解码器。”

So the stream is strictly correct but I need each object as separate message.

所以流是严格正确的,但我需要每个对象作为单独的消息。

I have looked at https://www.npmjs.com/package/JSONStream and others but am very new to nodejs and socketio and am not sure how to implement them in to the server.

我查看了https://www.npmjs.com/package/JSONStream和其他人,但对nodejs和socketio来说是一个新手,我不知道如何将它们实现到服务器中。

Have also read How can I parse the first JSON object on a stream in JS, nodejs JSON.parse(data_from_TCP_socket), http://www.sebastianseilund.com/json-socket-sending-json-over-tcp-in-node.js-using-sockets.

还阅读了如何在JS中解析流上的第一个JSON对象,nodejs JSON.parse(data_from_TCP_socket),http://www.sebastianseilund.com/json-socket-sending-json-over-tcp-in-node .js文件,使用的套接字。

I think it's something to do with buffer chunk lengths and them being too big so the messages get split but that could be wrong! I'm guessing I need a delimiter check that balances brackets but not sure how to go about it or if the right approach.

我认为这与缓冲区块长度有关,而且它们太大,所以消息会被拆分,但这可能是错误的!我猜我需要一个分隔符检查来平衡括号,但不知道如何去做或如果正确的方法。

My Server Script:

我的服务器脚本:

var app = require('express')();
var http = require('http').Server(app);
var io = require('socket.io')(http);
var net = require('net');
var port = 8992;              // Datafeed port
var host = '127.0.0.1';      // Datafeed IP address

//Whenever someone connects this gets executed
io.on('connection', function(socket){
  console.log('A user connected to me the server');

  //Whenever someone disconnects this piece of code executed
  socket.on('disconnect', function () {
    console.log('A user disconnected');
  });
});

//Create a TCP socket to read data from datafeed
var socket = net.createConnection(port, host);

socket.on('error', function(error) {
  console.log("Error Connecting");
});

socket.on('connect', function(connect) {
  console.log('connection established');
  socket.write('{"type":"SUBSCRIBE"}');
});

socket.on('data', function(data) {
  //console.log('DATA ' + socket.remoteAddress + ': ' + data);
  var data = data.toString();
  io.sockets.emit('event', JSON.stringify(data));
});

http.listen(3000, function(){
  console.log('listening on *:3000');
});

My Client:

  
  
  
  
  
    
      Send
    
    

    
  

Any help or guidance would be amazing as really struggling with this.

任何帮助或指导都会令人惊讶,因为真的在努力解决这个问题。

1 个解决方案

var sockBuf = '';
socket.setEncoding('utf8');
socket.on('data', function(data) {
  sockBuf += data;
  var i;
  var l = 0;
  while ((i = sockBuf.indexOf('\n', l)) !== -1) {
    io.sockets.emit('event', sockBuf.slice(l, i));
    l = i + 1;
  }
  if (l)
    sockBuf = sockBuf.slice(l);
});

var sockBuf = '';
socket.setEncoding('utf8');
socket.on('data', function(data) {
  var i = data.indexOf('\n');
  if (i === -1) {
    sockBuf += data;
    return;
  }
  io.sockets.emit('event', sockBuf + data.slice(0, i));
  var l = i + 1;
  while ((i = data.indexOf('\n', l)) !== -1) {
    io.sockets.emit('event', data.slice(l, i));
    l = i + 1;
  }
  sockBuf = data.slice(l);
});