在 express.js 启动之前运行异步函数

Posted 2023-02-22

【中文标题】在 express.js 启动之前运行异步函数

【英文标题】：Running an async function before express.js start

【发布时间】：2017-05-12 20:32:55

【问题描述】：

我想在启动应用程序之前运行异步操作（例如，等待 URL 调用完成）。我不知道该怎么做（因为它是一个上层应用程序 - 这里没有 async/await）。

www.js：

var app = require('./app');
var http = require('http');
const port = '3000';
app.set('port', port);
var server = http.createServer(app);
server.listen(port);

app.js：

var express = require('express');
var app = express();
var Promise = require('bluebird');

# HERE IS WHERE I WANT TO "AWAIT" AN ASYNCHRONOUS CALL. 
# I KNOW I CAN'T USE AWAIT BECAUSE I'M NOT WITHIN 
# AN "ASYNC" ANNOTATED FUNCTION. EXAMPLE:
const data = await Promise.promisify(fs.readFile('DATA'));

app.set('views', path.join(__dirname, 'views'));
app.set('view engine', 'jade');
app.use(express.static(path.join(__dirname, 'public')));
app.use('/', routes);
module.exports = app;

我想过用 Promise.promisify() 包装所有 app.js，这样我就可以使用 async await 了。但我不确定在www.js 中如何处理它，因为它没有被调用，就像在app() 中一样，而是传递给http.createServer

【问题讨论】：

你查过关于 Promise 的教程吗？这是一个好的开始：github.com/kriskowal/q

什么异步调用？此外，app.js 没有显示任何导出，但您正在使用它，就好像它有一样。

@T.J.Crowder 你是对的。我的错。编辑以添加导出并说明读取文件（我知道有一个同步版本。假设没有，或者我正在使用其他一些 Promised 调用）

【参考方案1】：

从你所说的来看，app.js 可能正在导出一些东西（也许是app？），但是直到异步调用（我认为你没有展示）之前，这些东西还没有准备好使用完成了。

假设这一切都是真的，那么app.js 导出的内容需要为使用它的事物提供一种等待它准备好的方法。一种方法是使用 Promise。

假设你等待的不是承诺化的，那么：

app.js:

var express = require('express');
var app = express();
exports.appPromise = new Promise(function(resolve, reject) 
    startTheAsyncOperation(function(err, result) 
        if (err) 
            reject(err);
            return;
        
        app.set('views', path.join(__dirname, 'views'));
        app.set('view engine', 'jade');
        app.use(express.static(path.join(__dirname, 'public')));
        app.use('/', routes);
        resolve(app);
    );
);

然后在www.js:

var appPromise = require('./app').appPromise;
var http = require('http');
const port = '3000';
appPromise.then(function(app) 
    app.set('port', port);
    var server = http.createServer(app);
    server.listen(port);
);

---

当然，如果您正在等待的异步事物为您提供了一个承诺，那么您不需要 new Promise in app.js；而是：

var express = require('express');
var app = express();
exports.appPromise = startTheAsyncOperation().then(function() 
    app.set('views', path.join(__dirname, 'views'));
    app.set('view engine', 'jade');
    app.use(express.static(path.join(__dirname, 'public')));
    app.use('/', routes);
    return app;
);

【参考方案2】：

看看异步包。根据您的需要，您应该使用 async 包提供的瀑布控制流。 You cann have a look as it is very well documented.

您可以使用瀑布函数包装您的代码，这部分代码将同步运行。