如何使用 apicache-plus 实现路由缓存的精细化失效控制

npm install apicache-plus

const express = require("express");
const apicache = require("apicache-plus"); // 注意这里是 apicache-plus

const app = express();
const router = express.Router(); // 建议使用 Express.Router 管理路由

// 初始化 apicache-plus 实例
// let cache = apicache.middleware; // apicache-plus 的中间件直接从包中导出

// 示例：一个需要被缓存的路由
router.get(
  "/api/users/getName/:id",
  apicache.middleware("10 minutes"), // 缓存 10 分钟
  async (req, res, next) => {
    // 设置缓存组，例如命名为 'userDataGroup'
    req.apicacheGroup = "userDataGroup"; 

    // 模拟从数据库获取数据
    const userId = req.params.id;
    const someData = { id: userId, name: "Amy" }; 
    console.log(`Fetching data for user ${userId} and caching it in group 'userDataGroup'`);
    res.json(someData);
  }
);

app.use(router); // 将路由挂载到 Express 应用

// ... 其他应用配置和启动

// 示例：一个触发数据更新并需要清除缓存的路由
router.patch("/api/users/updateUser/:id", async (req, res, next) => {
  const userId = req.params.id;
  // 模拟更新用户数据
  console.log(`User ${userId} data updated. Clearing cache group 'userDataGroup'.`);

  // 清除 'userDataGroup' 下的所有缓存
  apicache.clear("userDataGroup"); 

  const updatedUser = { id: userId, name: "Jeff", status: "updated" }; // 模拟更新后的数据
  res.json(updatedUser);
});

app.use(router); // 将路由挂载到 Express 应用

// ... 其他应用配置和启动
app.listen(3000, () => {
  console.log("Server running on port 3000");
});

const express = require("express");
const apicache = require("apicache-plus"); // 引入 apicache-plus

const app = express();
const router = express.Router();

// 模拟一些数据
let users = {
  "1": { id: "1", name: "Amy", email: "amy@example.com" },
  "2": { id: "2", name: "Bob", email: "bob@example.com" },
};

app.use(express.json()); // 用于解析请求体

// 路由：获取用户信息（带缓存）
router.get(
  "/api/users/:id",
  apicache.middleware("10 minutes"), // 缓存 10 分钟
  async (req, res) => {
    const userId = req.params.id;
    // 将此路由的缓存标记为 'userProfile' 组
    req.apicacheGroup = "userProfile"; 

    console.log(`[GET /api/users/${userId}] - 从后端获取数据`);
    const user = users[userId];
    if (user) {
      return res.status(200).json(user);
    } else {
      return res.status(404).json({ message: "User not found" });
    }
  }
);

// 路由：更新用户信息（清除相关缓存）
router.patch("/api/users/:id", async (req, res) => {
  const userId = req.params.id;
  const { name, email } = req.body;

  if (!users[userId]) {
    return res.status(404).json({ message: "User not found" });
  }

  // 更新用户数据
  if (name) users[userId].name = name;
  if (email) users[userId].email = email;

  console.log(`[PATCH /api/users/${userId}] - 用户数据已更新，清除 'userProfile' 缓存组`);
  // 数据更新后，清除 'userProfile' 组的所有缓存
  apicache.clear("userProfile"); 

  return res.status(200).json(users[userId]);
});

app.use(router);

const PORT = 3000;
app.listen(PORT, () => {
  console.log(`Server running on http://localhost:${PORT}`);
  console.log("尝试访问 http://localhost:3000/api/users/1 多次，观察缓存效果。");
  console.log("然后使用 PATCH 请求 http://localhost:3000/api/users/1 更新数据，再访问 GET 路由，观察缓存失效效果。");
});