koa2的中间件功能及应用示例

作者: A坏坏不坏A
来源: 51数据库
2021-08-29

最近因为开发一个自己的博客网站，学习了koa2的搭建，写了一些自己认为比较重要或需要知道的koa2中间件作用和使用场景。

koa-router

路由中间件

下载

npm i koa-router

使用

普通使用方法

需要注意的是引入的koa-router是一个方法，引入后需要执行这个方法。

const koa = require('koa'); 
const app = new koa(); 
const router = require('koa-router')(); 

// 配置路由url 
// 默认url 
router.get('/', async (ctx, next) => { 
 ctx.body = 'hello world'; 
}); 

// 自定义url 
router.get('/hello/:name', async (ctx, next) => { 
 var name = ctx.params.name; 
 ctx.response.body = \`<h1>hello, ${name}!</h1>\`; 
}); 

// 注册路由 
app.use(router.routes(), router.allowedmethods());

也可以按需引入并注册路由，可注册多个路由。

不同请求下接收的参数获取

router.get

通过ctx.query获取参数

router.post
通过ctx.request.body获取参数

动态路由 router.get('/:id', func)
通过ctx.params获取参数

遍历注册router

首先引入nodejs中的fs模块，使用fs的readdirsync方法获取到指定目录的所有文件名，遍历引入路由模块并注册。

const fs = require('fs');

// fs.readdirsync 获取指定目录下的所有文件名称，遍历引入路由模块并注册 
fs.readdirsync('./routes').foreach(route=> { 
 let api = require(\`./routes/${route}\`); 
 app.use(api.routes(), api.allowedmethods()); 
});

koa-router中的其它api

router.prefix(prefix) 添加url前缀

设置已经初始化的路由器实例的路径前缀

router.prefix('/user'); 
router.post('/login', function(ctx, next) { 
 ... 
}); 

// 实际路径 /user/login

router.use(url|[url1,url2,...], (ctx, next) => {...}) 路由中间件

使用场景：我们通常需要通过验证用户和用户权限来判定用户是否能使用该接口，如果在每个接口都写一次验证非常麻烦且不好维护。这时我们就需要路由中间件先进行验证，再执行下面操作。

router.use的第一个参数为一个路径或者由多个需要使用中间件的路径组成的数组（需要注意的是，如果路由设置了url前缀，需要在设置前缀后注册中间件，参数中的url不需要设置前缀）。

router.use的第二个参数为函数，函数传递ctx和next两个参数，可通过ctx进行权限验证后，判断是否执行next调用接口。这里特别需要注意的是函数使用next的时候需要添加await，如果不添加，在调用接口前，接口就会返回结果，前台则无法获取到数据。

 // this is wrong 
 app.use(function (ctx, next) { 
  ctx.set("access-control-allow-origin", "\*"); 
  next(); 
 }); 
 // this is right 
 app.use(async function (ctx, next) { 
  ctx.set("access-control-allow-origin", "\*"); 
  await next(); 
 });

koa-bodyparser处理post请求

处理post请求时，我们会遇到一个问题，无论是node的request对象还是koa的request对象，都没办法解析request的body，我们就需要下载并引入一个解析body的中间件koa-bodyparser，koa-bodyparser的具体配置详见下面的说明，这里我们直接放入使用方式。

 // 引入路由文件 
 const index = require('./routes/index.js'); 
 const user = require('./routes/user.js'); 

 // 引入解析request.body的中间件 
 const bodyparser = require('koa-bodyparser'); 

 // 注册bodyparser，需要注意，bodyparser的注册一定要在router路由注册之前 
 app.use(bodyparser({ 
  enabletypes:\['json', 'form', 'text'\] 
 })); 

 ... 

 // 注册routes 
 app.use(index.routes(), index.allowedmethods()); 
 app.use(user.routes(), user.allowedmethods());

koa-bodyparser

如上所述，koa-bodyparser用于解析request.body，因为node和koa的request无法解析body。

下载

 npm i koa-bodyparser

使用

const bodyparser = require('koa-bodyparser');

在注册运行时，bodyparser方法中可传入对象，作相应配置。

- enabletypes：解析器只在配置了enabletypes时解析请求类型，默认是['json'， 'form']。
- encoding：请求编码，默认是utf-8。
- formlimit：urlencoded body的imit如果主体最终大于此限制，则返回一个413错误代码。默认是56 kb。
- jsonlimit：json主体的限制。默认是1 mb。
- textlimit：文本主体的限制。默认是1 mb。
- strict：当设置为true时，json解析器将只接受数组和对象。默认是正确的。参见正文中的严格模式。在严格模式下，ctx.request。body总是一个对象(或数组)，这避免了很多类型判断。但文本正文总是返回字符串类型。
- detectjson：自定义json请求检测函数。默认为null。

app.use(bodyparser({ 
 detectjson: function (ctx) { 
 return /\\.json$/i.test(ctx.path); 
 } 
}));

- extendtypes：支持扩展类型

  app.use(bodyparser({ 
   extendtypes: { 
   json: \['application/x-javascript'\] // 解析application/x-javascript 类型 作为json字符串 
   } 
  }));

- onerror：支持自定义错误句柄，如果koa-bodyparser抛出一个错误，您可以自定义响应如下:

  app.use(bodyparser({ 
   onerror: function (err, ctx) { 
   ctx.throw('body parse error', 422); 
   } 
  }));

- disablebodyparser：可以通过设置ctx动态禁用body解析器。disablebodyparser = true。

  app.use(async (ctx, next) => { 
   if (ctx.path === '/disable')     ctx.disablebodyparser = true; 
   await next(); 
  }); 
  app.use(bodyparser());

koa-logger

请求响应监听日志

下载

npm i koa-logger

使用

~~// 引入日志中间件 
const logger = require('koa-logger'); 

// 注册日志中间件 
app.use(logger()); ~~

koa-session

用于koa的简单会话中间件。默认为基于cookie的会话，并支持外部存储。

session

我们知道，http协议是无状态的，当用户进行登录后，并不会保存账户密码，如果我们需要维持用户的登录状态，就需要使用一些方法。目前主流的用户认证方法有基于token和基于session两种方式。

基于token的认证可以使用koa-jwt中间件，基于session的认证则使用标题的koa-session。

下载

npm i koa-session

使用

app.js 入口文件中注册session

const config = { 
 key: 'koa:sess', /\*\* (string) cookie key (default is koa:sess) \*/ 
 /\*\* (number || 'session') maxage in ms (default is 1 days) \*/ 
  // 状态保存最大时间，默认为一天 
 maxage: 86400000, 
 autocommit: true, /\*\* (boolean) 自动保存头部 (default true) \*/ 
 overwrite: true, /\*\* (boolean) 能否覆盖 (default true) \*/ 
 httponly: true, /\*\* (boolean) httponly or not (default true) \*/ 
 signed: true, /\*\* (boolean) signed or not (default true) \*/ 
 /\*\* (boolean) 强制在每个响应上设置会话标识符cookie。过期将重置为原始maxage，重新设置过期倒计时。 (default is false) \*/ 
 rolling: false, 
 /\*\* (boolean) 当会话快过期时续订会话，这样我们可以始终保持用户登录。(default is false)\*/ 
 renew: false, 
}; 

// 如果你所有都为默认配置，则不需要传递配置参数，app.use(session(app))即可 
app.use(session(sessionconfig, app));

session的使用

注册后可以通过上下文ctx找到session属性，下面代码将用户信息存入session属性中，并创建key和value

user.js

// 用户登录 
static async login(ctx, next) {

const data = ctx.request.body 
const schema = joi.object().keys({ 
 username: joi.string().required(), 
 password: joi.string().required(), 
}) 
let result = joi.validate(data, schema) 
// 如果有字段类型错误 
if(result.error) { 
 return ctx.response.body = { status: 400, msg: result.error.details}; 
} 
let { username, password } = result.value // 验证过后的数据 
// 查找是否有该用户 
const userinfo = await usersmodel.findbyname(username) 
// 如果有该用户，继续验证密码是否正确 
if (userinfo) { 
 const userinfo2 = await usersmodel.findone({ username, password }) 
 if (userinfo2) { 
  ctx.response.body = {state: 200, msg: '登录成功'} 
  // 设置session 
  ctx.session.userinfo = userinfo2 
 } else { 
  ctx.response.body = {state: 410, msg: '密码错误'} 
 } 
// 如果没有该用户，返回结果 
} else { 
 ctx.response.body = {state: 410, msg: '该用户不存在'} 
} 
return ctx.response.body 
}

koa-router路由中间件中验证session，这里需要注意的是next()方法前一定要使用await，不然程序不会等待next()方法执行。

export const verifyuser = async (ctx, next) => {

if (ctx.session.userinfo) { 
 await next() 
} else { 
 return ctx.response.body = { state: 401, msg: '无权限访问' } 
} 
}

koa2-cors

用于解决跨域问题

下载

npm install koa2-cors

使用

app.use(cors())

到此这篇关于koa2的中间件功能及应用示例的文章就介绍到这了,更多相关koa2 中间件内容请搜索以前的文章或继续浏览下面的相关文章希望大家以后多多支持！