节点中的 HTTP GET 请求.js Express

javascript node.js express httprequest

2022-08-30 01:02:20

如何从 Node.js 或 Express.js 中发出 HTTP 请求？我需要连接到其他服务。我希望调用是异步的，并且回调包含远程服务器的响应。

答案 1

下面是我一个示例中的一些代码片段。它是异步的，并返回一个 JSON 对象。它可以执行任何形式的 GET 请求。

请注意，有更优化的方法（只是一个示例） - 例如，而不是将您放入数组中的块连接起来并加入它等...希望它能让你朝着正确的方向开始：

const http = require('http');
const https = require('https');

/**
 * getJSON:  RESTful GET request returning JSON object(s)
 * @param options: http options object
 * @param callback: callback to pass the results JSON object(s) back
 */

module.exports.getJSON = (options, onResult) => {
  console.log('rest::getJSON');
  const port = options.port == 443 ? https : http;

  let output = '';

  const req = port.request(options, (res) => {
    console.log(`${options.host} : ${res.statusCode}`);
    res.setEncoding('utf8');

    res.on('data', (chunk) => {
      output += chunk;
    });

    res.on('end', () => {
      let obj = JSON.parse(output);

      onResult(res.statusCode, obj);
    });
  });

  req.on('error', (err) => {
    // res.send('error: ' + err.message);
  });

  req.end();
};

它通过创建一个选项对象来调用，如下所示：

const options = {
  host: 'somesite.com',
  port: 443,
  path: '/some/path',
  method: 'GET',
  headers: {
    'Content-Type': 'application/json'
  }
};

并提供回调函数。

例如，在服务中，我需要上面的 REST 模块，然后执行以下操作：

rest.getJSON(options, (statusCode, result) => {
  // I could work with the resulting HTML/JSON here. I could also just return it
  console.log(`onResult: (${statusCode})\n\n${JSON.stringify(result)}`);

  res.statusCode = statusCode;

  res.send(result);
});

更新

如果您正在寻找/（线性，无回调），承诺，编译时支持和智能感知，我们创建了一个适合该账单的轻量级HTTP和REST客户端：asyncawait

Microsoft typed-rest-client

答案 2

尝试在 node 中使用简单的 http.get（options， callback） 函数.js：

var http = require('http');
var options = {
  host: 'www.google.com',
  path: '/index.html'
};

var req = http.get(options, function(res) {
  console.log('STATUS: ' + res.statusCode);
  console.log('HEADERS: ' + JSON.stringify(res.headers));

  // Buffer the body entirely for processing as a whole.
  var bodyChunks = [];
  res.on('data', function(chunk) {
    // You can process streamed parts here...
    bodyChunks.push(chunk);
  }).on('end', function() {
    var body = Buffer.concat(bodyChunks);
    console.log('BODY: ' + body);
    // ...and/or process the entire body here.
  })
});

req.on('error', function(e) {
  console.log('ERROR: ' + e.message);
});

还有一个通用的http.request（选项，回调）函数，允许您指定请求方法和其他请求详细信息。