运行流程
运行流程
Node.js 提供了 http 模块直接创建 HTTP 服务,用来响应用户的请求,比如 Node.js 官网提供的创建 HTTP 服务的例子:
const http = require('http');
const hostname = '127.0.0.1';
const port = 3000;
const server = http.createServer((req, res) => {
res.statusCode = 200;
res.setHeader('Content-Type', 'text/plain');
res.end('Hello World\n');
});
server.listen(port, hostname, () => {
console.log(`Server running at http://${hostname}:${port}/`);
});
ThinkJS 也是调用 http.createServer
的方式来创建服务的,所以整个运行流程包含了启动服务和响应用户请求二个部分。
系统服务启动
- 执行
npm start
或者node development.js
- 实例化 ThinkJS 里的 Application 类,执行
run
方法。 - 根据不同的环境(Master 进程、Worker 进程、命令行调用)处理不同的逻辑
- 如果是 Master 进程
- 加载配置文件,生成
think.config
和think.logger
对象。 - 加载文件
src/bootstrap/master.js
文件 - 如果配置文件监听服务,那么开始监听文件的变化,目录为
src/
。 - 文件修改后,如果配置文件编译服务,那么会对文件进行编译,编译到
app/
目录下。 - 根据配置
workers
来 fork 对应数目的 Worker。Worker 进程启动完成后,触发appReady
事件。(可以通过think.app.on("appReady")
来捕获) - 如果文件发生了新的修改,那么会触发编译,然后杀掉所有的 Worker 进程并重新 fork。
- 加载配置文件,生成
- 如果是 Worker 进程
- 加载配置文件,生成
think.config
和think.logger
对象。 - 加载 Extend,为框架提供更多的功能,配置文件为
src/config/extend.js
。 - 获取当前项目的模块列表,放在
think.app.modules
上,如果为单模块,那么值为空数组。 - 加载项目里的 controller 文件(
src/controller/*.js
),放在think.app.controllers
对象上。 - 加载项目里的 logic 文件(
src/logic/*.js
),放在think.app.logics
对象上。 - 加载项目里的 model 文件(
src/model/*.js
),放在think.app.models
对象上。 - 加载项目里的 service 文件(
src/service/*.js
),放在think.app.services
对象上。 - 加载路由配置文件
src/config/router.js
,放在think.app.routers
对象上。 - 加载校验配置文件
src/config/validator.js
,放在think.app.validators
对象上。 - 加载 middleware 配置文件
src/config/middleware.js
,并通过think.app.use
方法注册。 - 加载定时任务配置文件
src/config/crontab.js
,并注册定时任务服务。 - 加载
src/bootstrap/worker.js
启动文件。 - 监听 process 里的
onUncaughtException
和onUnhandledRejection
错误事件,并进行处理。可以在配置src/config.js
自定义这二个错误的处理函数。 - 等待
think.beforeStartServer
注册的启动前处理函数执行,这里可以注册一些服务启动前的事务处理。 - 如果自定义了创建服务配置
createServer
,那么执行这个函数createServer(port, host, callback)
来创建服务。 - 如果没有自定义,则通过
think.app.listen
来启动服务。 - 服务启动完成时,触发
appReady
事件,其他地方可以通过think.app.on("appReady")
监听。 - 创建的服务赋值给
think.app.server
对象。
- 加载配置文件,生成
服务启动后,会打印下面的日志:
[2017-07-02 13:36:40.646] [INFO] - Server running at http://127.0.0.1:8360
[2017-07-02 13:36:40.649] [INFO] - ThinkJS version: 3.0.0-beta1
[2017-07-02 13:36:40.649] [INFO] - Enviroment: development #当前运行的环境
[2017-07-02 13:36:40.649] [INFO] - Workers: 8 #子进程数量
用户请求处理
当用户请求服务时,会经过下面的步骤进行处理。
- 请求到达 webserver(如:nginx),通过反向代理将请求转发给 node 服务。如果直接通过端口访问 node 服务,那么就没有这一步了。
- node 服务接收用户请求,Master 进程将请求转发给对应的 Worker 进程。
- Worker 进程通过注册的 middleware 来处理用户的请求:
- meta 来处理一些通用的信息,如:设置请求的超时时间、是否发送 ThinkJS 版本号、是否发送处理的时间等。
- resource 处理静态资源请求,静态资源都放在
www/static/
下,如果命中当前请求是个静态资源,那么这个 middleware 处理完后提前结束,不再执行后面的 middleware。 - trace 处理一些错误信息,开发环境下打印详细的错误信息,生产环境只是报一个通用的错误。
- payload 处理用户上传的数据,包含:表单数据、文件等。解析完成后将数据放在
request.body
对象上,方便后续读取。 - router 解析路由,解析出请求处理对应的 Controller 和 Action,放在
ctx.controller
和ctx.action
上,方便后续处理。如果项目是多模块结构,那么还有ctx.module
。 - logic 根据解析出来的 controller 和 action,调用 logic 里对应的方法。
- 实例化 logic 类,并将
ctx
传递进去。如果不存在则直接跳过 - 执行
__before
方法,如果返回false
则不再执行后续所有的逻辑(提前结束处理) - 如果
xxxAction
方法存在则执行,结果返回false
则不再执行后续所有的逻辑 - 如果
xxxAction
方法不存在,则试图执行__call
方法 - 执行
__after
方法,如果返回false
则不再执行后续所有的逻辑 - 通过方法返回
false
来阻断后续逻辑的执行
- 实例化 logic 类,并将
- controller 根据解析出来的 controller 和 action,调用 controller 里的对应的方法。
- 具体的调用策略和 logic 完全一致
- 如果不存在,那么当前请求返回 404
- action 执行完成时,可以将结果放在
this.body
属性上然后返回给用户。
- 当 Worker 报错,触发
onUncaughtException
或者onUnhandledRejection
事件,或者 Worker 异常退出时,Master 会捕获到错误,重新 fork 一个新的 Worker 进程,并杀掉当前的进程。
可以看到,所有的用户请求处理都是通过 middleware 来完成的。具体的项目中,可以根据需求,组装更多的 middleware 来处理用户的请求。
本文档系腾讯云开发者社区成员共同维护,如有问题请联系 cloudcommunity@tencent.com