- 中间件是一种方法,可以接收客户端发来的请求,可以对请求做出响应,也可以将请求继续交给下一个中间件继续处理。
- 中间件主要由两部分组成,中间件方法及请求处理函数。
- 中间件方法由Express提供,负责拦截请求、请求处理函数由开发人员提供,负责处理请求。
- 可以针对同一个请求设置多个中间见,对同一个请求进行多次处理。
- 默认情况下,请求从上到下依次匹配中间件,一旦匹配成功,终止匹配。
- 可以调用next方法将请求的控制权交给下一个中间件,知道遇到结束请求的中间件
-
app.get('request', (req, res, next ) => { req.name = 'zhangsan' next() }) app.get('request', (req, res, next ) => { res.send(req.name) })
- 中间件的用法
- app.use 匹配所有的请求方式,可以直接传入请求处理函数,代表接收所有的请求。
-
app.use((req, res, next ) => { console.log('ok') next() })
-
- app.use 第一个参数也可以传入请求地址,代表不论什么请求方式,只要是这个地址就接收这个请求。
-
app.use('/admin', (req, res, next) => { console.log('ok') next() })
-
- 中间件的应用
- 路由保护,客户端访问需要登陆点的页面时,可以先使用中间件判断用户登陆状态,用户如果未登陆,则拦截请求,直接响应,禁止用户进入需要登陆的页面。
-
const express = require('express') const app = express() app.use('./admin', (req, res, next) => { let isLogin = false if (isLogin) { next() // 如果用户登陆,让请求继续向下执行 } else { res.send('你还没有登陆,不能访问/admin 这个页面') } }) app.get('/admin', (req, res) => { res.send('你已经登陆,可以访问当前页面') })
-
- 网站维护公告, 在所有路由最上面定义接收所有请求的中间件,直接为客户端做出响应,网站正在维护。
-
const express = require('express') const app = express() app.use((req, res, next ) => { res.send('当前网站正在维护') })
-
- 自定义404页面。
-
const express = require('express')const app = express()
app.get('login', (req, res) => {res.send('/login')})
app.use((req, res) => {res.status(404).send('当前访问页面不存在')})
-
- 路由保护,客户端访问需要登陆点的页面时,可以先使用中间件判断用户登陆状态,用户如果未登陆,则拦截请求,直接响应,禁止用户进入需要登陆的页面。
4. 错误处理中间件。在程序执行的过程中,不可避免的会出现一些无法预料的错误,比如文件读取失败 ,数据连接失败。错误处理中间件一个集中处理错误请求的地方。
const express = require('express') const app = express() // 创建一个错误实例 app.get('index', (req, res) => { throw new Error('程序发生了未知错误') // 创建错误对象 }) // 错误处理中间件 app.use((err, req, res, next) => { res.status(500).send('服务器发生位置错误') // 链式编程,此处也可以单独写。 }) app.listen(3000)
5.捕获错误。在node.js中,异步API的错误信息都是通过回调函数获取的,支持Promise 对象的异步API发生错误可以通过catch 方法捕获。try catch 可以捕获异步函数以及其他同步代码在执行过程中发生的错误,但是不能捕获其他类型的API发生的 错误。
const express = require('express') const fs = require('fs') const app = express() const promisify = require('util').promisify const readFile = proisify(fs.readFile) // 创建一个错误实例 app.get('index', async (req, res, next) => { try { await readFile('./aaa.js') } catch (error) { next(error) } }) // 错误处理中间件 app.use((err, req, res, next) => { res.status(500).send('服务器发生位置错误') // 链式编程,此处也可以单独写。 }) app.listen(3000)