Fastify 系列教程二（中间件、钩子函数和装饰器）

Fastify 系列教程：

Fastify 系列教程一 (路由和日志)
Fastify 系列教程二 (中间件、钩子函数和装饰器)
Fastify 系列教程三 (验证、序列化和生命周期)
Fastify 系列教程四 (请求对象、响应对象和插件)

中间件

Fastify 提供了与 Express 和 Restify 中间件兼容的异步中间件引擎。

所以，Fastify 可以使用 Express 中间件。

注意：Fastify 中没有错误处理中间件(err, req, res, next)。如果需要处理中间件中的错误时，只需要调用 next(new Error('error message')) 即可，Fastify 会为你关闭请求并发送错误响应。

示例：

访问静态资源

配置 serve-static 访问静态资源。

目录结构：

public

   |-css

   |-js

      |-jquery.js

   |-images

views

app.js

app.js:

const serveStatic = require('serve-static')

const path = require('path')

fastify.use('/public', serveStatic(path.resolve(__dirname, 'public')))

此时，访问 localhost:3030/public/js/jquery.js 可以正确获得静态资源文件。

注意：中间件的请求和响应参数是原生 Nodejs Http 的 req 和 res，而路由中的 request 和 reply 是经过 Fastify 封装的，两者并不一样：

const fastify = require('fastify')()

fastify.use(function(req, res, next){

  req.hello = "req.hello"

  res.hello = "res.hello"

  next()

})

fastify.use(function(req, res, next){

  console.log('middle:', req.hello)

  console.log('middle:', res.hello)

  next()

})

fastify.get('/', function (request, reply) {

  console.log('route:', request.hello)

  console.log('route:', reply.hello)

  reply.send({ hello: 'world' })

})

/*

middle: req.hello

middle: res.hello

route: undefined

route: undefined

*/

钩子函数

Fastify 中共有四个应用级钩子和一个路由级钩子。

四个应用级钩子：

onRequest(req, res, next)
preHandler(request, reply, next)
onResponse(res, next)
onClose(instance, done)

一个路由级钩子：

beforeHandler(request, reply, done)

注意 req、res 和 request、reply 的区别。

参数	描述
req	Node.js Http 请求对象
res	Node.js Http 响应对象
request	Fastify Request 接口
reply	Fastify Reply 接口
next	继续下一个生命周期任务

使用 addHook 方法添加钩子函数：

fastify.addHook('onRequest', (req, res, next) => {

  // some code

  next()

})

fastify.addHook('preHandler', (request, reply, next) => {

  // some code

  next()

})

fastify.addHook('onResponse', (res, next) => {

  // some code

  next()

})

如果在执行钩子函数时遇到错误，只需将其传递给 next()，并且 Fastify 将自动关闭请求并向用户发送相应的错误代码。

fastify.addHook('onRequest', (req, res, next) => {

next(new Error('some error'))

})

如果你希望传递一个自定义状态码，可以使用reply.code():

fastify.addHook('preHandler', (request, reply, next) => {

reply.code(500)

next(new Error('some error'))

})

onClose

onClose 是唯一不在生命周期中的钩子，当调用 fastify.close() 来停止服务器时，会触发此钩子，第一个参数是 Fastify 实例，第二个用来完成回调。

const fastify = require('fastify')()

fastify.get('/close', function(request, reply){

  reply.type('text/html').send('<h1>Close Server</h1>')

  fastify.close()

})

fastify.onClose(function(instance, done){

  console.log('close db connection')

  done()

})

访问 /close 时页面会显示 Close Server，并且控制台会输出：

[Running] node "/Users/lavyun/Code/node/learn-fastify/app.js"

close db connection

[Done] exited with code=0 in 8.524 seconds

在关闭数据库链连接之后，app.js 也被 exit 了。

preHandler 和 beforeHandler

preHandler 的受众对象是所有的路由，而 beforeHandler 的受众对象是某个特定的路由，另外，beforeHandler 总是在 preHandler 之后执行。

fastify.addHook('preHandler', (request, reply, done) => {

  console.log('preHandler')

  done()

})

fastify.get('/', {

  beforeHandler: function (request, reply, done) {

    console.log('beforeHandler')

    done()

  }

}, function (request, reply) {

  reply.send({ hello: 'world' })

})

// preHandler

// beforeHandler

beforeHandler 也可以是一个函数数组：

fastify.addHook('preHandler', (request, reply, done) => {

  console.log('preHandler')

  done()

})

const firstBeforeHandler = (request, reply, done) => {

  console.log('first beforeHandler')

  done()

}

const secondBeforeHandler = (request, reply, done) => {

  console.log('second beforeHandler')

  done()

}

fastify.get('/', {

  beforeHandler: [firstBeforeHandler, secondBeforeHandler]

}, function (request, reply) {

  reply.send({ hello: 'world' })

})

// preHandler

// first beforeHandler

// second beforeHandler

装饰器

如果想为 Fastify 实例添加功能，可以使用 decorate 方法。

decorate 允许向 Fastify 实例添加新属性。可以是一个值、一个函数，也可以是一个对象或一个字符串等。

使用方法

decorate

只需要调用 decorate 函数，并且传入新属性的键和值即可。

fastify.decorate('utility', () => {

// something very useful

})

也可以定义其他类型的实例：

fastify.decorate('conf', {

  db: 'some.db',

  port: 3000

})

一旦定义了这个实例，可以通过传入的参数名称来得到该值：

fastify.utility()

console.log(fastify.conf.db)

装饰器不可以重新被覆盖，如果要定义一个已经存在的装饰器，decorate 将会抛出异常。

fastify.decorate("d1", 'd1')

fastify.decorate("d1", "d2") // Error

decorateReply

decorateReply 可以为 Reply 对象添加新属性。

fastify.decorateReply('utility', function () {

// something very useful

})

decorateRequest

decorateRequest 可以为 Request 对象添加新属性。

fastify.decorateRequest('utility', function () {

// something very useful

})

extendServerError

如果要扩展服务器错误，可以使用此 API，必须传入一个返回值为对象的函数，该函数将接收原始的 Error 对象，并返回新Error 对象来扩展服务器错误。

fastify.extendServerError((err) => {

  return {

    timestamp: new Date()

  }

})

/*

最终的错误对象格式:

{

  error: String

  message: String

  statusCode: Number

  timestamp: Date

}

*/

依赖

如果一个装饰器依赖于另一个装饰器，可以将其他装饰器声明为依赖。只需要添加一个字符串数组（表示所依赖的装饰器的名称）作为第三个参数即可：

fastify.decorate('utility', fn, ['greet', 'log'])

如果不满足依赖关系，那么 decorate 会抛出一个异常，但是不用担心：依赖关系检查会在服务器启动之前执行，所以在运行时不会发生错误。

hasDecorator

可以使用 hasDecorator 检查装饰器是否存在：

fastify.hasDecorator('utility')

Fastify 的更多使用将在接下来的博客中说明。

Tips：

访问 https://lavyun.gitbooks.io/fastify/content/ 查看我翻译的 Fastify 中文文档。

访问 lavyun.cn 查看我的个人动态。