如何从 Node.js 或 Express.js 中发出 HTTP 请求?我需要连接到另一个服务。我希望调用是异步的,并且回调包含远程服务器的响应。
Node.js Express 中的 HTTP GET 请求
IT技术
javascript
node.js
express
httprequest
2021-01-28 00:39:58
6个回答
这是我的示例中的一些代码片段。它是异步的并返回一个 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 module,然后执行以下操作:
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);
});
更新
如果您正在寻找async
/ await
(线性,无回调)、promise、编译时支持和智能感知,我们创建了一个符合该要求的轻量级 HTTP 和 REST 客户端:
尝试使用node.js 中的简单http.get(options, callback)
函数:
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(options, callback)
功能,允许您指定请求方法和其他请求详细信息。
Request和Superagent是很好用的库。
注意:请求已被弃用,使用风险自负!
使用request
:
var request=require('request');
request.get('https://someplace',options,function(err,res,body){
if(err) //TODO: handle err
if(res.statusCode === 200 ) //etc
//TODO Do something with response
});
您还可以使用Requestify,这是我为 nodeJS 编写的一个非常酷且非常简单的 HTTP 客户端,它支持缓存。
只需对 GET 方法请求执行以下操作:
var requestify = require('requestify');
requestify.get('http://example.com/api/resource')
.then(function(response) {
// Get the response body (JSON parsed or jQuery object for XMLs)
response.getBody();
}
);
此版本基于bryanmac最初提出的函数,它使用了 promise,更好的错误处理,并用 ES6 重写。
let http = require("http"),
https = require("https");
/**
* getJSON: REST get request returning JSON object(s)
* @param options: http options object
*/
exports.getJSON = function (options) {
console.log('rest::getJSON');
let reqHandler = +options.port === 443 ? https : http;
return new Promise((resolve, reject) => {
let req = reqHandler.request(options, (res) => {
let output = '';
console.log('rest::', options.host + ':' + res.statusCode);
res.setEncoding('utf8');
res.on('data', function (chunk) {
output += chunk;
});
res.on('end', () => {
try {
let obj = JSON.parse(output);
// console.log('rest::', obj);
resolve({
statusCode: res.statusCode,
data: obj
});
}
catch (err) {
console.error('rest::end', err);
reject(err);
}
});
});
req.on('error', (err) => {
console.error('rest::request', err);
reject(err);
});
req.end();
});
};
因此,您不必传入回调函数,而是 getJSON() 返回一个Promise。在以下示例中,该函数在 ExpressJS 路由处理程序中使用
router.get('/:id', (req, res, next) => {
rest.getJSON({
host: host,
path: `/posts/${req.params.id}`,
method: 'GET'
}).then(({ statusCode, data }) => {
res.json(data);
}, (error) => {
next(error);
});
});
出错时,它将错误委托给服务器错误处理中间件。
其它你可能感兴趣的问题