需求

  • 一个简单的静态文件合并服务器,该服务器需要支持类似以下格式的JS或CSS文件合并请求。
http://assets.example.com/foo/??bar.js,baz.js
  • 在以上URL中,??是一个分隔符,之前是需要合并的多个文件的URL的公共部分,之后是使用,分隔的差异部分。因此服务器处理这个URL时,返回的是以下两个文件按顺序合并后的内容。
/foo/bar.js
/foo/baz.js
  • 另外,服务器也需要能支持类似以下格式的普通的JS或CSS文件请求。
http://assets.example.com/foo/bar.js

第一次迭代

  • 设计方案
          +---------+   +-----------+   +----------+
request -->|  parse  |-->|  combine  |-->|  output  |--> response+---------+   +-----------+   +----------+//服务器会首先分析URL,得到请求的文件的路径和类型(MIME)。然后,服务器会读取请求的文件,并按顺序合并文件内容。最后,服务器返回响应,完成对一次请求的处理;另外,服务器在读取文件时需要有个根目录,并且服务器监听的HTTP端口最好也不要写死在代码里,因此服务器需要是可配置的。
  • 实现
var fs = require('fs'),path = require('path'),http = require('http');var MIME = {'.css': 'text/css','.js': 'application/javascript'
};function combineFiles(pathnames, callback) {var output = [];(function next(i, len) {if (i < len) {fs.readFile(pathnames[i], function (err, data) {if (err) {callback(err);} else {output.push(data);next(i + 1, len);}});} else {callback(null, Buffer.concat(output));}}(0, pathnames.length));
}function main(argv) {var config = JSON.parse(fs.readFileSync(argv[0], 'utf-8')),root = config.root || '.',port = config.port || 80;http.createServer(function (request, response) {var urlInfo = parseURL(root, request.url);combineFiles(urlInfo.pathnames, function (err, data) {if (err) {response.writeHead(404);response.end(err.message);} else {response.writeHead(200, {'Content-Type': urlInfo.mime});response.end(data);}});}).listen(port);
}function parseURL(root, url) {var base, pathnames, parts;if (url.indexOf('??') === -1) {url = url.replace('/', '/??');}parts = url.split('??');base = parts[0];pathnames = parts[1].split(',').map(function (value) {return path.join(root, base, value);});return {mime: MIME[path.extname(pathnames[0])] || 'text/plain',pathnames: pathnames};
}main(process.argv.slice(2));
  • 注意

    • 使用命令行参数传递JSON配置文件路径,入口函数负责读取配置并创建服务器。

    • 入口函数完整描述了程序的运行逻辑,其中解析URL和合并文件的具体实现封装在其它两个函数里。

    • 解析URL时先将普通URL转换为了文件合并URL,使得两种URL的处理方式可以一致。

    • 合并文件时使用异步API读取文件,避免服务器因等待磁盘IO而发生阻塞。

  • 把以上代码保存为server.js,之后就可以通过node server.js config.json命令启动程序

第二次迭代

  • 第一次迭代之后,已经有了一个可工作的版本,满足了功能需求。接下来从性能的角度出发,看看代码还有哪些改进余地。

  • map方法换成for循环或许会更快一些,但第一版代码最大的性能问题存在于从读取文件到输出响应的过程当中。以处理/??a.js,b.js,c.js这个请求为例,看看整个处理过程中耗时在哪儿。

 发送请求       等待服务端响应         接收响应
---------+----------------------+------------->--                                        解析请求------                                  读取a.js------                            读取b.js------                      读取c.js--                    合并数据--                  输出响应
  • 第一版代码依次把请求的文件读取到内存中之后,再合并数据和输出响应。这会导致以下两个问题:

    • 当请求的文件比较多比较大时,串行读取文件会比较耗时,从而拉长了服务端响应等待时间。
    • 由于每次响应输出的数据都需要先完整地缓存在内存里,当服务器请求并发数较大时,会有较大的内存开销。
  • 对于第一个问题,很容易想到把读取文件的方式从串行改为并行。但是别这样做,因为对于机械磁盘而言,因为只有一个磁头,尝试并行读取文件只会造成磁头频繁抖动,反而降低IO效率。而对于固态硬盘,虽然的确存在多个并行IO通道,但是对于服务器并行处理的多个请求而言,硬盘已经在做并行IO了,对单个请求采用并行IO无异于拆东墙补西墙。因此,正确的做法不是改用并行IO,而是一边读取文件一边输出响应,把响应输出时机提前至读取第一个文件的时刻。这样调整后,整个请求处理过程变成下边这样。
发送请求 等待服务端响应 接收响应
---------+----+------------------------------->--                                        解析请求--                                      检查文件是否存在--                                    输出响应头------                              读取和输出a.js------                        读取和输出b.js------                  读取和输出c.js
  • 实现
function main(argv) {var config = JSON.parse(fs.readFileSync(argv[0], 'utf-8')),root = config.root || '.',port = config.port || 80;http.createServer(function (request, response) {var urlInfo = parseURL(root, request.url);validateFiles(urlInfo.pathnames, function (err, pathnames) {if (err) {response.writeHead(404);response.end(err.message);} else {response.writeHead(200, {'Content-Type': urlInfo.mime});outputFiles(pathnames, response);}});}).listen(port);
}function outputFiles(pathnames, writer) {(function next(i, len) {if (i < len) {var reader = fs.createReadStream(pathnames[i]);reader.pipe(writer, { end: false });reader.on('end', function() {next(i + 1, len);});} else {writer.end();}}(0, pathnames.length));
}function validateFiles(pathnames, callback) {(function next(i, len) {if (i < len) {fs.stat(pathnames[i], function (err, stats) {if (err) {callback(err);} else if (!stats.isFile()) {callback(new Error());} else {next(i + 1, len);}});} else {callback(null, pathnames);}}(0, pathnames.length));
}
  • 第二版代码在检查了请求的所有文件是否有效之后,立即就输出了响应头,并接着一边按顺序读取文件一边输出响应内容。并且,在读取文件时,第二版代码直接使用了只读数据流来简化代码。

第三次迭代

  • 接下来需要从稳定性的角度重新审视一下代码

  • 从工程角度上讲,没有绝对可靠的系统。即使第二次迭代的代码经过反复检查后能确保没有bug,也很难说是否会因为NodeJS本身,或者是操作系统本身,甚至是硬件本身导致服务器程序在某一天挂掉。因此一般生产环境下的服务器程序都配有一个守护进程,在服务挂掉的时候立即重启服务。一般守护进程的代码会远比服务进程的代码简单,从概率上可以保证守护进程更难挂掉。如果再做得严谨一些,甚至守护进程自身可以在自己挂掉时重启自己,从而实现双保险。

  • 因此在本次迭代时,先利用NodeJS的进程管理机制,将守护进程作为父进程,将服务器程序作为子进程,并让父进程监控子进程的运行状态,在其异常退出时重启子进程。

var cp = require('child_process');var worker;function spawn(server, config) {worker = cp.spawn('node', [ server, config ]);worker.on('exit', function (code) {if (code !== 0) {spawn(server, config);}});
}function main(argv) {spawn('server.js', argv[0]);process.on('SIGTERM', function () {worker.kill();process.exit(0);});
}main(process.argv.slice(2));
  • 此外,服务器代码本身的入口函数也要做以下调整。
function main(argv) {var config = JSON.parse(fs.readFileSync(argv[0], 'utf-8')),root = config.root || '.',port = config.port || 80,server;server = http.createServer(function (request, response) {...}).listen(port);process.on('SIGTERM', function () {server.close(function () {process.exit(0);});});
}
  • 可以把守护进程的代码保存为daemon.js,之后可以通过node daemon.js config.json启动服务,而守护进程会进一步启动和监控服务器进程。
  • 为了能够正常终止服务,让守护进程在接收到SIGTERM信号时终止服务器进程。而在服务器进程这一端,同样在收到SIGTERM信号时先停掉HTTP服务再正常退出。至此,服务器程序就靠谱很多了。

第四次迭代

  • 解决了服务器本身的功能、性能和可靠性的问题后,接着需要考虑一下代码部署的问题,以及服务器控制的问题。

  • 一般而言,程序在服务器上有一个固定的部署目录,每次程序有更新后,都重新发布到部署目录里。而一旦完成部署后,一般也可以通过固定的服务控制脚本启动和停止服务。因此服务器程序部署目录可以做如下设计。

- deploy/- bin/startws.shkillws.sh+ conf/config.json+ lib/daemon.jsserver.js
  • 在以上目录结构中,分类存放了服务控制脚本、配置文件和服务器代码。

  • 按以上目录结构分别存放对应的文件之后,接下来看看控制脚本怎么写。首先是start.sh

#!/bin/sh
if [ ! -f "pid" ]
thennode ../lib/daemon.js ../conf/config.json &echo $! > pid
fi
  • 然后是killws.sh
#!/bin/sh
if [ -f "pid" ]
thenkill $(tr -d '\r\n' < pid)rm pid
fi

后续迭代

  • 服务器程序正式上线工作后,接下来或许会发现还有很多可以改进的点。比如服务器程序在合并JS文件时可以自动在JS文件之间插入一个;来避免一些语法问题,比如服务器程序需要提供日志来统计访问量,比如服务器程序需要能充分利用多核CPU,等等。

建议

  • 要熟悉官方API文档。并不是说要熟悉到能记住每个API的名称和用法,而是要熟悉NodeJS提供了哪些功能,一旦需要时知道查询API文档的哪块地方。

  • 要先设计再实现。在开发一个程序前首先要有一个全局的设计,不一定要很周全,但要足够能写出一些代码。

  • 要实现后再设计。在写了一些代码,有了一些具体的东西后,一定会发现一些之前忽略掉的细节。这时再反过来改进之前的设计,为第二轮迭代做准备。

  • 要充分利用三方包。NodeJS有一个庞大的生态圈,在写代码之前先看看有没有现成的三方包能节省不少时间。

  • 不要迷信三方包。任何事情做过头了就不好了,三方包也是一样。三方包是一个黑盒,每多使用一个三方包,就为程序增加了一份潜在风险。并且三方包很难恰好只提供程序需要的功能,每多使用一个三方包,就让程序更加臃肿一些。因此在决定使用某个三方包之前,最好三思而后行。

转载于:https://www.cnblogs.com/jinkspeng/p/4396429.html

node.js整理 07例子相关推荐

  1. [转]为什么我要用 Node.js? 案例逐一介绍

    原文地址:http://blog.jobbole.com/53736/ 介绍 JavaScript 高涨的人气带来了很多变化,以至于如今使用其进行网络开发的形式也变得截然不同了.就如同在浏览器中一样, ...

  2. node.js学习总结

    NodeJS介绍 1.概述: Node.js是基于Chrome JavaScript运行时建立的一个平台,实际上它是对Google Chrome V8引擎 进行了封装,它主要用于创建快速的.可扩展的网 ...

  3. 查询分析器在哪里_你应该知道的3种Node.js分析器类型

    Node.js类似于许多其他编码语言,因为它需要与正确的工具结合使用来调试程序,克服任何瓶颈并优化其功能.使用正确的分析器,您可以毫不费力地实现这一目标,尽管它们都不是完美的. 在编码中,分析器是一种 ...

  4. linux进程退出所有tcp数据才发送,深入理解Node.js 进程与线程(8000长文彻底搞懂)...

    前言 进程与线程是一个程序员的必知概念,面试经常被问及,但是一些文章内容只是讲讲理论知识,可能一些小伙伴并没有真的理解,在实际开发中应用也比较少.本篇文章除了介绍概念,通过Node.js 的角度讲解进 ...

  5. Node.js 应该用在什么地方

    Node.js 应该用在什么地方 聊天 聊天是最典型的多用户实时交互的应用.从IRC开始,有许多开源或者不开源的协议都运行在非标准端口上,而现在,使用 Node.js 则可以解决这些问题--在标准的8 ...

  6. 为什么我要用 Node.js? 案例逐一介绍

    介绍 JavaScript 高涨的人气带来了很多变化,以至于如今使用其进行网络开发的形式也变得截然不同了.就如同在浏览器中一样,现在我们也可以在服务器上运行 JavaScript ,从前端跨越到后端, ...

  7. Node.js到底是什么?为什么要使用它?

    by Dariya Kursova 通过达里娅·库尔索娃(Dariya Kursova) Node.js到底是什么?为什么要使用它? (What exactly is Node.js and why ...

  8. Node.js之Stream

    Node.js之Stream 例子1 Steam-流 例子2\3 管道 Stream对象的原型链 Stream的分类 自创流 例子1 const fs = require("fs" ...

  9. 拥抱Node.js 8.0,N-API入门极简例子

    本文摘录自<Nodejs学习笔记>,更多章节及更新,请访问 github主页地址.欢迎加群交流,群号 197339705. N-API简介 Node.js 8.0 在2017年6月份发布, ...

最新文章

  1. 3.分支结构与循环结构
  2. 使用Ansible批量部署SSH免密登录远程主机
  3. Scrapy中的splash的安装应用
  4. PHP与MYSQL数据库链接方法
  5. 一段代码把网站变成灰白色
  6. python四大器_Python编程四大神兽:迭代器、生成器、闭包和装饰器
  7. Atitit 文档的格式演变attilax总结
  8. JAVA的对象创建与调用的内存解析
  9. java定义数字类型的代码_数字类型内置方法(示例代码)
  10. 深入理解JS对象和原型链
  11. Zookeeper-watcher机制源码分析(一)
  12. Kotlin如何写脚本
  13. [渝粤教育] 扬州市职业大学 液压与气动技术 参考 资料
  14. 微信怎样设置聊天显示的字体大小?简单技巧!微信如何调整字体的大小?
  15. 一次性餐巾行业调研报告 - 市场现状分析与发展前景预测
  16. STM32F103_study56_The punctual atoms(STM32 PWM output experimental code analysis)
  17. 表单_内置Filed
  18. 判断天干,地支,生肖推算
  19. Android使用HttpURLConnection访问网络
  20. 你想要成为团队里什么样的角色呢?

热门文章

  1. 自动控制原理第二版王建辉_气箱脉冲布袋除尘器的工作原理
  2. Qt笔记-AES加密
  3. Leaflet笔记-Leaflet与echarts结合使用(在地图上绘图表)
  4. Spring Boot笔记-echarts的使用及数据的修改
  5. 对HTTP基本认识(HTTP协议入门必备)
  6. Linux学习笔记-Linux下的设备文件
  7. Qt工作笔记-QString中Split与section效率实践
  8. python中的参数函数_python中函数与参数的简介
  9. for in range语句_Python 之旅5——for循环
  10. isvisible java_.NET(C#) Selenium操作调用浏览器判断页面元素(ElementIsVisible)可见的方法...