Cet article présente principalement l'utilisation de async&await pour comprendre Koa2. Maintenant, je le partage avec vous et vous donne une référence.
Koa est un framework côté serveur Node très connu, avec les versions 1.x et 2.x. Le premier utilise un générateur pour effectuer des opérations asynchrones, et le second utilise la dernière solution async/await
Lorsque j'ai commencé à utiliser cette méthode d'écriture, j'ai rencontré un problème le code est le suivant :
<.>const Koa = require('koa'); const app = new Koa(); const doSomething = time => { return new Promise(resolve => { setTimeout(() => { resolve('task done!') }, time) }) } // 用来打印请求信息 app.use((ctx, next) => { console.log(`${ctx.method}:::${ctx.url}`) next() }) app.use(async ctx => { const result = await doSomething(3000) console.log(result); ctx.body = result }) app.listen(3000);
Introuvable
function compose (middleware) { return function (context, next) { // 这个index用来计数,防止next被多次调用 let index = -1 // 执行入口 return dispatch(0) function dispatch (i) { // 如果next被多次调用,报异常 if (i <= index) return Promise.reject(new Error('next() called multiple times')) index = i // 取出第一个middleware let fn = middleware[i] // 将最初传入的next作为最后一个函数执行 if (i === middleware.length) fn = next if (!fn) return Promise.resolve() try { /** 这里就是关键了,Promise.resolve是什么意思呢? Promise.resolve方法有下面三种形式: Promise.resolve(value); Promise.resolve(promise); Promise.resolve(theanable); 这三种形式都会产生一个新的Promise。其中: 第一种形式提供了自定义Promise的值的能力,它与Promise.reject(reason)对应。两者的不同,在于得到的Promise的状态不同。 第二种形式,提供了创建一个Promise的副本的能力。 第三种形式,是将一个类似Promise的对象转换成一个真正的Promise对象。它的一个重要作用是将一个其他实现的Promise对象封装成一个当前实现的Promise对象。例如你正在用bluebird,但是现在有一个Q的Promise,那么你可以通过此方法把Q的Promise变成一个bluebird的Promise。第二种形式可以归在第三种里面 **/ return Promise.resolve(fn(context, function next () { // 执行下一个middleware,返回结果也是一个Promise return dispatch(i + 1) })) } catch (err) { return Promise.reject(err) } } } }
app.use(async (ctx, next) => { console.log(`${ctx.method}:::${ctx.url}`) await next() }) app.use(async ctx => { const result = await doSomething(3000) console.log(result); ctx.body = result })
Gestion des erreurs
Grâce à la puissante puissance de Promise et à la syntaxe async/await, il nous suffit d'écrire l'opération try/catch dans le middleware le plus externe, et nous pouvons intercepter toutes les exceptions de middleware suivantes !app.use(async (ctx, next) => { try{ await next() }catch(err){ console.log(err) } }) app.use(async (ctx)=>{ throw new Error('something wrong!') ctx.body = 'Hello' })
Comment implémenter une barre de progression dynamique dans D3.js
Implémentation de la boîte modale dans vue (méthode d'écriture générale)
Comment créer un environnement webApp dans Vue.js 2.0 et le développement Cordova
Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!