Nodejs创建TCP服务器 - king0222
前端  /  管理员 发布于 4年前   328
1.Nodejs提供了net模块给我们,所以我们创建TCP服务器很简单:
require('net').createServer(function(socket) { // new connection socket.on('data', function(data) { // got data }); socket.on('end', function(data) { // connection closed }); socket.write('Some string'); }).listen();
通过var server = require('net').createServer();这行代码我们可以得到tcp服务器对象的引用。
server对象具注册了以下几个监听事件:
listening,connection,close,error
下面一个例子是在TCP服务器的声明周期中监听了如上几个事件:
var server = require('net').createServer(); var port = ; server.on('listening', function() { console.log('Server is listening on port', port); }); server.on('connection', function(socket) { console.log('Server has a new connection'); socket.end(); server.close(); }); server.on('close', function() { console.log('Server is now closed'); }); server.on('error', function(err) { console.log('Error occurred:', err.message); }); server.listen(port);
一旦建立连接成功后,会得到一个socket对象作为回调中的参数,我们可以操作这个socket对象,前面提到过tcp连接的对象是可读可写的流。作为一个流对象,因此能够监听data,end等事件;作为一个可写流,具有write()方法。 下面是一个能够监听用户输入的例子:
var server = require('net').createServer(function(socket) { console.log('new connection'); socket.setEncoding('utf'); socket.write("Hello! You can start typing. Type 'quit' to exit.\n"); socket.on('data', function(data) { console.log('got:', data.toString()) if (data.trim().toLowerCase() === 'quit') { socket.write('Bye bye!'); return socket.end(); } //反馈回客户端 socket.write(data); }); socket.on('end', function() { console.log('Client connection ended'); }); }).listen();
因为socket对象又是一个可读的流,因此你能够空气他的pause()和resume(),或者你可以直接使用pipe()方法输出一个可写流:
var ws = require('fs').createWriteStream('helloworld.txt'); require('net').createServer(function(socket) { socket.pipe(ws); }).listen();
上面的代码创建了一个可写流对象,然后将这个可写流对象输出到客户端。在客户端可以得到一个名为helloworld.txt的文件,
可以用“telnet localhost 4001”来测试该例子。
因为socket对象同时具有可读流的性质和可写流的性质,因此上面的例子你可以反过来形成下面这样的代码:
require('net').createServer(function(socket) { var rs = require('fs').createReadStream('hello.txt'); rs.pipe(socket); }).listen();
上面的代码将hello.text文件内容输出到socket对象中返回给客户端,当内容输出完成后,tcp连接就会退出,在前面的文章中有说过Pipe的用法,默认情况下在数据读取完成后就会执行end方法,因此如果不想要这样的效果并保持连接的话可以在pipe中添加第二个参数:{ end : false },并重写end监听。
2.闲置socket 当有闲置的socket出现的时候我们需要进行相应的清除的工作,由setTimeout方法可以帮我们把闲置的socket对象关闭。
var timeout = ; // minute socket.setTimeout(timeout); socket.on('timeout', function() { socket.write('idle timeout, disconnecting, bye!'); socket.end(); });
下面是一个更简洁的使用方式:
socket.setTimeout(60000, function() { socket.end('idle timeout, disconnecting, bye!'); });
3.保持连接
复制代码 代码如下:
socket.setKeepAlive(true);
你也可以添加第二个参数在设置可延时时长:
复制代码 代码如下:
socket.setKeepAlive(true, 10000); // 10 seconds
4.是否使用延时
kernel会在发送tcp数据包之前缓存数据,因此会占据一定的延时,这对于某些小数据包场景来说是有用的,但如果你不希望有这样的延时的话,那么你可以这样设置:
复制代码 代码如下:
socket.setNoDelay(true);
var port = ;
var host = '...';
server.listen(port, host);
listen方法的第二个参数是监听客户端的ip地址,如果填写则只监听所填写的ip,否则则监听所有ip地址,默认情况下不填写。 关闭服务器连接,我们可以使用close方法,同时也可以对该事件进行监听。
复制代码 代码如下:
server.close();
server.on('close', function() {
console.log('server closed!');
});
6.创建一个简单的TCP聊天室服务器
var net = require('net'); var server = net.createServer(); var sockets = []; server.on('connection', function(socket) { console.log('got a new connection'); sockets.push(socket); console.log('sockets length:', sockets.length); socket.on('data', function(data) { console.log('got data:', data.toString()); sockets.forEach(function(otherSocket) { if (otherSocket !== socket) { otherSocket.write(data); } }); }); socket.on('close', function() { console.log('connection closed'); var index = sockets.indexOf(socket); sockets.splice(index, ); console.log('sockets length:', sockets.length); }); }); server.on('error', function(err) { console.log('Server error:', err.message); }); server.on('close', function() { console.log('Server closed'); }); server.listen();
122 在
学历:一种延缓就业设计,生活需求下的权衡之选中评论 工作几年后,报名考研了,到现在还没认真学习备考,迷茫中。作为一名北漂互联网打工人..123 在
Clash for Windows作者删库跑路了,github已404中评论 按理说只要你在国内,所有的流量进出都在监控范围内,不管你怎么隐藏也没用,想搞你分..原梓番博客 在
在Laravel框架中使用模型Model分表最简单的方法中评论 好久好久都没看友情链接申请了,今天刚看,已经添加。..博主 在
佛跳墙vpn软件不会用?上不了网?佛跳墙vpn常见问题以及解决办法中评论 @1111老铁这个不行了,可以看看近期评论的其他文章..1111 在
佛跳墙vpn软件不会用?上不了网?佛跳墙vpn常见问题以及解决办法中评论 网站不能打开,博主百忙中能否发个APP下载链接,佛跳墙或极光..
Copyright·© 2019 侯体宗版权所有·
粤ICP备20027696号