如何在中间件中等待 next()

问题描述 投票:0回答:2

使用express,我有一个像这样的中间件:

app.use((req, res, next) => {
  console.log(req);
  next();
});

如何等待 next() 完成? 我问的原因是我在 next() 之后添加了 console.log,此消息发生在下一个路由函数中的消息之前。

app.use(async(req, res, next) => {
  console.log(req);
  await next();
  console.log('should be the last print but ...');
});
node.js express
2个回答
5
投票

我在项目中遇到了这个问题,我们快速解决了将中间件一分为二的问题。您可以在路由之前添加第一部分,并在之后添加的另一个部分中的“next()”之后添加要执行的内容。如果您需要访问相同的对象实例或其他内容,您可以随时将其保存在请求局部变量中。

我的例子:


const express = require('express');
const app = express();
const port = 5050;
const wait = (milliseconds) =>
    new Promise((res, rej) => {
        setTimeout(() => {
            res();
        }, milliseconds);
    });

const middleware = async (req, res, next) => {
    console.log('- 1');
    await wait(10);
    console.log('- 2');
    next();
    console.log('- 3');
    await wait(10);
    console.log('- 4');
    console.log('');
};
app.use(middleware);
app.get('/', async (req, res, next) => {
    console.log('-- 1');
    await wait(10);
    console.log('-- 2');
    console.log('hello');
    res.send('Hello World!');
    console.log('-- 3');
    await wait(10);
    console.log('-- 4');
    next();
    return;
});

app.listen(port, () => {
    console.log(`Example app listening at http://localhost:${port}`);
});

这就会有你遇到的问题。它会在这些行中打印一些东西。

- 1
- 2
-- 1
- 3
-- 2
hello
-- 3
- 4

-- 4

解决方案:

const express = require('express');
const app = express();
const port = 5050;
const wait = (milliseconds) =>
    new Promise((res, rej) => {
        setTimeout(() => {
            res();
        }, milliseconds);
    });

const middleware1 = async (req, res, next) => {
    console.log('- 1');
    await wait(10);
    console.log('- 2');
    next();
};

const middleware2 = async (req, res, next) => {
    console.log('- 3');
    await wait(10);
    console.log('- 4');
    console.log('');
    next();
};

app.use(middleware1);
app.get('/', async (req, res, next) => {
    console.log('-- 1');
    await wait(10);
    console.log('-- 2');
    console.log('hello');
    res.send('Hello World!');
    console.log('-- 3');
    await wait(10);
    console.log('-- 4');
    next();
    return;
});
app.use(middleware2);

app.listen(port, () => {
    console.log(`Example app listening at http://localhost:${port}`);
});

您将中间件一分为二,以确保中间件2仅在路由中的所有内容执行后才执行。您将得到如下输出:

- 1
- 2
-- 1
-- 2
hello
-- 3
-- 4
- 3
- 4

0
投票

事实上,你可以创建一个中间件来替换你的 res.send : 有点脏

app.use( async (req,res,next) => {

        const old = res.send;
        res.send = ( body: any ) => {
            console.log( `${req.method} ${req.originalUrl.toString()} ${res.statusCode}` );
            return old.call( res, body );
        }

        next( );
    });
© www.soinside.com 2019 - 2024. All rights reserved.