请教下async/await如何应用在http.request的业务中？

我自己也封装了一个，可以参考下。 https://github.com/LeoHughes/InterfaceProxy

考虑下这个？ https://github.com/request/request-promise-native

@wldlzt 你的node不是v8版本吗？v8.*才有 promisify方法在util里

原生模块用起来比较麻烦... 优先考虑 fetch request(promisify 版本) urllib 等

请直接使用 httpx、urllib 之类的模块。

@bs32g1038 谢谢谢谢代码没问题，但我发现业务上是我自己设计思路搞错了....

@wldlzt 示例代码：

const http = require('http')
const options = {
    hostname: 'cnodejs.org',
    port: 80,
    path: '/',
    method: 'get'
};
let request = function(options) {
    // 注意返回promise对象
    return new Promise((resolve, reject) => {
        const req = http.request(options, (res) => {
            let ret = '';
            res.on('data', buffer => { ret += buffer.toString() });
            res.on('end', () => resolve(ret));
        });
        req.on('error', (e) => reject(e));
        req.end();
    });
};

(async () => {
    console.log(await request(options))
})();

@fantasticsoul 谢谢您先~~~~ret是我定义少了....然后您发的代码我试运行了一下，是报promisify(...)(...) is not a function的错误，当然我也去了解了promisify的用法，正在摸索中，您发的代码是少了什么吗？

貌似你的代码有问题，ret在哪里定义过？

var http = require('http');
var util = require('util');
const request = util.promisify(function(post_option, cb){
	var post_req = http.request(post_option, function(resa){
		let ret = '';//这里考虑用数组，然后 Buffer.concat(array)会比较好，先沿用你的写法
		resa.on(‘data’, buffer=>{ret += buffer.toString()});
		resa.on(‘end’,()=>cb(null,ret));
		resa.on('error',(err)=>cb(err))
	});
	post_req.write(post_data);
	post_req.end();
})

(async ()=>{
	const ret = await request(post_option);//your post_option
	console.log(ret);
})()

@bs32g1038 不好意思，用上Promise还是无法直接封装函数并返回请求结果，有没办法只用async/await的呢？

@bs32g1038 谢谢，可以~~~

这样是否能够满足你的需求呢？

let p = new Promise((resolve, reject)=>{
    var post_req = http.request(post_option, function(resa){
        resa.on(‘data’, function(buffer){
            ret += buffer.toString();
        });
        resa.on(‘end’, function(){
            return resolve(ret);
        });
        });
        post_req.write(post_data);
        post_req.end();
        //...err reject(err)
})
// await p 获取ret

来自于 bs32g1038 LIZCBLOG博客