2

我在 Node.js 中有一个非常简单的 TCP 套接字。它连接到以 XML 格式发回数据的设备。有一个 C# 程序可以做到这一点,但我必须在 Node.js 中构建它。

因此,当设备发送消息时,我会在大约 5 秒后收到响应!C# 程序在 1 或 2 秒后得到它。

看起来“tcp 套接字”具有特定的轮询频率或某种“等待功能”。这甚至可能吗?每次显示传入消息。它还显示“sock.on('close')”的退出消息

似乎 5 秒后“服务器”自动关闭。见底线“console.log('[LISTENER] Connection paused.');” 之后,传入的消息将正确显示。

我的代码有什么问题?

// Set Node.js dependencies
var fs = require('fs');
var net = require('net');

// Handle uncaughtExceptions
process.on('uncaughtException', function (err) {
    console.log('Error: ', err);
    // Write to logfile
    var log = fs.createWriteStream('error.log', {'flags': 'a'});
    log.write(err+'\n\r');

});

/*  
    -------------------------------------------------
    Socket TCP : TELLER
    -------------------------------------------------
*/
var oHOST = '10.180.2.210';
var oPORT = 4100;

var client = new net.Socket();
client.connect(oPORT, oHOST, function() {

            console.log('TCP TELLER tells to: ' + oHOST + ':' + oPORT);

            // send xml message here, this goes correct!
            client.write(oMessage);                     
});

// Event handler: incoming data
client.on('data', function(data) {
    // Close the client socket completely
    client.destroy();
});

// Event handler: close connection
client.on('close', function() {
    console.log('[TELLER] Connection paused.');
});     

/*  
    -------------------------------------------------
    Socket TCP : LISTENER
    -------------------------------------------------
*/
var iHOST = '0.0.0.0';
var iPORT = 4102;

// Create a server instance, and chain the listen function to it
var server = net.createServer(function(sock) {

    // We have a connection - a socket object is assigned to the connection automatically
    console.log('TCP LISTENER hearing on: ' + sock.remoteAddress +':'+ sock.remotePort);

    // Event handler: incoming data
    sock.on('data', function(data) {
        console.log('Message: ', ' '+data);
    });

    // Event handler: close connection
    sock.on('close', function(data) {
        console.log('[LISTENER] Connection paused.');
    });

}).listen(iPORT, iHOST);    
4

3 回答 3

0

client.write() 并不总是立即发送数据,它会等到缓冲区满后再发送数据包。client.end() 将关闭套接字并刷新缓冲区。

于 2012-11-15T20:33:47.637 回答
0

你可以试试这个:http ://nodejs.org/api/net.html#net_socket_setnodelay_nodelay

不过,您的 5 秒延迟确实有点奇怪。

于 2012-11-15T20:54:49.317 回答
0

所以在“TELLER”中我不得不写“sock.write(data);” 在 "sock.on('data', function(data)" 事件中。

现在可以了。感谢 Jeremy 和 rdrey 帮助我朝着正确的方向前进。

于 2012-11-15T21:45:00.660 回答