精通 apicache-plus：实现 Node.js 路由缓存的条件性清除

npm install apicache-plus

const express = require("express");
const apicache = require("apicache-plus"); // 确保引入的是 apicache-plus
const app = express();

// 初始化 apicache-plus 中间件
let cache = apicache.middleware;

// 路由：获取用户名称，并缓存10分钟，归类到 "userData" 组
app.get(
  "/api/users/getName/:id",
  cache("10 minutes"), // 缓存10分钟
  async (req, res, next) => {
    // 将此路由的缓存条目归类到 "userData" 组
    req.apicacheGroup = "userData";
    // 模拟从数据库获取数据
    const someData = { id: req.params.id, name: "Amy" };
    console.log(`[GET] /api/users/getName/${req.params.id} - 从数据库获取数据`);
    res.json(someData);
  }
);

// 中间件，用于解析 JSON 请求体
app.use(express.json());

// 路由：更新用户数据，并清除 "userData" 组的缓存
app.patch("/api/users/updateUser/:id", async (req, res, next) => {
  // 模拟更新用户数据的逻辑
  console.log(`[PATCH] /api/users/updateUser/${req.params.id} - 更新用户数据`);
  // 更新数据后，清除 "userData" 组的所有缓存，确保下次请求获取最新数据
  apicache.clear("userData");

  const updatedUser = { id: req.params.id, name: req.body.name || "Jeff", status: "updated" };
  res.json(updatedUser);
});

const express = require("express");
const apicache = require("apicache-plus"); // 确保引入的是 apicache-plus
const app = express();
const port = 3000;

// 初始化 apicache-plus 中间件
let cache = apicache.middleware;

// 中间件，用于解析 JSON 请求体
app.use(express.json());

// 路由1: 获取用户名称，并缓存10分钟，归类到 "userData" 组
app.get(
  "/api/users/getName/:id",
  cache("10 minutes"),
  async (req, res, next) => {
    // 设置缓存分组
    req.apicacheGroup = "userData";
    // 模拟从数据库获取数据
    const someData = { id: req.params.id, name: "Amy" };
    console.log(`[GET] /api/users/getName/${req.params.id} - 从数据库获取数据`);
    res.json(someData);
  }
);

// 路由2: 更新用户数据，并清除 "userData" 组的缓存
app.patch("/api/users/updateUser/:id", async (req, res, next) => {
  // 模拟更新用户数据的逻辑
  console.log(`[PATCH] /api/users/updateUser/${req.params.id} - 更新用户数据`);
  // 更新数据后，清除 "userData" 组的所有缓存，确保下次请求获取最新数据
  apicache.clear("userData");

  const updatedUser = { id: req.params.id, name: req.body.name || "Jeff", status: "updated" };
  res.json(updatedUser);
});

// 启动服务器
app.listen(port, () => {
  console.log(`Server running at http://localhost:${port}`);
  console.log("\n--- 测试步骤 ---");
  console.log("1. 访问 http://localhost:3000/api/users/getName/1");
  console.log("   观察控制台输出，第一次会显示 '[GET] ... 从数据库获取数据'。");
  console.log("2. 再次访问 http://localhost:3000/api/users/getName/1");
  console.log("   如果缓存生效，则不会显示 '[GET] ... 从数据库获取数据'。");
  console.log("3. 发送 PATCH 请求到 http://localhost:3000/api/users/updateUser/1");
  console.log("   请求体: {\"name\": \"NewName\"}");
  console.log("   观察控制台输出 '[PATCH] ... 更新用户数据'。");
  console.log("4. 再次访问 http://localhost:3000/api/users/getName/1");
  console.log("   此时应该会再次显示 '[GET] ... 从数据库获取数据'，表示缓存已被清除。");
});