2015-09-03 57 views
1

我正在尝试创建一个简单的Node.js脚本,该脚本在未使用分配的端口时创建服务器,或者如果端口正在连接到服务器用过的。我正在使用递归方法(使用this链接作为参考),所以我在两个不同的cmd窗口上运行相同的.js文件。Node.js:即使allowHalfOpen设置为True,客户端与服务器断开连接

问题是,每当客户端连接到服务器,它会自动进入'结束'侦听器,我不知道为什么。阅读文档后,我发现了关于allowHalfOpen属性,它的下面是API中说:

如果allowHalfOpen为真,则套接字不会自动发送一个FIN数据包时的另一端套接字发送一个FIN数据包。

我认为这是显而易见的解决方案,所以我在服务器上将属性设置为true,但这也不起作用。

下面是代码:

var net = require('net'); 

var PORT_NUMBER = 1337; 

connectToPort = function(connection) { 
    if(connection === "server") { // Connect as server to the port. 
     connectAsServer(); 
    } else if (connection == "client") { // Connect as client to the port. 
     connectAsClient(); 
    } else { 
     console.log("Incorrect Type Of Connection Passed."); 
    } 
} 

connectAsServer = function() { 
    // Attempt to create server. 
    var server = net.createServer({allowHalfOpen:true}, function (socket) { 
     socket.allowHalfOpen = true; 

     socket.write('Hello from Server\r\n'); 
     socket.end("hello"); 
     console.log("someone went into server."); 
     socket.pipe(socket); 
    }); 

    console.log("Trying to Open Port " + PORT_NUMBER); 

    server.listen(PORT_NUMBER, function() { 
     console.log("\nServer 2 is now the official server. \n"); 
    }); 

    server.on('error', function(err) { 
     console.log("error is " + err.code); 
     if(err.code == 'EADDRINUSE') { 
      console.log('Port is in use, becoming client...'); 
      setTimeout(function() { 
       server.close(); 
       connectToPort("client"); 
      }, 1000); 
     } 
     if(err.code == 'ECONNRESET') { 
      console.log("connection reset error."); 
     } 
    }); 

    server.on('end', function() { 
     console.log("server 2 disconnected from port"); 
    }); 
} 

connectAsClient = function() { 

    var client = net.connect({port: PORT_NUMBER}, function() { //'connect' listener 
     console.log('THIS IS CLIENT connected to server!'); 
    }); 

    client.on('data', function(data) { 
     console.log(data.toString()); 
     client.write('hello world! from client!!\r\n'); 
    }); 

    client.on('end', function() { 
     // client automatically goes here. 
     console.log('disconnected from server'); 
    }); 

    client.on('error', function(err) { 
     console.log("there was an error in the client and the error is: " + err.code); 
    }); 
} 

connectToPort("server"); 

这里是从控制台输出:

对于服务器:

enter image description here

对于客户端:

enter image description here

我想要的基本上是让客户端断开,只有当服务器关闭或其他事件发生时。但理想情况下,我希望将它连接到服务器以在它们之间交换数据。

有什么我做错了吗?即使服务器上的allowHalfOpen为true,为什么仍然发送FIN包?

感谢,

回答

0

我看到了我的错误,我有以下行:

socket.end("hello"); 

在服务器内部的代码,它本质上杀死了客户端反正。

相关问题