侯体宗的博客
  • 首页
  • Hyperf版
  • beego仿版
  • 人生(杂谈)
  • 技术
  • 关于我
  • 更多分类
    • 文件下载
    • 文字修仙
    • 中国象棋ai
    • 群聊
    • 九宫格抽奖
    • 拼图
    • 消消乐
    • 相册

Nodejs创建TCP服务器 - king0222

前端  /  管理员 发布于 5年前   338

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();


  • 上一条:
    电脑能不能自动做系统?电脑自动做系统的方法详细图文教程
    下一条:
    为Node.js程序配置使用Nginx服务器的简明教程
  • 昵称:

    邮箱:

    0条评论 (评论内容有缓存机制,请悉知!)
    最新最热
    • 分类目录
    • 人生(杂谈)
    • 技术
    • linux
    • Java
    • php
    • 框架(架构)
    • 前端
    • ThinkPHP
    • 数据库
    • 微信(小程序)
    • Laravel
    • Redis
    • Docker
    • Go
    • swoole
    • Windows
    • Python
    • 苹果(mac/ios)
    • 相关文章
    • 使用 Alpine.js 排序插件对元素进行排序(0个评论)
    • 在js中使用jszip + file-saver实现批量下载OSS文件功能示例(0个评论)
    • 在vue中实现父页面按钮显示子组件中的el-dialog效果(0个评论)
    • 使用mock-server实现模拟接口对接流程步骤(0个评论)
    • vue项目打包程序实现把项目打包成一个exe可执行程序(0个评论)
    • 近期文章
    • 智能合约Solidity学习CryptoZombie第三课:组建僵尸军队(高级Solidity理论)(0个评论)
    • 智能合约Solidity学习CryptoZombie第二课:让你的僵尸猎食(0个评论)
    • 智能合约Solidity学习CryptoZombie第一课:生成一只你的僵尸(0个评论)
    • 在go中实现一个常用的先进先出的缓存淘汰算法示例代码(0个评论)
    • 在go+gin中使用"github.com/skip2/go-qrcode"实现url转二维码功能(0个评论)
    • 在go语言中使用api.geonames.org接口实现根据国际邮政编码获取地址信息功能(1个评论)
    • 在go语言中使用github.com/signintech/gopdf实现生成pdf分页文件功能(0个评论)
    • gmail发邮件报错:534 5.7.9 Application-specific password required...解决方案(0个评论)
    • 欧盟关于强迫劳动的规定的官方举报渠道及官方举报网站(0个评论)
    • 在go语言中使用github.com/signintech/gopdf实现生成pdf文件功能(0个评论)
    • 近期评论
    • 122 在

      学历:一种延缓就业设计,生活需求下的权衡之选中评论 工作几年后,报名考研了,到现在还没认真学习备考,迷茫中。作为一名北漂互联网打工人..
    • 123 在

      Clash for Windows作者删库跑路了,github已404中评论 按理说只要你在国内,所有的流量进出都在监控范围内,不管你怎么隐藏也没用,想搞你分..
    • 原梓番博客 在

      在Laravel框架中使用模型Model分表最简单的方法中评论 好久好久都没看友情链接申请了,今天刚看,已经添加。..
    • 博主 在

      佛跳墙vpn软件不会用?上不了网?佛跳墙vpn常见问题以及解决办法中评论 @1111老铁这个不行了,可以看看近期评论的其他文章..
    • 1111 在

      佛跳墙vpn软件不会用?上不了网?佛跳墙vpn常见问题以及解决办法中评论 网站不能打开,博主百忙中能否发个APP下载链接,佛跳墙或极光..
    • 2016-10
    • 2016-11
    • 2017-06
    • 2017-07
    • 2017-08
    • 2017-09
    • 2017-10
    • 2017-11
    • 2018-03
    • 2018-04
    • 2018-05
    • 2018-06
    • 2018-09
    • 2018-11
    • 2018-12
    • 2019-02
    • 2020-03
    • 2020-04
    • 2020-05
    • 2020-06
    • 2021-04
    • 2021-05
    • 2021-07
    • 2021-08
    • 2021-09
    • 2021-10
    • 2021-11
    • 2022-08
    • 2022-09
    • 2022-10
    • 2022-11
    • 2022-12
    • 2023-01
    • 2023-02
    • 2023-03
    • 2023-04
    • 2023-05
    • 2023-06
    • 2023-07
    • 2023-09
    • 2023-10
    • 2023-11
    • 2023-12
    • 2024-01
    • 2024-02
    • 2024-03
    • 2024-04
    Top

    Copyright·© 2019 侯体宗版权所有· 粤ICP备20027696号 PHP交流群

    侯体宗的博客