企业级WEB缓存中间件之Redis

以下是一个使用ioredis和koa创建简单的Redis缓存中间件的示例代码：

const Koa = require('koa');
const Redis = require('ioredis');
 
// 初始化Redis客户端
const redis = new Redis();
 
// 创建Koa应用
const app = new Koa();
 
// 缓存中间件
app.use(async (ctx, next) => {
  // 构造缓存键
  const key = `cache:${ctx.url}`;
 
  // 尝试从Redis缓存中获取数据
  let data = await redis.get(key);
 
  if (data !== null) {
    // 如果缓存命中，则直接返回缓存数据
    ctx.body = JSON.parse(data);
  } else {
    // 如果缓存未命中，执行后续中间件，并将响应结果存储到Redis
    await next();
    if (ctx.body) {
      // 设置缓存过期时间，例如300秒
      await redis.set(key, JSON.stringify(ctx.body), 'EX', 300);
    }
  }
});
 
// 示例路由响应数据
app.use(ctx => {
  ctx.body = {
    message: 'Hello, World!'
  };
});
 
// 启动Koa服务
app.listen(3000);

这段代码首先初始化了一个Redis客户端，然后定义了一个Koa中间件，用于处理缓存逻辑。如果请求的数据在Redis缓存中存在，它将直接返回缓存的数据。如果缓存未命中，它会继续执行后续的中间件，并在响应完成后将响应结果存储到Redis中。这个示例还展示了如何设置缓存的过期时间。