快捷導(dǎo)航

Node.js自動(dòng)清理過(guò)期Token的方法步驟

更新時(shí)間：2026年05月09日 08:34:52 作者：yingyima

你是否遇到過(guò) Token 過(guò)期導(dǎo)致用戶無(wú)法登錄的問(wèn)題？在高并發(fā)場(chǎng)景下,手動(dòng)清理顯然不是個(gè)好主意,自動(dòng)定時(shí)清理才是王道,本文通過(guò)實(shí)戰(zhàn)案例詳細(xì)講解如何在 Node.js 中實(shí)現(xiàn)定時(shí)清理過(guò)期 Token,適合收藏備查,需要的朋友可以參考下

1. 安裝依賴
2. 連接 MongoDB
3. 定義 Token 模型
4. 創(chuàng)建定時(shí)任務(wù)
5. 使用 Bull 管理任務(wù)隊(duì)列
6. 定時(shí)將任務(wù)加入隊(duì)列
7. 監(jiān)控任務(wù)執(zhí)行
8. 高可用配置
9. 部署和測(cè)試
10. 日志記錄
11. 安全性考慮
12. 優(yōu)化建議
13. 常見問(wèn)題
14. 其他工具推薦
15. 總結(jié)

引言

你是否遇到過(guò) Token 過(guò)期導(dǎo)致用戶無(wú)法登錄的問(wèn)題？在高并發(fā)場(chǎng)景下，手動(dòng)清理顯然不是個(gè)好主意，自動(dòng)定時(shí)清理才是王道。

業(yè)務(wù)場(chǎng)景

假設(shè)你有一個(gè)在線商城，用戶登錄后會(huì)生成一個(gè) JWT Token，有效期為 7 天。超過(guò)有效期后，Token 應(yīng)該被自動(dòng)清理，防止數(shù)據(jù)庫(kù)膨脹和提高安全性。

技術(shù)選型

cron：用于定時(shí)任務(wù)調(diào)度
bull：用于任務(wù)隊(duì)列管理
MongoDB：存儲(chǔ) Token

實(shí)現(xiàn)步驟

1. 安裝依賴

npm install cron bull mongoose

2. 連接 MongoDB

const mongoose = require('mongoose');
mongoose.connect('mongodb://localhost:27017/your-database', { useNewUrlParser: true, useUnifiedTopology: true });
const db = mongoose.connection;
db.on('error', console.error.bind(console, '連接錯(cuò)誤：'));
db.once('open', () => {
  console.log('數(shù)據(jù)庫(kù)連接成功');
});

3. 定義 Token 模型

const tokenSchema = new mongoose.Schema({
  token: String,
  expiresAt: { type: Date, index: { expires: 1 } }
});
const Token = mongoose.model('Token', tokenSchema);

4. 創(chuàng)建定時(shí)任務(wù)

使用 cron 創(chuàng)建一個(gè)定時(shí)任務(wù)，每 1 小時(shí)執(zhí)行一次。

const cron = require('cron');
const ClearTokenJob = new cron.CronJob('0 * * * *', async () => {
  await Token.deleteMany({ expiresAt: { $lt: new Date() } });
  console.log('過(guò)期 Token 已清理');
});
ClearTokenJob.start();

5. 使用 Bull 管理任務(wù)隊(duì)列

Bull 可以確保任務(wù)的可靠執(zhí)行，即使 Node.js 進(jìn)程崩潰也能恢復(fù)。

const Queue = require('bull');
const clearTokenQueue = new Queue('clearTokenQueue', 'redis://127.0.0.1:6379');

clearTokenQueue.process(async (job, done) => {
  await Token.deleteMany({ expiresAt: { $lt: new Date() } });
  console.log('過(guò)期 Token 已清理');
  done();
});

6. 定時(shí)將任務(wù)加入隊(duì)列

結(jié)合 cron 和 bull，確保任務(wù)定時(shí)加入隊(duì)列。

const cron = require('cron');
const ClearTokenJob = new cron.CronJob('0 * * * *', () => {
  clearTokenQueue.add();
});
ClearTokenJob.start();

7. 監(jiān)控任務(wù)執(zhí)行

使用 Bull 的內(nèi)置監(jiān)控功能，確保任務(wù)執(zhí)行情況。

clearTokenQueue.on('completed', (job, result) => {
  console.log(`任務(wù)完成: ${job.id}, 結(jié)果: ${result}`);
});

clearTokenQueue.on('failed', (job, err) => {
  console.error(`任務(wù)失敗: ${job.id}, 錯(cuò)誤: ${err}`);
});

8. 高可用配置

在生產(chǎn)環(huán)境中，確保定時(shí)任務(wù)的高可用性。

Redis 集群：配置 Redis 集群，確保任務(wù)隊(duì)列的高可用性。
多實(shí)例：在多臺(tái)服務(wù)器上運(yùn)行定時(shí)任務(wù)，確保任務(wù)不會(huì)因?yàn)閱吸c(diǎn)故障而失敗。

9. 部署和測(cè)試

部署到生產(chǎn)環(huán)境前，務(wù)必進(jìn)行充分的測(cè)試。

本地測(cè)試：使用 nodemon 進(jìn)行本地測(cè)試，確保代碼無(wú)誤。
Docker：使用 Docker 部署，確保環(huán)境一致性。

# Dockerfile
FROM node:14
WORKDIR /app
COPY package*.json ./
RUN npm install
COPY . .
CMD ["node", "app.js"]

10. 日志記錄

記錄日志，便于問(wèn)題排查和監(jiān)控。

const winston = require('winston');
const logger = winston.createLogger({
  transports: [
    new winston.transports.Console(),
    new winston.transports.File({ filename: 'error.log', level: 'error' }),
    new winston.transports.File({ filename: 'combined.log' })
  ]
});

clearTokenQueue.process(async (job, done) => {
  try {
    await Token.deleteMany({ expiresAt: { $lt: new Date() } });
    logger.info('過(guò)期 Token 已清理');
    done();
  } catch (err) {
    logger.error(`清理 Token 失敗: ${err}`);
    done(err);
  }
});

11. 安全性考慮

Token 簽名：確保 JWT Token 的簽名安全。
環(huán)境變量：將敏感信息（如數(shù)據(jù)庫(kù)連接字符串）存儲(chǔ)在環(huán)境變量中。

const secret = process.env.SECRET_KEY;
const jwt = require('jsonwebtoken');

const generateToken = (userId) => {
  const token = jwt.sign({ userId }, secret, { expiresIn: '7d' });
  return token;
};

const verifyToken = (token) => {
  try {
    const decoded = jwt.verify(token, secret);
    return decoded;
  } catch (err) {
    return null;
  }
};

12. 優(yōu)化建議

索引優(yōu)化：在 expiresAt 字段上添加索引，提高查詢效率。
任務(wù)調(diào)度：根據(jù)業(yè)務(wù)需求調(diào)整 cron 的調(diào)度頻率。

const tokenSchema = new mongoose.Schema({
  token: String,
  expiresAt: { type: Date, index: { expires: 1 } } // 添加索引
});

13. 常見問(wèn)題

Token 未被清理：檢查 expiresAt 字段是否正確設(shè)置。
任務(wù)執(zhí)行失敗：查看日志文件，確保 Redis 連接無(wú)誤。

14. 其他工具推薦

如果你對(duì) cron 和 bull 的組合感到復(fù)雜，可以考慮使用 Hey Cron。Hey Cron 是一個(gè)高性能、易用的定時(shí)任務(wù)管理工具，支持多種任務(wù)調(diào)度方式和集成方式，能夠顯著簡(jiǎn)化任務(wù)管理的復(fù)雜度。

# 安裝 Hey Cron
npm install hey-cron

const { Cron } = require('hey-cron');

const clearTokenCron = new Cron('0 * * * *', async () => {
  await Token.deleteMany({ expiresAt: { $lt: new Date() } });
  logger.info('過(guò)期 Token 已清理');
});

clearTokenCron.start();