Reader

CTO:通电全司,前端入关!

| 掘金本周最热 | Default

"2025年3月8日,公司CTO一纸和平通电发出,200前端再度入关,全面接管公司后端服务,公司近代史上规模最大的一次前后端混战也随之即将结束。"

下载.png

3月8日夜,整个公司都在为妇女节活动做着最后的冲刺,但我们开发团队却暗流涌动,最终我们在前端Leader的带领下全面夺权,发动闪电战,全面接管后端服务,将公司技术架构推向全栈。

【兵变导火索】

公司的核心系统主要使用 Java 编写,后端API网关是用 Spring Boot 开发的。每次流量激增时,API网关的响应速度都变得迟钝,出现大量超时和 5xx 错误,有很深的隐患。

那天中午,公司发布了一个3.8运营活动,并进行大规模的促销活动。随着流量暴增,API网关开始出现了瓶颈——请求的处理时间变得越来越长。很快,线上系统发生了 500 错误,大多数客户的请求都未能及时响应,导致大量订单丢失和客户流失。

【闪电入关】

CTO正急的焦头烂额,这时候作为应届生的我站出来了:"我提议,我们应该采用Node.js来替代目前的后端API网关。"

所有人都转过来看着我,我继续说道:“Node.js 的非阻塞异步 I/O 能处理更多的请求,而且启动速度快,内存占用少。我们可以利用它的优势,提升系统的响应能力,特别是在高并发的情况下。”

"Node.js 真的能处理我们的高并发请求吗?它的单线程模型会不会导致性能问题?" CTO提出了自己的疑问。

我微笑着回应道:“我理解你们的担忧,Node.js 确实在某些场景下会遇到单线程性能瓶颈,但它的异步非阻塞I/O设计让它能够非常高效地处理大量并发请求。如果处理的是 I/O 密集型的任务,它能够比Java更好地表现。”

CTO眉头紧锁:“可是我们没有时间开发了”

这时,我们前端Leader拿出我们前端内部早就开发好的Node服务演示给CTO看,等待了三年的夺权机会,终于来了。

【技术巷战】

前端Node.js服务随即在凌晨三点上线。前端团队用早已备好的脚本将流量逐步切至新系统,监控面板上的错误率曲线如悬崖般骤降。然而,胜利的欢呼尚未持续半小时,服务器CPU突然飙升至90%——Node.js的单线程弱点在密集的JWT令牌解密计算中暴露无遗。

后端团队的反击来得迅猛。后端Leader在钉钉群甩出一张火焰图:"Node.js连线程池都没有,硬扛加密计算就是自杀!" 配图是Java线程池优雅调度的监控曲线。  前端立刻回击:"你们的阻塞式IO把数据库连接池拖垮了,我们是在替你们擦屁股!"

群聊瞬间沦为战场。后端Leader突然@全体成员:"缓存雪崩了!Redis集群扛不住促销流量!"

我秒回一个邪笑表情:"Redis?我们有localStorage!"

后端团队炸锅:"浏览器存储能和服务器缓存比?"

"至少不会因为线程阻塞让整个集群挂掉!" 我们Leader补刀,顺带贴了张Chrome DevTools截图,"看好了,会话存储热更新,零延迟!"

战火蔓延到数据库层。

后端Leader冷笑:"订单事务你们拿头保证?MySQL的ACID特性是摆设?"

我们Leader不甘示弱:"MongoDB的文档模型天然适合促销活动,嵌套式订单结构一把梭!"

"事务一致性呢?"

"用乐观锁和Two-Phase Commit照样玩得转!"

"那分库分表呢?"

"Sharding Key配哈希路由,我们写React时早把树形结构玩透了!"

有人给前端Node服务提issue标注 "建议改用Java"

我们立刻在Spring Boot仓库回敬 "推荐重写为TypeScript"

【全栈和解】

CTO眼见事态难以控制,随即说道:“半个小时以前,刚刚通过武装调停的决议”

并发表《和平宣言》:“前端Leader兼任后端架构师,全面接管后端服务;后端开发从头开始学HTML”

他端起咖啡杯冷笑:“全栈不是语言宗教,是缝合怪艺术。”

【Node实现后端服务】

1. 初始化项目

首先,初始化一个新的 Node.js 项目并安装必要的依赖。

mkdir node-api-server
cd node-api-server
npm init -y
npm install express dotenv mongoose cors helmet morgan body-parser joi

2. 项目结构

node-api-server/
│
├── src/
│   ├── controllers/   # 控制器层,处理业务逻辑
│   ├── middlewares/   # 中间件,处理请求前后逻辑
│   ├── models/        # 数据模型
│   ├── routes/        # 路由层,定义接口路径
│   ├── services/      # 服务层,处理与数据库交互等
│   ├── utils/         # 工具类
│   └── app.js         # 应用主文件
├── .env               # 环境变量配置
├── package.json
└── server.js          # 入口文件

3. 配置 .env 文件

PORT=3000
MONGO_URI=mongodb://localhost:27017/mydb

4. 创建 server.js 文件

这是项目的入口文件,负责启动 Express 应用。

const express = require('express');
const mongoose = require('mongoose');
const dotenv = require('dotenv');
const cors = require('cors');
const helmet = require('helmet');
const morgan = require('morgan');
const bodyParser = require('body-parser');

// 环境变量加载
dotenv.config();

const app = express();

// 中间件
app.use(helmet()); // 安全中间件
app.use(cors()); // 启用 CORS
app.use(morgan('dev')); // 请求日志中间件
app.use(bodyParser.json()); // 解析 JSON 格式的请求体

// 数据库连接
mongoose.connect(process.env.MONGO_URI, {
  useNewUrlParser: true,
  useUnifiedTopology: true,
})
  .then(() => console.log('MongoDB Connected'))
  .catch((err) => console.error('MongoDB connection error: ', err));

// 路由
const userRoutes = require('./src/routes/userRoutes');
app.use('/api/users', userRoutes);

// 404 处理
app.use((req, res) => {
  res.status(404).json({ message: 'Not Found' });
});

// 错误处理
app.use((err, req, res, next) => {
  console.error(err);
  res.status(500).json({ message: 'Internal Server Error' });
});

// 启动服务
const PORT = process.env.PORT || 3000;
app.listen(PORT, () => {
  console.log(`Server running on port ${PORT}`);
});

5. 创建 src/routes/userRoutes.js 文件

路由定义层,负责接收请求并调用对应的控制器方法。

PORT=3000
MONGO_URI=mongodb://localhost:27017/mydb

5. 创建 src/routes/userRoutes.js 文件

const express = require('express');
const router = express.Router();
const userController = require('../controllers/userController');

// 用户注册
router.post('/register', userController.register);

// 用户登录
router.post('/login', userController.login);

// 获取用户信息
router.get('/:id', userController.getUserInfo);

module.exports = router;

6. 创建 src/controllers/userController.js 文件

控制器层,负责处理业务逻辑。

const User = require('../models/userModel');
const bcrypt = require('bcrypt');
const jwt = require('jsonwebtoken');

// 注册
exports.register = async (req, res) => {
  try {
    const { username, password } = req.body;

    // 检查用户是否已存在
    const userExists = await User.findOne({ username });
    if (userExists) {
      return res.status(400).json({ message: 'Username already exists' });
    }

    // 密码加密
    const hashedPassword = await bcrypt.hash(password, 10);

    // 创建新用户
    const newUser = new User({ username, password: hashedPassword });
    await newUser.save();

    res.status(201).json({ message: 'User created successfully' });
  } catch (error) {
    res.status(500).json({ message: 'Server error', error });
  }
};

// 登录
exports.login = async (req, res) => {
  try {
    const { username, password } = req.body;

    const user = await User.findOne({ username });
    if (!user) {
      return res.status(404).json({ message: 'User not found' });
    }

    const validPassword = await bcrypt.compare(password, user.password);
    if (!validPassword) {
      return res.status(400).json({ message: 'Invalid password' });
    }

    const token = jwt.sign({ id: user._id }, process.env.JWT_SECRET, { expiresIn: '1h' });

    res.status(200).json({ message: 'Login successful', token });
  } catch (error) {
    res.status(500).json({ message: 'Server error', error });
  }
};

// 获取用户信息
exports.getUserInfo = async (req, res) => {
  try {
    const user = await User.findById(req.params.id);
    if (!user) {
      return res.status(404).json({ message: 'User not found' });
    }

    res.status(200).json({ username: user.username });
  } catch (error) {
    res.status(500).json({ message: 'Server error', error });
  }
};

7. 创建 src/models/userModel.js 文件

Mongoose 数据模型定义层。

const mongoose = require('mongoose');

const userSchema = new mongoose.Schema({
  username: {
    type: String,
    required: true,
    unique: true,
    minlength: 3,
    maxlength: 50,
  },
  password: {
    type: String,
    required: true,
    minlength: 6,
  },
}, { timestamps: true });

module.exports = mongoose.model('User', userSchema);

8. 创建 src/middlewares/authMiddleware.js 文件

一个验证用户身份的中间件,可以用于需要身份认证的接口。

const jwt = require('jsonwebtoken');

// 验证 JWT token
module.exports = (req, res, next) => {
  const token = req.header('Authorization');
  if (!token) {
    return res.status(401).json({ message: 'No token, authorization denied' });
  }

  try {
    const decoded = jwt.verify(token, process.env.JWT_SECRET);
    req.user = decoded;
    next();
  } catch (error) {
    res.status(401).json({ message: 'Token is not valid' });
  }
};

9. 启动服务

node server.js

10. 测试接口

  1. POST /api/users/register - 注册用户
  2. POST /api/users/login - 登录并返回 JWT token
  3. GET /api/users/:id - 获取用户信息

【后记】

夕阳透过落地窗洒在Git提交记录上,那些"紧急修复"的commit message里,夹杂着一条Node服务调用Java方法的日志:
// 真香警告:线程池其实挺好用的
而某个Spring Boot配置文件的注释栏赫然写着:
@TODO 考虑移植到Deno