使用Consul实现服务发现时Node.js无法连接服务的问题

你遇到的ECONNREFUSED 127.0.0.1:80错误，本质是踩了服务发现里的初始化时机坑——你的API适配器在模块加载阶段就被固定初始化了，而此时known_data_instances还是空数组。当你尝试从空数组里选实例时，得到的是undefined，axios会默认使用http://localhost:80作为baseURL，这就导致了连接被拒绝。

除此之外还有两个隐形问题：

• 就算后续Consul推送了健康服务列表，你的API适配器也不会自动更新，还是会用初始化时的错误配置
• 没有对服务实例为空的情况做处理，极端场景下会直接抛出未处理的错误

我们需要调整代码逻辑，让API实例的创建动态化，每次请求都从最新的健康服务列表里选择实例。以下是修改后的路由文件代码：

var consul = require("consul")({host: '10.0.1.248'});
var known_data_instances = [];
const apiAdapter = require('./apiAdapter');

// 监听健康服务列表变更
var watcher = consul.watch({
  method: consul.health.service,
  options: { service:'test-service', passing:true }
});

watcher.on('change', data => {
  console.log('received discovery update:', data.length);
  // 用map简化实例列表的生成
  known_data_instances = data.map(entry => 
    `http://${entry.Service.Address}:${entry.Service.Port}/`
  );
});

watcher.on('error', err => {
  console.error('watch error', err);
});

// 封装获取可用服务实例的工具函数
function getHealthyServiceInstance() {
  if (known_data_instances.length === 0) {
    throw new Error('No healthy test-service instances are available');
  }
  // 随机选择实例（也可替换为轮询等负载均衡策略）
  return known_data_instances[Math.floor(Math.random() * known_data_instances.length)];
}

router.get('/login', (req, res) => {
  try {
    // 每次请求都动态获取最新健康实例，创建API适配器
    const targetInstance = getHealthyServiceInstance();
    const api = apiAdapter(targetInstance);
    
    api.get(req.path)
      .then(resp => res.send(resp.data))
      .catch(apiErr => {
        console.error('Failed to call test-service:', apiErr);
        res.status(503).send('Service temporarily unavailable');
      });
  } catch (initErr) {
    res.status(503).send(initErr.message);
  }
});

1. 延迟API适配器初始化：不再在模块顶部固定创建API实例，而是每次请求时根据最新的健康服务列表动态创建，确保使用的是Consul推送的有效地址
2. 添加空实例检查：通过getHealthyServiceInstance函数提前判断是否有可用服务，避免直接抛出未处理的错误
3. 简化实例列表生成：用map替代forEach+push，代码更简洁易读
4. 完善错误处理：捕获API请求和实例获取过程中的错误，返回合理的HTTP状态码

• 缓存API实例：如果不想每次请求都创建新的axios实例，可以维护一个实例缓存，在服务列表更新时清空缓存
• 负载均衡策略：把随机选择换成轮询、加权轮询等策略，让流量分布更均匀
• 重试机制：当某个实例请求失败时，自动重试另一个健康实例，提升服务可用性

内容的提问来源于stack exchange，提问作者joshk132