Node.js (Express) + MySQL + Redis构建项目流程
以下是使用 Node.js (Express) + MySQL + Redis 构建完整项目的详细流程，涵盖环境搭建、架构设计、核心代码实现和部署优化：
一、项目初始化
1. 创建项目目录
mkdir my-project
cd my-project
npm init -y
2. 安装基础依赖
npm install express mysql2 redis dotenv cors
npm install --save-dev nodemon eslint prettier
3. 目录结构设计
my-project/
├── config/ # 配置文件
│ ├── db.js # 数据库连接
│ └── redis.js # Redis连接
├── controllers/ # 业务逻辑
│ └── userController.js
├── models/ # 数据模型
│ └── User.js
├── routes/ # 路由定义
│ └── userRoutes.js
├── middlewares/ # 中间件
│ └── authMiddleware.js
├── utils/ # 工具函数
│ └── cache.js
├── app.js # 应用入口
├── .env # 环境变量
└── package.json
二、数据库配置
1. MySQL 连接配置 (config/db.js)
const mysql = require('mysql2/promise');
const pool = mysql.createPool({host: process.env.MYSQL_HOST,user: process.env.MYSQL_USER,password: process.env.MYSQL_PASSWORD,database: process.env.MYSQL_DATABASE,waitForConnections: true,connectionLimit: 10,queueLimit: 0
});module.exports = pool;
2. Redis 连接配置 (config/redis.js)
const redis = require('redis');
const client = redis.createClient({url: `redis://${process.env.REDIS_HOST}:6379`
});client.on('error', (err) => console.log('Redis Client Error', err));
client.connect();module.exports = client;
3. 环境变量 (.env)
MYSQL_HOST=localhost
MYSQL_USER=root
MYSQL_PASSWORD=yourpassword
MYSQL_DATABASE=myapp
REDIS_HOST=localhost
PORT=3000
三、Express 应用骨架 (app.js)
require('dotenv').config();
const express = require('express');
const cors = require('cors');
const userRoutes = require('./routes/userRoutes');const app = express();// 中间件
app.use(cors());
app.use(express.json());// 路由
app.use('/api/users', userRoutes);// 错误处理中间件
app.use((err, req, res, next) => {console.error(err.stack);res.status(500).send('Server Error');
});// 启动服务器
const PORT = process.env.PORT || 3000;
app.listen(PORT, () => {console.log(`Server running on port ${PORT}`);
});
四、核心功能实现
1. 数据模型 (models/User.js)
const pool = require('../config/db');class User {static async create({ username, email }) {const [result] = await pool.query('INSERT INTO users (username, email) VALUES (?, ?)',[username, email]);return result.insertId;}static async findById(id) {const [rows] = await pool.query('SELECT * FROM users WHERE id = ?', [id]);return rows[0];}
}module.exports = User;
2. 控制器 (controllers/userController.js)
const User = require('../models/User');
const client = require('../config/redis');const UserController = {async createUser(req, res) {try {const userId = await User.create(req.body);res.status(201).json({ id: userId });} catch (err) {res.status(500).json({ error: err.message });}},async getUser(req, res) {try {const { id } = req.params;const cacheKey = `user:${id}`;// 检查Redis缓存const cachedUser = await client.get(cacheKey);if (cachedUser) return res.json(JSON.parse(cachedUser));// 数据库查询const user = await User.findById(id);if (!user) return res.status(404).send('User not found');// 设置缓存（过期时间60秒）await client.setEx(cacheKey, 60, JSON.stringify(user));res.json(user);} catch (err) {res.status(500).json({ error: err.message });}}
};module.exports = UserController;
3. 路由定义 (routes/userRoutes.js)
const express = require('express');
const router = express.Router();
const UserController = require('../controllers/userController');router.post('/', UserController.createUser);
router.get('/:id', UserController.getUser);module.exports = router;
五、高级功能扩展
1. 缓存工具类 (utils/cache.js)
const client = require('../config/redis');const Cache = {async getOrSet(key, cb, ttl = 60) {const cachedData = await client.get(key);if (cachedData) return JSON.parse(cachedData);const freshData = await cb();await client.setEx(key, ttl, JSON.stringify(freshData));return freshData;}
};module.exports = Cache;
2. 使用示例（改造控制器）
const Cache = require('../utils/cache');async getUser(req, res) {const { id } = req.params;const user = await Cache.getOrSet(`user:${id}`,() => User.findById(id),60 // TTL 60秒);res.json(user);
}
六、数据库初始化
1. 创建MySQL表
CREATE TABLE users (id INT AUTO_INCREMENT PRIMARY KEY,username VARCHAR(50) NOT NULL,email VARCHAR(100) NOT NULL UNIQUE,created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);
2. Redis 基础命令验证
redis-cli
> PING # 应返回 "PONG"
七、项目运行与调试
1. 开发模式启动
npx nodemon app.js
2. 测试API
# 创建用户
curl -X POST http://localhost:3000/api/users \-H "Content-Type: application/json" \-d '{"username":"test","email":"test@example.com"}'# 查询用户
curl http://localhost:3000/api/users/1
八、生产环境部署
1. PM2 进程管理
npm install -g pm2
pm2 start app.js --name "my-api"
2. Nginx 反向代理配置
server {listen 80;server_name api.example.com;location / {proxy_pass http://localhost:3000;proxy_set_header Host $host;}
}
3. 安全加固
- 使用HTTPS（Let’s Encrypt）
- 数据库连接限制IP白名单
- Redis设置密码认证
九、性能监控（可选）
npm install express-status-monitor
在 app.js 中添加：
const monitor = require('express-status-monitor');
app.use(monitor());
访问 /status 查看实时指标
通过以上流程，您已经构建了一个具备以下特性的生产级项目：
✅ RESTful API 基础架构
✅ MySQL 数据持久化
✅ Redis 缓存加速
✅ 分层架构设计（Router-Controller-Model）
✅ 环境变量管理
✅ 生产环境部署方案
可根据需求进一步扩展：
- 添加JWT认证
- 集成Swagger文档
- 实现分页查询
- 接入日志系统（Winston/Morgan）