如何用JavaScript实现一个支持多版本并存的API网关？

Accept-Version

const express = require('express');
const { createProxyMiddleware } = require('http-proxy-middleware');
const app = express();
const port = 8080;

// 服务与版本配置：这是一个关键的配置，定义了每个服务不同版本的后端地址
const serviceConfig = {
  users: {
    'v1': 'http://localhost:3001', // 用户服务v1版本
    'v2': 'http://localhost:3002'  // 用户服务v2版本
  },
  products: {
    'v1': 'http://localhost:4001', // 产品服务v1版本
    'v2': 'http://localhost:4002' // 产品服务v2版本
  },
  // 更多服务...
};

// 全局中间件，用于处理版本识别和请求代理
app.use('/api/:serviceName/*', (req, res, next) => {
  const { serviceName } = req.params;
  // 优先从Accept-Version头获取版本，其次是query参数，最后默认v1
  let version = req.headers['accept-version'] || req.query.version || 'v1';
  // 获取API路径中服务名之后的部分，例如 /api/users/profile -> profile
  const pathSuffix = req.params[0];

  const serviceVersions = serviceConfig[serviceName];

  if (!serviceVersions) {
    console.warn(`[Gateway] 服务 '${serviceName}' 未在配置中找到。`);
    return res.status(404).send(`服务 '${serviceName}' 不存在。`);
  }

  let targetUrl = serviceVersions[version];
  if (!targetUrl) {
    // 如果请求的版本不存在，尝试回退到v1版本。这是一个常见的容错策略。
    console.warn(`[Gateway] 服务 '${serviceName}' 的版本 '${version}' 不存在。回退到v1版本。`);
    targetUrl = serviceVersions['v1'];
    if (!targetUrl) {
      return res.status(400).send(`服务 '${serviceName}' 不支持版本 '${version}'，且无默认v1版本。`);
    }
    version = 'v1 (fallback)'; // 标记为回退版本
  }

  console.log(`[Gateway] 代理请求 /api/${serviceName}/${pathSuffix} (版本: ${version}) 到 ${targetUrl}/${pathSuffix}`);

  // 为当前请求动态创建代理实例
  const proxyMiddleware = createProxyMiddleware({
    target: targetUrl,
    changeOrigin: true, // 更改请求头中的Host字段，使其与目标URL的主机名相同
    pathRewrite: {
      // 重写路径，移除 /api/:serviceName 部分，确保后端服务接收到正确的路径
      [`^/api/${serviceName}`]: ''
    },
    onProxyReq: (proxyReq, req, res) => {
      // 在转发请求到后端服务之前，可以清理掉版本相关的头或查询参数
      // 因为后端服务可能不需要这些信息，或者有自己的版本识别机制
      proxyReq.removeHeader('accept-version');
      const url = new URL(proxyReq.path, 'http://dummy');
      url.searchParams.delete('version');
      proxyReq.path = url.pathname + url.search;
    },
    onError: (err, req, res) => {
      console.error(`[Gateway Error] 代理服务 '${serviceName}' (版本 ${version}) 失败:`, err);
      res.status(500).send('API网关代理错误，请稍后再试。');
    }
  });

  // 执行代理中间件
  proxyMiddleware(req, res, next);
});

// 根路径或健康检查
app.get('/', (req, res) => {
  res.send('API网关运行中。');
});

app.listen(port, () => {
  console.log(`API网关已启动，监听端口 ${port}`);
  console.log('配置的服务和版本:\n', JSON.stringify(serviceConfig, null, 2));
});

serviceConfig

users

products

serviceName

Accept-Version

version

v1

/v1/users

/v2/users

Accept-Version: v1

X-API-Version: v2

/users?version=v1

Accept: application/vnd.myapi.v1+json

Accept

Accept

jsonwebtoken