jwt获取token_Koa开发之koa-jwt工作过程

最近的工作是开发一个分布式的服务系统，选用的环境是node开发环境，由于需要全面的进行异步开发所以使用Koa框架，开发Web服务需要对用户进行身份认证，所以就使用koa-jwt，为什么使用token这种方式网上有很多介绍token和session的区别我这里就不再赘述了。在给大家演示代码之前我在这一章主要是介绍koa-jwt的工作流程在后面的一章中我将使用程序对大家进行演示。

首先我在这附上koa-jwt的源代码，然后为大家剖析其的工作流程。

源程序

koa-jwt的源程序的主程序在lib/index.js中

'use strict';const pAny = require('p-any');const unless = require('koa-unless');const verify = require('./verify');const getSecret = require('./get-secret');const resolveAuthHeader = require('./resolvers/auth-header');const resolveCookies = require('./resolvers/cookie');module.exports = (opts = {}) => {    const { debug, getToken, isRevoked, key = 'user', passthrough, tokenKey } = opts;    const tokenResolvers = [resolveCookies, resolveAuthHeader];    if (getToken && typeof getToken === 'function') {        tokenResolvers.unshift(getToken);    }    const middleware = async function jwt(ctx, next) {        let token;        tokenResolvers.find(resolver => token = resolver(ctx, opts));        if (!token && !passthrough) {            ctx.throw(401, debug ? 'Token not found' : 'Authentication Error');        }        let { state: { secret = opts.secret } } = ctx;        try {            if (typeof secret === 'function') {                secret = await getSecret(secret, token);            }                        if (!secret) {                throw new Error('Secret not provided');            }            let secrets = Array.isArray(secret) ? secret : [secret];            const decodedTokens = secrets.map(async s => await verify(token, s, opts));            const decodedToken = await pAny(decodedTokens)                .catch(function (err) {                    if (err instanceof pAny.AggregateError) {                        for (const e of err) {                            throw e;                        }                    } else {                        throw err;                    }                });            if (isRevoked) {                const tokenRevoked = await isRevoked(ctx, decodedToken, token);                if (tokenRevoked) {                    throw new Error('Token revoked');                }            }            ctx.state[key] = decodedToken;            if (tokenKey) {                ctx.state[tokenKey] = token;            }        } catch (e) {            if (!passthrough) {                const msg = debug ? e.message : 'Authentication Error';                ctx.throw(401, msg, { originalError: e });            }else{                 ctx.state.jwtOriginalError = e;            }        }        return next();    };    middleware.unless = unless;    return middleware;};