Koa は自身を HTTP ミドルウェア フレームワークとして位置付けており、HTTP サーバーの作成に関連する共通のメソッドとプロパティを提供することに重点を置いています。ミドルウェア自体はバンドルされておらず、実際のベースに基づいてオープン ソース コミュニティによって開発されています。特定のミドルウェアを開発する必要があります。
Koa は、app.use() メソッドを使用してミドルウェアを登録し、注入順にミドルウェア配列に追加します。これらのミドルウェアは、キャッシュの生成、プロキシの指定、リダイレクトなどの HTTP リクエストの処理によく使用されます。待って。
const Koa = require('koa');const app = new Koa();// responseapp.use(ctx => { ctx.body = 'Hello Koa';});app.listen(3000)
Koa2 は、次の 3 つのミドルウェア機能をサポートします。
// common function app.use((ctx, next) => { const start = new Date(); return next().then(() => { const ms = new Date() - start; console.log(`${ctx.method} ${ctx.url} - ${ms}ms`); });});// async functionapp.use(async (ctx, next) => { const start = new Date(); await next(); const ms = new Date() - start; console.log(`${ctx.method} ${ctx.url} - ${ms}ms`);});// generator function.use(co.wrap(function *(ctx, next) { const start = new Date(); yield next(); const ms = new Date() - start; console.log(`${ctx.method} ${ctx.url} - ${ms}ms`);}));
Node.js はまだ非同期関数をサポートしていないため、Babel を使用して JS ファイルをプリコンパイルする必要があります。私のアプローチは、依存関係 babel-core babel-polyfill babel-preset-es2015 babel-preset- をインストールすることです。 stage-0 を作成し、実際のエントリ ファイル (index.js など) の前に Babel をロードするように疑似エントリ ファイル (index.babel.js など) を設定します。将来、Node.js が Async をサポートするようになったら、このファイルを削除します。 :
require("babel-core/register")({ "presets": [ "es2015", "stage-0" ]});require("babel-polyfill");require('./index.js');
ミドルウェアは 2 つのパラメーター (ctx、next) を固定的に受け取ります。他のパラメーターを渡したい場合は、ミドルウェアを再パッケージ化できます。 🎜>
function logger(format) { format = format || ':method ":url"'; return async function (ctx, next) { const str = format .replace(':method', ctx.method) .replace(':url', ctx.url); console.log(str); await next(); };}app.use(logger());app.use(logger(':method :url'));
const compose = require('koa-compose');async function random(ctx, next) { // ...};async function backwards(ctx, next) { // ...};async function pi(ctx, next) { // ...};const all = compose([random, backwards, pi]);app.use(all);
app.use(async (ctx, next) => { try { await next(); } catch (err) { err.status = err.statusCode || err.status || 500; throw err; }});
app.on('error', (err, ctx) { // ...});
app.context.db = db();
app.use(async (ctx, next) => { // Context ctx; // Request ctx.request; // Response ctx.response; });
ctx.throw('name required', 400);// 等同于const err = new Error('name required');err.status = 400;throw err;
request.path
// With Content-Type: text/html; charset=utf-8ctx.is('html'); // => 'html'ctx.is('text/html'); // => 'text/html'ctx.is('text/*', 'text/html'); // => 'text/html'// When Content-Type is application/jsonctx.is('json', 'urlencoded'); // => 'json'ctx.is('application/json'); // => 'application/json'ctx.is('html', 'application/*'); // => 'application/json'ctx.is('html'); // => false
该对象是对 Node 原生 Response 对象的再封装,包含以下只读属性
包含以下可读写属性:
tx.response.etag = crypto.createHash('md5').update(ctx.body).digest('hex');
包含以下方法: