微服务架构的核心思想是将大型单体应用拆分为多个职责单一、独立运行的小型服务,每个服务可以独立开发、部署和扩展,服务之间通过轻量协议通信。Node.js的异步特性和丰富的生态非常适合实现这类轻量服务,下面我们逐步讲解构建过程。

微服务拆分思路
在构建微服务前,首先需要明确业务边界,常见的拆分维度包括业务功能、数据边界、团队职责等。以电商系统为例,可以拆分为用户服务、商品服务、订单服务、支付服务等独立模块,每个服务只负责自身的核心业务逻辑,拥有独立的数据库,避免服务间的强耦合。
基础微服务开发
我们使用Express框架快速搭建单个微服务,首先初始化项目并安装依赖:
mkdir user-service cd user-service npm init -y npm install express cors
接下来编写用户服务的基础代码,提供用户查询接口:
const express = require('express');
const cors = require('cors');
const app = express();
const port = 3001;
// 允许跨域请求
app.use(cors());
// 解析JSON格式的请求体
app.use(express.json());
// 模拟用户数据
const users = [
{ id: 1, name: '张三', age: 25 },
{ id: 2, name: '李四', age: 28 }
];
// 获取用户列表接口
app.get('/users', (req, res) => {
res.json({
code: 200,
data: users
});
});
// 根据ID获取单个用户接口
app.get('/users/:id', (req, res) => {
const userId = parseInt(req.params.id);
const user = users.find(item => item.id === userId);
if (user) {
res.json({
code: 200,
data: user
});
} else {
res.status(404).json({
code: 404,
message: '用户不存在'
});
}
});
app.listen(port, () => {
console.log(`用户服务运行在 http://127.0.0.1:${port}`);
});
启动服务后,访问http://127.0.0.1:3001/users即可获取用户列表数据。按照同样的方式,我们可以开发商品服务,端口设置为3002,提供商品相关的接口。
服务间通信实现
微服务之间需要相互调用完成业务,常见的通信方式有HTTP REST和RPC,这里我们使用HTTP REST实现服务调用。例如订单服务需要获取用户信息,可以直接发起HTTP请求到用户服务:
const express = require('express');
const cors = require('cors');
const axios = require('axios');
const app = express();
const port = 3003;
app.use(cors());
app.use(express.json());
// 模拟订单数据
const orders = [
{ id: 1, userId: 1, productId: 1, count: 2 }
];
// 获取订单详情,同时查询对应的用户信息
app.get('/orders/:id', async (req, res) => {
const orderId = parseInt(req.params.id);
const order = orders.find(item => item.id === orderId);
if (!order) {
return res.status(404).json({
code: 404,
message: '订单不存在'
});
}
try {
// 调用用户服务获取用户信息
const userResponse = await axios.get(`http://127.0.0.1:3001/users/${order.userId}`);
order.user = userResponse.data.data;
res.json({
code: 200,
data: order
});
} catch (error) {
res.status(500).json({
code: 500,
message: '获取用户信息失败'
});
}
});
app.listen(port, () => {
console.log(`订单服务运行在 http://127.0.0.1:${port}`);
});
上述代码需要先安装axios依赖:npm install axios,服务间通过HTTP接口直接通信,简单直接,适合中小规模的微服务场景。
API网关配置
当微服务数量增多后,前端直接调用多个服务的接口会变得复杂,此时需要引入API网关,统一接收前端请求,再路由到对应的后端服务。我们使用Express搭建简单的API网关:
const express = require('express');
const cors = require('cors');
const { createProxyMiddleware } = require('http-proxy-middleware');
const app = express();
const port = 3000;
app.use(cors());
app.use(express.json());
// 用户服务代理
app.use('/api/users', createProxyMiddleware({
target: 'http://127.0.0.1:3001',
changeOrigin: true,
pathRewrite: {
'^/api/users': '/users'
}
}));
// 订单服务代理
app.use('/api/orders', createProxyMiddleware({
target: 'http://127.0.0.1:3003',
changeOrigin: true,
pathRewrite: {
'^/api/orders': '/orders'
}
}));
app.listen(port, () => {
console.log(`API网关运行在 http://127.0.0.1:${port}`);
});
安装代理依赖:npm install http-proxy-middleware,之后前端只需要访问http://127.0.0.1:3000/api/users即可调用用户服务,访问http://127.0.0.1:3000/api/orders/1即可调用订单服务,网关会自动完成请求转发。
服务治理扩展
实际生产环境中,微服务还需要考虑服务注册与发现、熔断降级、链路追踪等治理能力。可以使用Consul、Etcd等工具实现服务注册发现,使用Circuit Breaker模块实现熔断,结合Jaeger等工具实现链路追踪,进一步完善微服务架构的稳定性和可观测性。
Node.js微服务架构ExpressRESTful_APIAPI_Gateway修改时间:2026-07-15 17:30:21