Node.js Express中的HTTP GET请求-Java 学习之路

160

如何从node / express中发出HTTP请求？我需要连接到另一个服务 . 我希望该调用是异步的，并且回调包含远程服务器响应 .

12 回答

这是我的一个样本的代码 . 它是异步并返回一个JSON对象 . 它可以做任何获取请求 . 请注意，有更多的最佳方式（只是一个示例） - 例如，而不是连接您放入数组并加入它的块等...希望它能让您开始朝着正确的方向前进：

var http = require("http");
var https = require("https");

/**
 * getJSON:  REST get request returning JSON object(s)
 * @param options: http options object
 * @param callback: callback to pass the results JSON object(s) back
 */
exports.getJSON = function(options, onResult)
{
    console.log("rest::getJSON");

    var port = options.port == 443 ? https : http;
    var req = port.request(options, function(res)
    {
        var output = '';
        console.log(options.host + ':' + res.statusCode);
        res.setEncoding('utf8');

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

        res.on('end', function() {
            var obj = JSON.parse(output);
            onResult(res.statusCode, obj);
        });
    });

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

    req.end();
};

通过创建选项对象来调用它，例如：

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

并提供回调函数 .

例如，在服务中，我需要上面的其余模块，然后执行此操作 .

rest.getJSON(options, function(statusCode, result) {
    // I could work with the result html/json here.  I could also just return it
    console.log("onResult: (" + statusCode + ")" + JSON.stringify(result));
    res.statusCode = statusCode;
    res.send(result);
});

更新：

如果你正在寻找async await（线性无回调），promises，编译时支持和intellisense，我们创建一个适合该账单的轻量级http和rest客户端：

Microsoft typed-rest-client

回复于 2024-05-02T08:24:51+08:00

尝试在node.js中使用简单的http.get(options, callback) function：

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) function，它允许您指定请求方法和其他请求详细信息 .

回复于 2024-05-02T08:24:51+08:00

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
});

回复于 2024-05-02T08:24:51+08:00

您还可以使用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();
  }
);

回复于 2024-05-02T08:24:51+08:00

Unirest是我想要成为多平台框架的最佳库，因此如果您需要在Ruby，PHP，Java，Python，Objective C，.Net或Windows上使用HTTP客户端，那么了解它如何在Node上工作将很有用 . 8也是 . 据我所知，unirest库主要由现有的HTTP客户端支持（例如在Java，Apache HTTP客户端，在Node上，Mikeal's Request libary） - Unirest只是将更好的API放在首位 .

以下是Node.js的几个代码示例：

var unirest = require('unirest')

// GET a resource
unirest.get('http://httpbin.org/get')
  .query({'foo': 'bar'})
  .query({'stack': 'overflow'})
  .end(function(res) {
    if (res.error) {
      console.log('GET error', res.error)
    } else {
      console.log('GET response', res.body)
    }
  })

// POST a form with an attached file
unirest.post('http://httpbin.org/post')
  .field('foo', 'bar')
  .field('stack', 'overflow')
  .attach('myfile', 'examples.js')
  .end(function(res) {
    if (res.error) {
      console.log('POST error', res.error)
    } else {
      console.log('POST response', res.body)
    }
  })

你可以直接跳到Node docs here

回复于 2024-05-02T08:24:51+08:00

30

看看shred . 它是由spire.io创建和维护的节点HTTP客户端，用于处理重定向，会话和JSON响应 . 它非常适合与其他API交互 . 有关详细信息，请参阅this blog post .

回复于 2024-05-02T08:24:51+08:00
64

看看httpreq：这是我创建的节点库，因为我很沮丧，那里没有简单的http GET或POST模块;-)

回复于 2024-05-02T08:24:51+08:00

此版本基于最初由bryanmac函数提出的函数，它使用promises，更好的错误处理，并在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(({status, data}) => {
        res.json(data);
    }, (error) => {
        next(error);
    });
});

出错时，它将错误委托给服务器错误处理中间件 .

回复于 2024-05-02T08:24:51+08:00

如果您只需要进行简单的get请求而不需要支持任何其他HTTP方法，请查看：simple-get：

var get = require('simple-get');

get('http://example.com', function (err, res) {
  if (err) throw err;
  console.log(res.statusCode); // 200
  res.pipe(process.stdout); // `res` is a stream
});

回复于 2024-05-02T08:24:51+08:00

-1

看看请求模块 . 请参考这里http://www.sitepoint.com/making-http-requests-in-node-js/

回复于 2024-05-02T08:24:51+08:00

189

使用reqclient：不是为 request 或许多其他库的脚本目的而设计的 . 当你需要一次又一次地重复使用相同的配置时，Reqclient允许在构造函数中指定许多有用的配置：基本URL，头，auth选项，日志选项，缓存等 . 还有一些有用的功能，如查询和URL解析，自动查询编码和JSON解析等

使用该库的最佳方法是创建一个模块来导出指向API的对象以及连接所需的配置：

模块 client.js ：

let RequestClient = require("reqclient").RequestClient

let client = new RequestClient({
  baseUrl: "https://myapp.com/api/v1",
  cache: true,
  auth: {user: "admin", pass: "secret"}
})

module.exports = client

在需要使用API的控制器中使用如下：

let client = require('client')
//let router = ...

router.get('/dashboard', (req, res) => {
  // Simple GET with Promise handling to https://myapp.com/api/v1/reports/clients
  client.get("reports/clients")
    .then(response => {
       console.log("Report for client", response.userId)  // REST responses are parsed as JSON objects
       res.render('clients/dashboard', {title: 'Customer Report', report: response})
    })
    .catch(err => {
      console.error("Ups!", err)
      res.status(400).render('error', {error: err})
    })
})

router.get('/orders', (req, res, next) => {
  // GET with query (https://myapp.com/api/v1/orders?state=open&limit=10)
  client.get({"uri": "orders", "query": {"state": "open", "limit": 10}})
    .then(orders => {
      res.render('clients/orders', {title: 'Customer Orders', orders: orders})
    })
    .catch(err => someErrorHandler(req, res, next))
})

router.delete('/orders', (req, res, next) => {
  // DELETE with params (https://myapp.com/api/v1/orders/1234/A987)
  client.delete({
    "uri": "orders/{client}/{id}",
    "params": {"client": "A987", "id": 1234}
  })
  .then(resp => res.status(204))
  .catch(err => someErrorHandler(req, res, next))
})

reqclient 支持许多功能，但它有一些其他库不支持：OAuth2 integration和logger与cURL syntax集成，并始终返回本机Promise对象 .

回复于 2024-05-02T08:24:51+08:00

## you can use request module and promise in express to make any request ##
const promise                       = require('promise');
const requestModule                 = require('request');

const curlRequest =(requestOption) =>{
    return new Promise((resolve, reject)=> {
        requestModule(requestOption, (error, response, body) => {
            try {
                if (error) {
                    throw error;
                }
                if (body) {

                    try {
                        body = (body) ? JSON.parse(body) : body;
                        resolve(body);
                    }catch(error){
                        resolve(body);
                    }

                } else {

                    throw new Error('something wrong');
                }
            } catch (error) {

                reject(error);
            }
        })
    })
};

const option = {
    url : uri,
    method : "GET",
    headers : {

    }
};


curlRequest(option).then((data)=>{
}).catch((err)=>{
})

回复于 2024-05-02T08:24:51+08:00

Node.js Express中的HTTP GET请求

12 回答

相关问题