当前位置：首页 > article >正文

【动态路由】系统Web URL资源整合系列（后端技术实现）【nodejs实现】

article 2025/2/24 6:35:45

需求说明

软件功能需求：反向代理功能（描述：apollo、eureka控、apisix、sentinel、普米、kibana、timetask、grafana、hbase、skywalking-ui、pinpoint、cmak界面、kafka-map、nacos、gateway、elasticsearch、 oa-portal 业务应用等多个web资源等只能通过有限个代理地址访问），不考虑SSO。

软件质量需求：满足基本的性能要求：页面响应耗时：3s内（页面本身不走代理就慢的情况除外）

约束条件：内部web资源权限控制的原因，可申请的web资源数量有限制，成百上千的web应用地址只能通过有限个（10个以内）代理地址访问

原型界面【Axuare】

原型界面视频讲解

系统URL整合系列视频二（界面原型）【axure原型界面】_系统url整合系列视频二(界面原型)-配套文档-CSDN博客

原型设计稿下载

https://download.csdn.net/download/jjk_02027/90335900

前端代码实现【d3js】

前端代码视频讲解

系统URL整合系列视频三（前端代码实现）【d3js版本】-CSDN博客

前端代码下载

https://download.csdn.net/download/jjk_02027/90335919

后端技术实现【nodejs实现】

在Node.js中，根据不同的条件将请求转发到不同的后端服务可以通过多种方式实现，其中最常用的是使用中间件。这里我将介绍几种常见的方法：

1. 使用 `express` 框架

假设你正在使用 express 框架，你可以使用 express-http-proxy 或 http-proxy-middleware 包来实现条件转发。

使用 `http-proxy-middleware`

首先，你需要安装这个包：

npm install http-proxy-middleware

然后，创建一个新的JavaScript文件，例如app.js，并设置你的Express服务器，你可以创建一个代理中间件并根据条件转发请求：

const express = require('express');
const { createProxyMiddleware } = require('http-proxy-middleware');
 
const app = express();
 
// 定义一个条件路由
app.use((req, res, next) => {
    if (req.headers['x-api-key'] === 'secret123') {
        // 使用代理转发到特定的后端服务
        return createProxyMiddleware({
            target: 'http://backend1.example.com', // 后端1的URL
            changeOrigin: true, // 更改请求头中的Host
        })(req, res, next);
    } else {
        // 使用另一个代理转发到另一个后端服务
        return createProxyMiddleware({
            target: 'http://backend2.example.com', // 后端2的URL
            changeOrigin: true, // 更改请求头中的Host
        })(req, res, next);
    }
});
 
app.listen(3000, () => {
    console.log('Server is running on port 3000');
});

2. 使用 `axios` 或 `node-fetch` 手动转发请求

如果你不希望使用代理中间件，也可以使用 axios 或 node-fetch 来手动转发请求。

使用 `axios`

首先，安装 axios

npm install axios

然后，编写代码来根据条件转发请求：

const express = require('express');
const axios = require('axios');
 
const app = express();
 
app.use(async (req, res) => {
    let targetUrl;
    if (req.headers['x-api-key'] === 'secret123') {
        targetUrl = 'http://backend1.example.com'; // 后端1的URL
    } else {
        targetUrl = 'http://backend2.example.com'; // 后端2的URL
    }
    try {
        const response = await axios({ ...req, url: targetUrl }); // 使用axios转发请求，保持原有的请求方法、头部等属性
        res.status(response.status).send(response.data); // 发送响应给客户端
    } catch (error) {
        res.status(error.response ? error.response.status : 500).send(error.message); // 处理错误并返回给客户端
    }
});
 
app.listen(3000, () => {
    console.log('Server is running on port 3000');
});

3. 直接使用原生 `http` 模块（不推荐，除非有特殊需求）

虽然不推荐，但你也可以使用 Node.js 的原生 http 或 https 模块来手动转发请求：

const http = require('http');
const express = require('express');
const app = express();
 
app.use((req, res) => {
    let targetUrl;
    if (req.headers['x-api-key'] === 'secret123') {
        targetUrl = 'http://backend1.example.com'; // 后端1的URL
    } else {
        targetUrl = 'http://backend2.example.com'; // 后端2的URL
    }
    const options = { ...req, url: targetUrl }; // 注意这里的url应为完整的URL或使用其他方式指定目标URL和端口等参数，此处仅为示意。实际使用时需调整。通常需要使用`url`模块来处理完整的URL。
    const proxyReq = http.request(options, proxyRes => { // 使用原生http模块创建代理请求。注意这里的options需要正确设置。通常需要额外处理headers等。此处仅为示意。实际使用时需调整。通常需要额外处理headers等。此处仅为示意。实际使用时需调整。通常需要额外处理headers等。此处仅为示意

4、运行你的应用

保存你的更改并运行你的Express应用

node app.js

现在，你的Express应用会根据请求的路径将请求转发到不同的后端服务。例如，所有发送到['x-api-key'] === 'secret123'的请求将被转发到http://backend1.example.com，而所有其他的请求将被转发到http://backend2.example.com。