向web客户端发送实时数据错误捕获

尝试将数据从串行设备发送到Web客户端。我正在使用串行到网络代理ser2Net以使数据可用于作用于数据的服务器，并将操作版本的数据发送给Web客户端。客户端指定ser2net主机和端口的位置。这一行动的核心在node.js中被编码如下所示：向web客户端发送实时数据错误捕获

function getDataStream(socket, dataSourcePort, host) { 
    var dataStream = net.createConnection(dataSourcePort, host), 
     dataLine = ""; 

    dataStream.on('error', function(error){ 
     socket.emit('error',{message:"Source not found on host:"+ host + " port:"+dataSourcePort}); 
     console.log(error); 
    }); 

    dataStream.on('connect', function(){ 
     socket.emit('connected',{message:"Data Source Found"}); 
    }); 

    dataStream.on('close', function(){ 
     console.log("Close socket");  
    }); 

    dataStream.on('end',function(){ 
     console.log('socket ended'); 
     dataConnection.emit('lost',{connectInfo:{host:host,port:dataSourcePort}}); 
    }); 

    dataStream.on('data', function(data) { 

     // Collect a line from the host 
     line += data.toString(); 
     // Split collected data by delimiter 
     line.split(delimiter).forEach(function (part, i, array) { 
     if (i !== array.length-1) { // Fully delimited line. 
      //push on to buffer and emit when bufferSendCommand is present 
      dataLine = part.trim(); 
      buffer.push(part.trim()); 
      if(part.substring(0, bufferSendCommand.length) == bufferSendCommand){ 
       gotALine.emit('new', buffer); 
       buffer=[]; 
      } 
     } 
     else { 
      // Last split part might be partial. We can't announce it just yet. 
      line = part; 
     } 
     }); 
    }); 
    return dataStream; 
} 


io.sockets.on('connection', function(socket){ 

    var stream = getDataStream(socket, dataSourcePort, host); 

    //dispense incoming data from data server 
    gotALine.on('new', function(buffer){ 
     socket.emit('feed', {feedLines: buffer}); 
    }); 

    dataConnection.on('lost', function(connectInfo){ 
     setTimeout(function(){ 
      console.log("Trying --- to reconnect "); 
      stream = getDataStream(socket, connectInfo.port, connectInfo.host); 
     },5000); 
    }); 

    // Handle Client request to change stream 
    socket.on('message',function(data) { 
     var clientMessage = JSON.parse(data); 
     if('connectString' in clientMessage 
      && clientMessage.connectString.dataHost !== '' 
      && clientMessage.connectString.dataPort !== '') { 
      stream.destroy(); 
      stream = getDataStream(socket, 
       clientMessage.connectString.dataPort, 
       clientMessage.connectString.dataHost); 
     } 
    });  
});

直到串行设备脱落和ser2net停止发送数据，此作品不够好。我试图捕捉套接字并重新连接不起作用。事件得到正确发射，但setTimeout只能进行一次。我想找到一种方法，在向客户端发送通知或重试尝试的消息时尝试重新连接。我是node.js新手，这可能不是最好的方式来做到这一点。任何建议，将不胜感激。

来源

2013-01-11 lowjumpingfrog

好吧，我想我想通了在dataStream.on（“数据” ......我加了的setTimeout

clearTimeout(connectionMonitor); 
connectionMonitor = setTimeout(function(){doReconnect(socket);}, someThresholdTime);

超时执行，如果数据停止进来，因为它是反复每次清除数据进入。doReconnect功能不断尝试连接并向客户端发送消息，表示发生了不利的事情。

来源

2013-01-12 21:54:05 lowjumpingfrog

向web客户端发送实时数据错误捕获

回答

相关问题