Node.js与Springboot集成：如何从Nodejs后端向Spring-boot微服务发起Rest调用

方案选型参考 #

根据你的项目场景选择对应方案即可：

• 普通业务场景优先选Axios实现：开发效率高、生态成熟，90%以上的业务场景都适用
• 无额外依赖要求的轻量场景选原生模块：不需要安装第三方包，性能损耗最低
• 微服务集群场景在基础调用逻辑上额外增加高可用配置即可

具体实现步骤 #

1. Spring Boot侧前置准备 #

首先确保Spring Boot的REST接口可正常调用，优先用curl/Postman先调通接口，避免后续排查问题混淆错误来源。如果两个服务不在同一内网需要跨域，可在Spring Boot侧增加如下配置：

@Configuration
public class WebConfig implements WebMvcConfigurer {
    @Override
    public void addCorsMappings(CorsRegistry registry) {
        registry.addMapping("/**")
                // 填写Node.js服务的IP/域名
                .allowedOrigins("http://xxx.xxx.xxx.xxx:端口")
                .allowedMethods("GET", "POST", "PUT", "DELETE")
                .allowCredentials(true);
    }
}

2. 最优方案1：Axios实现（通用场景首选） #

优点是语法简洁、支持Promise、内置拦截器、自动序列化JSON，是Node.js服务调用REST接口的主流方案。
首先安装依赖：
npm install axios
调用示例：

const axios = require('axios');

// 封装通用调用实例，避免重复配置
const springBootClient = axios.create({
  // 填写Spring Boot服务的访问地址
  baseURL: 'http://SpringBoot服务IP:端口',
  timeout: 5000,
  headers: {
    'Content-Type': 'application/json',
    // 统一配置鉴权信息，不需要可以删掉
    // 'Authorization': 'Bearer 你的鉴权token'
  }
});

// GET请求示例
async function getUserInfo(userId) {
  try {
    const response = await springBootClient.get('/user/info', {
      params: { userId }
    });
    return response.data;
  } catch (error) {
    console.error('调用Spring Boot接口失败：', error.response?.data || error.message);
    throw error;
  }
}

// POST请求示例
async function createUser(userData) {
  try {
    const response = await springBootClient.post('/user/add', userData);
    return response.data;
  } catch (error) {
    console.error('创建用户接口调用失败：', error.response?.data || error.message);
    throw error;
  }
}

3. 最优方案2：原生http/https模块实现（无依赖场景首选） #

如果你的Node.js项目不希望引入额外第三方依赖，可以用Node.js自带的网络模块实现，性能更高，只是代码相对繁琐：

const http = require('http');

function callSpringBootApi(path, method, data = null) {
  return new Promise((resolve, reject) => {
    const postData = data ? JSON.stringify(data) : null;
    const options = {
      hostname: 'SpringBoot服务IP',
      port: 8080,
      path: path,
      method: method,
      headers: {
        'Content-Type': 'application/json',
        'Content-Length': postData ? Buffer.byteLength(postData) : 0
      }
    };

    const req = http.request(options, (res) => {
      let result = '';
      res.on('data', (chunk) => {
        result += chunk;
      });
      res.on('end', () => {
        try {
          resolve(JSON.parse(result));
        } catch (e) {
          resolve(result);
        }
      });
    });

    req.on('error', (e) => {
      reject(e);
    });

    if (postData) {
      req.write(postData);
    }
    req.end();
  });
}

// 调用示例
callSpringBootApi('/user/info?userId=123', 'GET')
  .then(res => console.log(res))
  .catch(err => console.error(err));

4. 微服务集群场景增强 #

如果你的Spring Boot服务是注册在Nacos/Eureka等注册中心的集群服务，需要高可用能力，可以在上述基础上增加配置：

• 对接注册中心OpenAPI拉取Spring Boot服务的可用节点列表，自行实现轮询/随机负载均衡逻辑
• 引入opossum库实现熔断降级，避免上游服务故障拖垮Node.js服务
• 增加幂等请求的重试逻辑，对网络抖动类错误自动重试2-3次

常见问题排查 #

• 连接超时：优先检查两个服务的网络是否连通，防火墙是否开放Spring Boot的服务端口
• 401/403错误：检查请求的鉴权头是否正确传递
• 400错误：检查请求参数格式、字段是否符合Spring Boot接口要求
• 500错误：优先查看Spring Boot服务的日志确认错误原因

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