1

シリアル デバイスから Web クライアントにデータを送信しようとしています。私はシリアルからネットワークへのプロキシであるser2Netを使用して、データに基づいて動作し、データの操作されたバージョンをWebクライアントに送信するサーバーでデータを利用できるようにしています。クライアントは、ser2net ホストとポートの場所を指定します。このアクションのコアは、次のように node.js でコーディングされています。

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 は 1 回しか発生しません。クライアントにメッセージを送信したり、試行を再試行したりしながら、再接続を試み続ける方法を見つけたいと思います。私は node.js の初心者であり、これが最善の方法ではない可能性があります。任意の提案をいただければ幸いです。

4

1 に答える 1

0

わかりました dataStream.on('data' ... setTimeout を追加しました

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

データが着信するたびにデータが繰り返しクリアされるため、タイムアウトはデータの着信が停止した場合に実行されます。

于 2013-01-12T21:54:05.123 に答える