Express中使用Redis中间件，报错TypeError: Router.use() requires a middleware function but got a undefined方法解决

'# Express中使用Redis中间件，报错TypeError: Router.use() requires a middleware function but got a undefined方法解决

一、背景与问题

在Express项目中引入Redis中间件时，开发者常遇到TypeError: Router.use() requires a middleware function but got a undefined的错误。这个错误表明调用Router.use()时传入的参数不是有效的中间件函数，而是undefined。该问题在以下场景中尤为常见：

Redis连接未正确初始化导致中间件未定义
异步函数未正确返回中间件函数
中间件函数未正确导出或暴露
Redis客户端库版本兼容性问题

本篇文章将深入分析该错误的底层原理，结合完整代码示例和真实开发场景，探讨Express与Redis中间件的整合方案。

二、基本原理

1. Express中间件机制

Express的中间件本质是函数，其执行流程遵循以下规则：

中间件函数必须接收(req, res, next)三个参数
当调用next()时，控制权传递给下一个中间件
若未调用next()且未处理请求，则请求被终止

app.use((req, res, next) => {
  console.log('Middleware executed');
  next();
});

2. Redis中间件的特殊性

Redis中间件需要在请求处理前/处理后与Redis进行交互，其核心特征包括：

建立与Redis的连接（redis.createClient()）
使用Promise或async/await处理异步操作
管理缓存命中/未命中逻辑
处理连接异常和超时

三、环境准备

npm init -y
npm install express redis

创建基础项目结构：

express-redis-demo/
├── app.js
├── config/
│   └── redis.js
├── middleware/
│   └── redis.js
└── package.json

四、核心实现

1. 正确的中间件定义（推荐方式）

// middleware/redis.js
const Redis = require('redis');
const { createClient } = Redis;

// 1. 创建连接池（推荐方式）
const redisClient = createClient({
  host: '127.0.0.1',
  port: 6379,
  password: process.env.REDIS_PASSWORD,
  db: 0
});

// 2. 定义中间件函数
const redisMiddleware = (req, res, next) => {
  // 3. 异步处理逻辑
  redisClient.get(req.originalUrl, (err, data) => {
    if (err) {
      return next(err);
    }
    if (data) {
      // 缓存命中
      res.locals.cache = data;
      return next();
    }
    // 缓存未命中
    next();
  });
};

module.exports = redisMiddleware;

关键点说明：

使用createClient()创建连接池而非单例
中间件函数必须接收req, res, next参数
异步操作后必须调用next()传递控制权

2. 错误示例：未定义中间件

// 错误写法（会导致undefined）
const redisMiddleware = () => {
  // 未定义中间件函数
};

app.use(redisMiddleware); // 此时传入的是undefined

错误原因： 中间件函数未正确定义，导致Router.use()接收到undefined。

3. 异步中间件的正确写法

// 使用async/await处理异步逻辑
const redisMiddleware = async (req, res, next) => {
  try {
    const data = await redisClient.get(req.originalUrl);
    if (data) {
      res.locals.cache = data;
      return next();
    }
    next();
  } catch (err) {
    next(err);
  }
};

注意事项：

必须使用async/await或.then()处理异步逻辑
必须确保函数返回值为中间件函数（即必须有next()调用）

五、完整案例：缓存中间件实现

1. 项目结构

express-redis-demo/
├── app.js
├── config/
│   └── redis.js
├── middleware/
│   └── redis.js
└── package.json

2. 完整代码示例

// app.js
const express = require('express');
const redisMiddleware = require('./middleware/redis');

const app = express();

// 设置路由
app.get('/users', (req, res) => {
  res.json({ message: 'This is a cached response' });
});

// 使用缓存中间件
app.use(redisMiddleware);

// 启动服务
app.listen(3000, () => {
  console.log('Server is running on port 3000');
});

3. Redis配置文件

// config/redis.js
module.exports = {
  host: '127.0.0.1',
  port: 6379,
  password: process.env.REDIS_PASSWORD,
  db: 0
};

4. 中间件实现

// middleware/redis.js
const Redis = require('redis');
const { createClient } = Redis;
const { host, port, password, db } = require('../config/redis');

// 创建连接池
const redisClient = createClient({
  host,
  port,
  password,
  db
});

// 中间件函数
const redisMiddleware = async (req, res, next) => {
  try {
    const data = await redisClient.get(req.originalUrl);
    if (data) {
      res.locals.cache = data;
      return next();
    }
    next();
  } catch (err) {
    next(err);
  }
};

module.exports = redisMiddleware;

运行流程说明：

客户端请求/users路径
中间件先尝试从Redis获取缓存
若存在缓存则直接返回，否则继续处理
确保所有异常都被正确传递和处理

六、源码解析

1. Redis客户端初始化

const redisClient = createClient({
  host: '127.0.0.1',
  port: 6379,
  password: process.env.REDIS_PASSWORD,
  db: 0
});

关键点：

使用连接池模式（默认行为）
密码认证需要配置password字段
db参数指定使用哪个数据库（0-15）

2. 中间件函数执行流程

const redisMiddleware = async (req, res, next) => {
  try {
    const data = await redisClient.get(req.originalUrl);
    if (data) {
      res.locals.cache = data;
      return next();
    }
    next();
  } catch (err) {
    next(err);
  }
};

执行流程：

调用get()方法获取缓存
若存在数据则设置res.locals.cache并调用next()
若无数据则直接调用next()继续后续处理
异常情况通过next(err)传递错误

七、进阶使用

1. 带过期时间的缓存

const redisMiddleware = async (req, res, next) => {
  try {
    const data = await redisClient.get(req.originalUrl);
    if (data) {
      res.locals.cache = data;
      return next();
    }
    // 未命中时设置缓存并继续处理
    next();
  } catch (err) {
    next(err);
  }
};

建议：

在未命中时设置TTL（Time To Live）
使用setex()方法设置带过期时间的缓存

2. 缓存更新策略

app.get('/users', (req, res) => {
  const data = { users: ['Alice', 'Bob'] };
  res.locals.cache = JSON.stringify(data);
  
  // 设置缓存（带过期时间）
  redisClient.setex(req.originalUrl, 3600, JSON.stringify(data));
  
  res.json(data);
});

注意事项：

缓存更新应与业务逻辑解耦
建议使用setex()代替set()设置缓存

八、性能与工程实践

1. 性能优化策略

优化项	解决方案
连接池	使用`createClient()`创建连接池
异步处理	使用`async/await`避免阻塞
缓存命中率	优化缓存键的设计
错误处理	增加重试机制和日志记录

2. 安全风险分析

未授权访问： Redis默认开放端口，需配置密码和防火墙
缓存注入： 需要对请求参数进行过滤
数据泄露： 建议使用redis-cli --raw进行安全访问

推荐做法：

使用redis-cli配置密码保护
使用redis-sentinel或redis-cluster集群部署
对敏感数据进行加密处理

3. 错误处理机制

redisClient.on('error', (err) => {
  console.error('Redis connection error:', err);
  // 可以在此触发全局错误处理
});