在 Koa v2 中，仅在服务器启动时一次性执行中间件

Question

我创建了这个中间件，它只在网站中的任何路线受到访问者的第一次点击时执行一次：

// pg-promise
const db = require('./db/pgp').db;
const pgp = require('./db/pgp').pgp;

app.use(async (ctx, next) => {
  try {
    ctx.db = db;
    ctx.pgp = pgp;
  } catch (err) {
    debugErr(`PGP ERROR: ${err.message}` || err);
  }
  await next();
});

// One-Time middleware
// https://github.com/expressjs/express/issues/2457
const oneTime = (fn) => {
  try {
    let done = false;
    const res = (ctx, next) => {
      if (done === false) {
        fn(ctx, next);
        done = true;
      }
      next();
    };
    return res;
  } catch (err) {
    debugErr(`oneTime ERROR: ${err.message}` || err);
  }
};

const oneTimeQuery = async (ctx) => {
  const result = await ctx.db.proc('version', [], a => a.version);
  debugLog(result);
};

app.use(oneTime(oneTimeQuery));

此代码仅在用户首次访问网站时执行，结果：

app:log Listening on port 3000 +13ms
app:req GET / 200 - 24ms +2s
23:07:15 connect(postgres@postgres)
23:07:15 SELECT * FROM version()
23:07:15 disconnect(postgres@postgres)
app:log PostgreSQL 9.6.2, compiled by Visual C++ build 1800, 64-bit +125ms

我的问题是我想在服务器启动时执行它，当网站上没有任何访问时。

此代码的未来用途将是检查数据库中是否存在表。

解决方案：

在const server = http.createServer(app.callback()); 声明之前将其放在./bin/www 中会有所帮助：

const query = async () => {
  const db = require('../db/pgp').db;
  const pgp = require('../db/pgp').pgp;
  const result = await db.proc('version', [], a => a.version);
  debugLog(`www: ${result}`);
  pgp.end(); // for immediate app exit, closing the connection pool (synchronous)
};
query();

Answer 1

您可以使用 js 脚本启动您的应用程序，该脚本需要您的应用程序并使用节点的本机 http 模块来启动服务器。就像在 koa-generator (click) 中一样。

这在您的 app.js 文件中：

const app = require('koa')();
...
module.exports = app;

然后在你的脚本中启动服务器：

const app = require('./app');
const http = require('http');

[this is the place where you should run your code before server starts]

const server = http.createServer(app.callback());
server.listen(port);

然后你开始你的应用程序：

node [script_name].js

这样做时当然要记住节点的异步性质。我的意思是 - 在回调/承诺中的“服务器”变量上运行“监听”方法。