精华 在Node.js中使用TCP套接字编程
发布于 7 年前 作者 alli 116018 次浏览 最后一次编辑是 3 年前

译自http://www.hacksparrow.com/tcp-socket-programming-in-node-js.html

想知道如何在NodeJS中使用socket编程?在NodeJS中有三种socket:1. TCP,2. UDP,3. Unix域套接字,本文主要介绍NodeJS中TCP的基本编程知识。

你可以创建两种类型的TCP套接字:1. 服务端,2. 客户端。服务端TCP监听来自客户端的连接请求,并使用TCP连接向客户端发送数据;客户端TCP连接到服务端并与服务器交互数据。客户端与服务端之间依靠套接字进行双向通信。

在NodeJS中使用TCP需要引用net模块。net模块是NodeJS中异步网络编程的封装,可以做很多事情,本文仅关注于如何使用该模块创建服务端与客户端的TCP套接字。

创建TCP服务端

下面是一个在NodeJS中创建TCP服务端套接字的简单例子,相关说明见代码注释。

var net = require('net');

var HOST = '127.0.0.1';
var PORT = 6969;

// 创建一个TCP服务器实例,调用listen函数开始监听指定端口
// 传入net.createServer()的回调函数将作为”connection“事件的处理函数
// 在每一个“connection”事件中,该回调函数接收到的socket对象是唯一的
net.createServer(function(sock) {

    // 我们获得一个连接 - 该连接自动关联一个socket对象
    console.log('CONNECTED: ' +
        sock.remoteAddress + ':' + sock.remotePort);

    // 为这个socket实例添加一个"data"事件处理函数
    sock.on('data', function(data) {
        console.log('DATA ' + sock.remoteAddress + ': ' + data);
        // 回发该数据,客户端将收到来自服务端的数据
        sock.write('You said "' + data + '"');
    });

    // 为这个socket实例添加一个"close"事件处理函数
    sock.on('close', function(data) {
        console.log('CLOSED: ' +
            sock.remoteAddress + ' ' + sock.remotePort);
    });

}).listen(PORT, HOST);

console.log('Server listening on ' + HOST +':'+ PORT);

服务端也可以用稍不同的方式接受TCP连接,即显式处理"connection"事件:

var server = net.createServer();
server.listen(PORT, HOST);
console.log('Server listening on ' +
    server.address().address + ':' + server.address().port);

server.on('connection', function(sock) {

    console.log('CONNECTED: ' +
         sock.remoteAddress +':'+ sock.remotePort);
    // 其它内容与前例相同

});

上述两个例子只是写法不同,并无本质区别。

创建TCP客户端

现在让我们创建一个TCP客户端连接到刚创建的服务器上,该客户端向服务器发送一串消息,并在得到服务器的反馈后关闭连接。下面的代码描述了这一过程。

var net = require('net');

var HOST = '127.0.0.1';
var PORT = 6969;

var client = new net.Socket();
client.connect(PORT, HOST, function() {

    console.log('CONNECTED TO: ' + HOST + ':' + PORT);
    // 建立连接后立即向服务器发送数据,服务器将收到这些数据 
    client.write('I am Chuck Norris!');

});

// 为客户端添加“data”事件处理函数
// data是服务器发回的数据
client.on('data', function(data) {

    console.log('DATA: ' + data);
    // 完全关闭连接
    client.destroy();

});

// 为客户端添加“close”事件处理函数
client.on('close', function() {
    console.log('Connection closed');
});

这就是NodeJS中进行TCP网络编程的基本过程,希望能对你有所帮助。需要注意的是,套接字编程要比这里的例子复杂得多,当你使用套接字发送大量数据或完成复杂任务的时候,你就会用到流(Streams)和缓冲区(Buffers)等相关模块。

进一步阅读

  1. NodeJS net 模块
  2. NodeJS stream 模块
  3. NodeJS buffer 模块
25 回复

写得很详细,不过照例子里的代码看来,好像例子是外国人写的

client.write('I am Chuck Norris!');

不过没关系,描述得很好。

Sorry,没看到正文开头,原来是译文!

不好意思,的确是译文。本来想自己写点TCP的简介,偶见一篇外文,内容也算称心,就转译在这了。

请教一个问题 我想用node和java服务器通讯,用的net模块,双方是长连接的形式。在客户端接收数据的时候data事件被触发了好几次,有时候是一次有时候是两次多的时候有五六次,由于服务端没有关闭连接,那么在客户端就不会触发end事件和close事件,这样就无法判断数据什么时候接收完。这样的情况该怎么处理呢?

建议你用zmq,会很开心的

Very good example for us. Thanks.

创建的客户端有什么作用? var net = require(‘net’); 它用到了很多node的模块,不能直接放在客户端吧,不然怎么运行?

看到所有的node.js net socket的讲解就是这么一个demo,等我把手上稍微复杂一点的demo完成了发个example上来

对于这个问题,你首先要设计一个通信协议,二进制或者文本都行,二进制协议比如4个包头的长度然后包体数据,文本协议可以参考memcached文本协议,更加复杂的http协议,希望能给你帮助。

请问哪里又免费的空间,支持使用net模块实现的tcp? 貌似很多空间都不支持net模块

请教下 我运行例子的时候 为什么server端在进入close之后sock.remoteAddress和 sock.remotePort都是undefined了?

DATA 127.0.0.1: I am here! CLOSED: undefined undefined

请问socket.io使用的是哪一种socket编程呢?

@yualone 建议你看看这个,里面有TCP socket的完整通讯模块。https://cnodejs.org/topic/5506a3eecfb53dab033a8308

我想问一个问题,当客户端连接服务器后,关掉服务器,客户端会报错:TypeError: Object #<Socket> has no method ‘destory’,这是怎么回事啊?

有点小问题,服务端下面的代码,sock.remoteAddress和sock.remotePort都是undefined。node版本v0.12.4

// 为这个socket实例添加一个"close"事件处理函数
    sock.on('close', function(data) {
        console.log('CLOSED: ' +
            sock.remoteAddress + ' ' + sock.remotePort);
    });

@yualone 不是应该是在接受完数据的时候告诉服务端接受完,然后触发end事件,但是这样连接就断开了。。为什么要用长连接呢

我想问下,服务器设置N秒之后启动成功,客户端立马去运行,这样的话,客户端发送数据,服务器就没法收到信息,这块怎么优化呢?比如客户端连接服务器的时候,怎么判断成功连接到了服务器?

@alli 是增强了哪部分功能

V587, 谢谢楼主分享

五年前 -。 -

回到顶部