异步/等待 Node.js https.get

Question

我正在尝试使用 async / await 简化代码

但是在https.get使用 async / await 结构时有问题。

我知道如何使用第三方模块执行此操作，但更喜欢本机 node.jshttps模块。

下面的代码对我不起作用：

async function get_page() {

    const https = require('https')
    const url = 'https://example.com'

    const util = require('util')
    const https_get = util.promisify(https.get)

    const data = await https_get(url)

    do_awesome_things_with_data(data)
}

此代码工作正常：

function get_page() {

    const https = require('https')
    const url = 'https://example.com'

    let data = ''

    https.get(url, res => {

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

        res.on('end', () => {

           do_awesome_things_with_data(data)

        })
    }) 
}

Answer 1

https.get不会返回可以被承诺的东西，因为回调的签名不匹配(err, value)，所以你不能等待它。

但是，您可以https.get像这样将调用包装在 Promise 中，然后在调用时等待get_page

const https = require('https')

async function get_page() {
    const url = 'https://example.com'

    return new Promise((resolve) => {
        https.get(url, res => {

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

            res.on('end', () => {

               resolve(do_awesome_things_with_data(data));

            })
        }) 
    })
}

// usage

(async () => await get_page())()

编辑

我已经更新了我的答案，包括https.get不能被承诺并移动require('https')到函数调用之外的注释。

Answer 2

而不是承诺，推出自己的功能，或使用第 3 方库。Promise 无法包装https.get返回的内容。

// generic promise method for https
const requestPromise = ((urlOptions, data) => {
  return new Promise((resolve, reject) => {
    const req = https.request(urlOptions,
      (res) => {
        let body = '';
        res.on('data', (chunk) => (body += chunk.toString()));
        res.on('error', reject);
        res.on('end', () => {
          if (res.statusCode >= 200 && res.statusCode <= 299) {
            resolve({statusCode: res.statusCode, headers: res.headers, body: body});
          } else {
            reject('Request failed. status: ' + res.statusCode + ', body: ' + body);
          }
        });
      });
    req.on('error', reject);
    req.write(data, 'binary');
    req.end();
  });
});

然后像这样调用它：

async function get_page() {
    const url = 'https://example.com'
    const data = await requestPromise({url, method:'GET'})
    do_awesome_things_with_data(data)
}

或者简单地使用一个库，比如axios返回一个本地承诺，并处理额外的样板案例。