0

在我的应用程序中，我需要每晚同步一些资源。/api/sync/通过向正文中的 JSON 对象数组发送 PUT 请求来启动同步。我的任务是在我的应用程序中以 JSON 格式镜像数据，因此首先我必须解决需要添加、更新和删除的内容，然后向数据库发出适当的查询。这可能需要一段时间，所以我不希望有任何其他要求妨碍我。

所以我需要关闭 Express 的连接，进行同步并重新开始收听。但是有2个问题：

  1. http.Server.close()阻止接收新连接但等待已经执行完成
  2. 有可能PUT /api/sync/在前一个请求可以调用之前收到另一个请求close()。PUT /api/sync/因此，将接受2 个传入请求进行处理。

目前我以这种方式创建 Express 应用程序：

// index.js
const app = express();
app.server = new Server(app);
app.server.start();

// Server.ts
export class Server {
  public readonly server: http.Server;
  private readonly close: () => Promise<http.Server>;
  private readonly listen: (port: number) => Promise<http.Server>;

  constructor(public readonly app: express.Application) {
    this.server = http.createServer(app);
    this.close = promisify<http.Server>(this.server.close.bind(this.server));
    this.listen = promisify<http.Server>(this.server.listen.bind(this.server));
  }

  async start() {
    console.log('START');
    await this.listen(Number(process.env.PORT));
  }

  async stop() {
    console.log('STOP');
    if (!this.server.listening) {
      throw new Error('Server is not listening');
    }

    await this.close();
  }
}

// middleware
module.exports = fn => (req, res, next) => {
  console.log('START MAINTENANCE');
  req.app.server.stop()
    .then(() => {
      const endMaintenance = (err) => {
        console.log('END MAINTENANCE'); 
        req.app.server.start().then(() => next(err));
      };

      Promise.resolve(fn(req, res)).then(() => endMaintenance())
        .catch(err => endMaintenance(err));
    });
};

// route definition
routes.put(
  '/',
  exclusiveRun(
    async (req: Request, res: Response) => {
      await dataSync.synchronize(req.body);
      res.sendStatus(204);
    }
  )
);

但是，当我/api/sync连续向端点发送 2 个请求时，Express 接受它们，然后其中一个会引发“服务器未在侦听”错误。我在哪里出错？这种方法是否足以防止中断同步过程（或在同步进行时造成麻烦）？

4

1 回答 1

1

除了关闭服务器之外，您还可以将请求处理程序作为您的第一个中间件，该处理程序检测您的服务器是否正在维护（您有一些标志），如果是这样，它会立即失败，并显示所有传入请求的 5xx 状态代码。

然后，当您的/api/sync请求进入时，您设置该标志（阻止更多请求）并在所有当前处理的请求完成后开始同步。或者，您可以将此逻辑与实际关闭服务器相结合，以便在服务器实际关闭之前进入的任何其他请求都获得 5xx 响应。

于 2019-08-03T21:46:49.700 回答