Node Express 中的并行异步路由器

Question

我有一个快速服务器，它需要为每个请求从多个外部来源获取一些数据。这个逻辑被分成多个路由器（有些不是我管理的）。

这些路由器是完全独立的，因此不需要一个等待另一个。

---

例如，我有以下代码：

const router1 = express.Router();
const router2 = express.Router();
const router3 = express.Router();
const finalRouter = express.Router();

router1.use((req, res, next) => setTimeout(next, 2000));
router2.use((req, res, next) => setTimeout(next, 2000));
router3.use((req, res, next) => setTimeout(next, 2000));

finalRouter.use((req, res, next) => console.log('All done!'));

当我通常在我的应用程序中使用所有这些路由器时，它将按顺序执行并在 6 秒内打印All done!。

但是为了提高页面的速度，我想并行执行它们，所以它们都在 2 秒内完成。我该怎么做？

Answer 1

这里绝对不需要单独的路由，您可以只使用一条路由并使用Promise.all 等待所有请求。如果它们不自然地支持 Promises，您可以将它们包装在一个中，例如

router.use(async (req, res, next) => {
    await Promise.all([
       new Promise((resolve, reject) => {
           setTimeout(() => resolve(), 2000);
       }),
       ...
    ]);
    next();
});
router.use((req, res, next) => {
    console.log('All done!');
});

---

根据 cmets 中的讨论，如果您无法将路线合并为一条路线 - 没关系，而且并不重要。考虑更多这一点，您真正需要的是一个包装器来捕获“真正的”中间件，将其添加到队列中，然后移至下一个。为此，您至少需要访问设置路线的代码（它似乎有），例如

queue.js

module.exports = route => {
    return (req, res, next) => {
        // ensure we've got a queue
        if (!(req.queue instanceof Array)) {
            req.queue = [];
        }
        // queue the blocking route
        req.queue.push(new Promise((resolve, reject) => {
            // run real route, signal success or failure when done
            route(req, res, err => err ? reject(err) : resolve()); 
        });
        next(); // move on, don't wait
    };
}

然后在你的路线中

const queue = require('./queue');
...
router.use(queue((req, res, next) => setTimeout(() => next(), 2000))));
router.use(queue((req, res, next) => setTimeout(() => next(), 2000))));
router.use(queue((req, res, next) => setTimeout(() => next(), 2000))));
router.use(async (req, res, next) => {
    await Promise.all(req.queue);
    console.log('All done!');
}

Answer 2

您可以向所有子路由器发出虚假请求（通过this 答案发现的内部 handle 方法）：

const mainroute = Express.Router();

mainroute.get("/",function(req,res,next){     
 Promise.all([
  new Promise(resolve => 
    router1.handle(req,res, resolve)),
  new Promise(resolve => 
    router2.handle(req,res,resolve))
  ]).then(_=>res.end("all done"));
});

---

这也可以通过在请求中传递一个 promise 数组来手动实现，然后你可以在最后等待它们：

const router1 = express.Router();
const router2 = express.Router();

const timer = ms => new Promise( res => setTimeout(res,ms));

router1.use((req, res, next) =>{
  req.promises = [timer(2000)];
});      
router1.use( req => req.promises[0] = req.promises[0].then(_=>"first done"));

router2.use((req, res, next)=>req.promises.push(timer(2000)));

router1.use("/test",router2);
router1.use((req,res)=> Promise.all(req.promises).then(_=>res.end("all done")));