在express服务器内部运行时，如何优雅地关闭bullmq

Question

• 我有一个express应用程序，它使用bullmq队列、调度器和工作者。即使在按下Ctrl+C之后，我仍然可以看到节点进程在我的活动管理器中运行，但我在终端上的服务器关闭了。我之所以知道这一点，是因为bullmq任务开始输出console.log语句，即使在服务器关闭到终端之后也是如此

这就是我的server.js文件看起来像的样子

// eslint-disable-next-line import/first
import http from 'http';
import { app } from './app';
import { sessionParser } from './session';
import { websocketServer } from './ws';
import 'jobs/repeatable';
const server = http.createServer(app);
server.on('upgrade', (request, socket, head) => {
sessionParser(request, {}, () => {
websocketServer.handleUpgrade(request, socket, head, (ws) => {
websocketServer.emit('connection', ws, request);
});
});
});
server.on('listening', () => {
websocketServer.emit('listening');
});
server.on('close', () => {
websocketServer.emit('close');
});
// https://stackoverflow.com/questions/18692536/node-js-server-close-event-doesnt-appear-to-fire
process.on('SIGINT', () => {
server.close();
});
export { server };

请注意，我在上面定义了一个SIGINT处理程序。这就是我不离职的原因吗？我必须手动关闭SIGINT中的每个队列、工作进程和调度程序吗？我的jobs/repeatable.js文件如下所示

const { scheduleJobs } = require('jobs');
if (process.env.ENABLE_JOB_QUEUE === 'true') {
scheduleJobs();
}

这是我的jobs.js文件

import { scheduleDeleteExpiredTokensJob } from './delete-expired-tokens';
import { scheduleDeleteNullVotesJob } from './delete-null-votes';
export async function scheduleJobs() {
await scheduleDeleteExpiredTokensJob();
await scheduleDeleteNullVotesJob();
}

这是我的delete-expired-tokens.js文件，另一个与非常相似

import { processor as deleteExpiredTokensProcessor } from './processor';
import { queue as deleteExpiredTokensQueue } from './queue';
import { scheduler as deleteExpiredTokensScheduler } from './scheduler';
import { worker as deleteExpiredTokensWorker } from './worker';
export async function scheduleDeleteExpiredTokensJob() {
const jobId = process.env.QUEUE_DELETE_EXPIRED_TOKENS_JOB_ID;
const jobName = process.env.QUEUE_DELETE_EXPIRED_TOKENS_JOB_NAME;
await deleteExpiredTokensQueue.add(jobName, null, {
repeat: {
cron: process.env.QUEUE_DELETE_EXPIRED_TOKENS_FREQUENCY,
jobId,
},
});
}
export {
deleteExpiredTokensProcessor,
deleteExpiredTokensQueue,
deleteExpiredTokensScheduler,
deleteExpiredTokensWorker,
};

如何优雅地关闭bullmq任务队列？

Answer 1

您必须在workers上调用close()方法：

server.on('close', async () => {
websocketServer.emit('close');
// Close the workers
await worker.close()
});

文档