缓存层

@ventostack/cache 提供了统一的缓存接口，底层可以切换内存缓存或 Redis，无需修改业务代码。

创建缓存

import { createCache, createMemoryAdapter } from "@ventostack/cache";

const cache = createCache(createMemoryAdapter());

基本操作

// 设置缓存（无 TTL，永久有效）
await cache.set("user:1", { id: 1, name: "Alice" });

// 设置缓存（自定义 TTL，秒）
await cache.set("session:abc", token, { ttl: 3600 });

// 获取缓存
const user = await cache.get<User>("user:1");
if (user) {
  // 命中缓存
} else {
  // 缓存未命中，从数据库加载
}

// 删除缓存
await cache.del("user:1");

// 检查是否存在
const exists = await cache.has("user:1");

// 清空所有缓存
await cache.flush();

缓存穿透保护（remember）

// 如果缓存命中直接返回，否则执行函数并缓存结果
const user = await cache.remember(
  `user:${id}`,
  300,  // TTL 秒
  async () => {
    return db.query(UserModel).where("id", "=", id).get();
  }
);

在路由中使用

router.get("/users/:id", async (ctx) => {
  const { id } = ctx.params;

  const user = await cache.remember(
    `user:${id}`,
    600, // 缓存 10 分钟
    async () => {
      const u = await db.query(UserModel).where("id", "=", id).get();
      if (!u) throw new NotFoundError("用户不存在");
      return u;
    }
  );

  return ctx.json(user);
});

// 更新时使缓存失效
router.put("/users/:id", async (ctx) => {
  const { id } = ctx.params;
  const body = await ctx.request.json();
  await db.query(UserModel).where("id", "=", id).update(body);
  await cache.del(`user:${id}`);  // 清除缓存
  return ctx.json({ ok: true });
});

Cache 接口

interface Cache {
  get<T>(key: string): Promise<T | null>;
  set(key: string, value: unknown, options?: { ttl?: number; tags?: string[] }): Promise<void>;
  del(key: string): Promise<void>;
  has(key: string): Promise<boolean>;
  flush(): Promise<void>;
  tags(tagNames: string[]): TaggedCache;
  remember<T>(key: string, ttl: number, factory: () => Promise<T>): Promise<T>;
}