首页 >> js开发 >> JavaScriptnodejs实现的http、https 请求封装操作示例
JavaScriptnodejs实现的http、https 请求封装操作示例
发布时间: 2021年1月13日 | 浏览:
| 分类:js开发
本文实例讲述了nodejs实现的http、https 请求封装操作。分享给大家供大家参考，具体如下：libs/request.js
const URL = require('url');
const zlib = require('zlib');
const http = require('http');
const https = require('https');
const qs = require('querystring');
function Request(cookie) {
this.cookies = [];
if (cookie !== undefined) {
this.setCookie(cookie);
}
}
Request.prototype.getHeaders = function(host, postData) {
let headers = {
'Host': host,
'Pragma': 'no-cache',
'Connection': 'keep-alive',
'Cache-Control': 'no-cache',
'Content-Type': 'application/x-www-form-urlencoded',
'Accept-Language': 'zh-CN,zh;q=0.8,en;q=0.6,zh-TW;q=0.4,es;q=0.2',
'Accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,*/*;q=0.8',
'User-Agent': 'Mozilla/5.0 (iPhone; CPU iPhone OS 9_1 like Mac OS X) AppleWebKit/601.1.46 (KHTML, like Gecko) Version/9.0 Mobile/13B143 Safari/601.1',
};
if (this.cookies.length) {
headers.Cookie = this.cookies.join('; ');
}
if (postData != '') {
headers['Content-Length'] = Buffer.byteLength(postData);
}
return headers;
}
Request.prototype.setCookie = function(cookie) {
let cookies = cookie.split(';');
for (let c of cookies) {
c = c.replace(/^\s/, '');
this.cookies.push(c);
}
return this;
}
Request.prototype.request = function(method, url, params) {
let postData = qs.stringify(params || {});
let urlObj = URL.parse(url);
let protocol = urlObj.protocol;
let options = {
hostname: urlObj.host,
port: urlObj.port,
path: urlObj.path,
method: method,
headers: this.getHeaders(urlObj.host, postData),
};
return new Promise((resolve, reject) => {
let req = (protocol == 'http:' ? http : https).request(options, (res) => {
let chunks = [];
res.on('data', (data) => {
chunks.push(data);
});
res.on('end', () => {
let buffer = Buffer.concat(chunks);
let encoding = res.headers['content-encoding'];
if (encoding == 'gzip') {
zlib.gunzip(buffer, function(err, decoded) {
resolve(decoded.toString());
});
} else if (encoding == 'deflate') {
zlib.inflate(buffer, function(err, decoded) {
resolve(decoded.toString());
});
} else {
resolve(buffer.toString());
}
});
});
req.on('error', (e) => {
reject(e);
});
if (postData != '') {
req.write(postData);
}
req.end();
})
}
Request.prototype.get = function(url) {
return this.request('GET', url, null);
}
Request.prototype.post = function(url, params) {
return this.request('POST', url, params);
}
module.exports = function(cookie) {
return new Request(cookie);
}
const URL = require('url');
const zlib = require('zlib');
const http = require('http');
const https = require('https');
const qs = require('querystring');
function Request(cookie) {
this.cookies = [];
if (cookie !== undefined) {
this.setCookie(cookie);
}
}
Request.prototype.getHeaders = function(host, postData) {
let headers = {
'Host': host,
'Pragma': 'no-cache',
'Connection': 'keep-alive',
'Cache-Control': 'no-cache',
'Content-Type': 'application/x-www-form-urlencoded',
'Accept-Language': 'zh-CN,zh;q=0.8,en;q=0.6,zh-TW;q=0.4,es;q=0.2',
'Accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,*/*;q=0.8',
'User-Agent': 'Mozilla/5.0 (iPhone; CPU iPhone OS 9_1 like Mac OS X) AppleWebKit/601.1.46 (KHTML, like Gecko) Version/9.0 Mobile/13B143 Safari/601.1',
};
if (this.cookies.length) {
headers.Cookie = this.cookies.join('; ');
}
if (postData != '') {
headers['Content-Length'] = Buffer.byteLength(postData);
}
return headers;
}
Request.prototype.setCookie = function(cookie) {
let cookies = cookie.split(';');
for (let c of cookies) {
c = c.replace(/^\s/, '');
this.cookies.push(c);
}
return this;
}
Request.prototype.request = function(method, url, params) {
let postData = qs.stringify(params || {});
let urlObj = URL.parse(url);
let protocol = urlObj.protocol;
let options = {
hostname: urlObj.host,
port: urlObj.port,
path: urlObj.path,
method: method,
headers: this.getHeaders(urlObj.host, postData),
};
return new Promise((resolve, reject) => {
let req = (protocol == 'http:' ? http : https).request(options, (res) => {
let chunks = [];
res.on('data', (data) => {
chunks.push(data);
});
res.on('end', () => {
let buffer = Buffer.concat(chunks);
let encoding = res.headers['content-encoding'];
if (encoding == 'gzip') {
zlib.gunzip(buffer, function(err, decoded) {
resolve(decoded.toString());
});
} else if (encoding == 'deflate') {
zlib.inflate(buffer, function(err, decoded) {
resolve(decoded.toString());
});
} else {
resolve(buffer.toString());
}
});
});
req.on('error', (e) => {
reject(e);
});
if (postData != '') {
req.write(postData);
}
req.end();
})
}
Request.prototype.get = function(url) {
return this.request('GET', url, null);
}
Request.prototype.post = function(url, params) {
return this.request('POST', url, params);
}
module.exports = function(cookie) {
return new Request(cookie);
}
test.js
const request = require('./request')();
(async function() {
let res = await request.get('http://www.axita.com.cn/');
console.log(res);
})();
const request = require('./request')();
(async function() {
let res = await request.get('http://www.axita.com.cn/');
console.log(res);
})();
执行命令
nodemon test.js
nodemon test.js
希望本文所述对大家node.js程序设计有所帮助。
const URL = require('url');
const zlib = require('zlib');
const http = require('http');
const https = require('https');
const qs = require('querystring');
function Request(cookie) {
this.cookies = [];
if (cookie !== undefined) {
this.setCookie(cookie);
}
}
Request.prototype.getHeaders = function(host, postData) {
let headers = {
'Host': host,
'Pragma': 'no-cache',
'Connection': 'keep-alive',
'Cache-Control': 'no-cache',
'Content-Type': 'application/x-www-form-urlencoded',
'Accept-Language': 'zh-CN,zh;q=0.8,en;q=0.6,zh-TW;q=0.4,es;q=0.2',
'Accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,*/*;q=0.8',
'User-Agent': 'Mozilla/5.0 (iPhone; CPU iPhone OS 9_1 like Mac OS X) AppleWebKit/601.1.46 (KHTML, like Gecko) Version/9.0 Mobile/13B143 Safari/601.1',
};
if (this.cookies.length) {
headers.Cookie = this.cookies.join('; ');
}
if (postData != '') {
headers['Content-Length'] = Buffer.byteLength(postData);
}
return headers;
}
Request.prototype.setCookie = function(cookie) {
let cookies = cookie.split(';');
for (let c of cookies) {
c = c.replace(/^\s/, '');
this.cookies.push(c);
}
return this;
}
Request.prototype.request = function(method, url, params) {
let postData = qs.stringify(params || {});
let urlObj = URL.parse(url);
let protocol = urlObj.protocol;
let options = {
hostname: urlObj.host,
port: urlObj.port,
path: urlObj.path,
method: method,
headers: this.getHeaders(urlObj.host, postData),
};
return new Promise((resolve, reject) => {
let req = (protocol == 'http:' ? http : https).request(options, (res) => {
let chunks = [];
res.on('data', (data) => {
chunks.push(data);
});
res.on('end', () => {
let buffer = Buffer.concat(chunks);
let encoding = res.headers['content-encoding'];
if (encoding == 'gzip') {
zlib.gunzip(buffer, function(err, decoded) {
resolve(decoded.toString());
});
} else if (encoding == 'deflate') {
zlib.inflate(buffer, function(err, decoded) {
resolve(decoded.toString());
});
} else {
resolve(buffer.toString());
}
});
});
req.on('error', (e) => {
reject(e);
});
if (postData != '') {
req.write(postData);
}
req.end();
})
}
Request.prototype.get = function(url) {
return this.request('GET', url, null);
}
Request.prototype.post = function(url, params) {
return this.request('POST', url, params);
}
module.exports = function(cookie) {
return new Request(cookie);
}
const URL = require('url');
const zlib = require('zlib');
const http = require('http');
const https = require('https');
const qs = require('querystring');
function Request(cookie) {
this.cookies = [];
if (cookie !== undefined) {
this.setCookie(cookie);
}
}
Request.prototype.getHeaders = function(host, postData) {
let headers = {
'Host': host,
'Pragma': 'no-cache',
'Connection': 'keep-alive',
'Cache-Control': 'no-cache',
'Content-Type': 'application/x-www-form-urlencoded',
'Accept-Language': 'zh-CN,zh;q=0.8,en;q=0.6,zh-TW;q=0.4,es;q=0.2',
'Accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,*/*;q=0.8',
'User-Agent': 'Mozilla/5.0 (iPhone; CPU iPhone OS 9_1 like Mac OS X) AppleWebKit/601.1.46 (KHTML, like Gecko) Version/9.0 Mobile/13B143 Safari/601.1',
};
if (this.cookies.length) {
headers.Cookie = this.cookies.join('; ');
}
if (postData != '') {
headers['Content-Length'] = Buffer.byteLength(postData);
}
return headers;
}
Request.prototype.setCookie = function(cookie) {
let cookies = cookie.split(';');
for (let c of cookies) {
c = c.replace(/^\s/, '');
this.cookies.push(c);
}
return this;
}
Request.prototype.request = function(method, url, params) {
let postData = qs.stringify(params || {});
let urlObj = URL.parse(url);
let protocol = urlObj.protocol;
let options = {
hostname: urlObj.host,
port: urlObj.port,
path: urlObj.path,
method: method,
headers: this.getHeaders(urlObj.host, postData),
};
return new Promise((resolve, reject) => {
let req = (protocol == 'http:' ? http : https).request(options, (res) => {
let chunks = [];
res.on('data', (data) => {
chunks.push(data);
});
res.on('end', () => {
let buffer = Buffer.concat(chunks);
let encoding = res.headers['content-encoding'];
if (encoding == 'gzip') {
zlib.gunzip(buffer, function(err, decoded) {
resolve(decoded.toString());
});
} else if (encoding == 'deflate') {
zlib.inflate(buffer, function(err, decoded) {
resolve(decoded.toString());
});
} else {
resolve(buffer.toString());
}
});
});
req.on('error', (e) => {
reject(e);
});
if (postData != '') {
req.write(postData);
}
req.end();
})
}
Request.prototype.get = function(url) {
return this.request('GET', url, null);
}
Request.prototype.post = function(url, params) {
return this.request('POST', url, params);
}
module.exports = function(cookie) {
return new Request(cookie);
}
test.js
const request = require('./request')();
(async function() {
let res = await request.get('http://www.axita.com.cn/');
console.log(res);
})();
const request = require('./request')();
(async function() {
let res = await request.get('http://www.axita.com.cn/');
console.log(res);
})();
执行命令
nodemon test.js
nodemon test.js
希望本文所述对大家node.js程序设计有所帮助。
刚刚发布热门点击发布时间
- [07/09]Chrome抓取页面内容代码|chrome插件获取页面数据
- [07/09]谷歌浏览器数据采集插件开发|谷歌浏览器的采集功能
- [07/09]Chrome插件轻松抓取网络数据,Chrome插件轻松抓取网页源码数据
- [07/09]chrome插件怎么安装?chrome插件开发如何安装chrome插件
- [07/09]快速chrome插件开发-北京chrome插件开发外包
- [12/31]清大光德落地护眼灯|清大光德儿童护眼灯
- [07/20]网站无障碍适老化外包改造私有化过程遇到问题整理
- [07/19]适老化改造工信部明确APP适老化规范：禁广告弹窗，网站需提供特大字体
- [07/19]适老化改造包括哪些方面?
- [07/19]什么是适老化改造？
- [07/19]适老化与信息无障碍是什么关系，二者有何异同？
- [07/19]网站如何进行适老化改造？
- [07/12]老年群体面临“数字鸿沟” 数字化网站适老化改造服务彰显人文关怀
- [07/12]数字适老化改造方案 老龄群体数字化改造受关注
- [07/11]什么是重绘?什么是回流?常见引起回流属性和方法：
