NodeJS创建HTTP、HTTPS服务器与客户端

来源 | https://blog.csdn.net/ligang2585116/article/details/72827781

超文本传输协议&＃xff08;HTTP&＃xff0c;HyperText Transfer Protocol)是互联网上应用最为广泛的一种网络协议。所有的WWW文件都必须遵守这个标准。设计HTTP最初的目的是为了提供一种发布和接收HTML页面的方法。其属于下图七层网路协议的“应用层”。

HTTP服务器

创建HTTP服务器

创建服务

方式一&＃xff1a;回调方式

var server &＃61; http.createServer((request, response) &＃61;> { // 接受客户端请求时触发 ...
});
server.listen(10000, &＃39;localhost&＃39;, 511, () &＃61;> { // 开始监听 ...
});

方式二&＃xff1a;事件监听方式

var server &＃61; http.createServer();
// 接受客户端请求时触发
server.on(&＃39;request&＃39;, (request, rsponse) &＃61;> { ...
});
server.listen(10000, &＃39;localhost&＃39;, 511);
// 开始监听
server.on(&＃39;listening&＃39;, () &＃61;> { ...
});

注意&＃xff1a;

• server.listen(port, [host], [backlog], [callback])中的backlog参数为整数&＃xff0c;指定位于等待队列中客户端连接的最大数量&＃xff0c;一旦超过这个长度&＃xff0c;HTTP服务器将开始拒绝来自新客户端的连接&＃xff0c;默认值为511。

• 在HTTP请求服务器时&＃xff0c;会发送两次请求。一次是用户发出请求&＃xff0c;另一次是浏览器为页面在收藏夹中的显示图标&＃xff08;默认为favicon.ico&＃xff09;而自动发出的请求。

关闭服务器

server.close();
// 服务器关闭时会触发close事件
server.on(&＃39;close&＃39;, () &＃61;> {...});

超时

server.setTimeout(60 * 1000, () &＃61;> { console.log(&＃39;超时了&＃39;);
});
// 或者通过事件形式
server.setTimeout(60 * 1000);
server.on(&＃39;timeout&＃39;, () &＃61;> {...});

注意&＃xff1a;默认超时时间为2分钟

错误

server.on(&＃39;error&＃39;, (e) &＃61;> { if(e.code &＃61;&＃61;&＃61; &＃39;EADDRINUSE&＃39;) { // 端口被占用 }
});

获取客户端请求信息

当从客户端请求流中读取到数据时会触发data事件&＃xff0c;当读取完客户端请求流中的数据时触发end事件。

Get请求

server.on(&＃39;request&＃39;, (request, response) &＃61;> { if(request.url !&＃61;&＃61; &＃39;/favicon.ico&＃39;) { /* Get请求 */ var params &＃61; url.parse(req.url, true).query; // 或者 // var params &＃61; querystring.parse(url.parse(request.url).query); // 根据参数做处理 // ... // 结束请求 response.end(); }
});

Post请求

server.on(&＃39;request&＃39;, (request, response) &＃61;> { request.setEncoding(&＃39;utf-8&＃39;); if(request.url !&＃61;&＃61; &＃39;/favicon.ico&＃39;) { let result &＃61; &＃39;&＃39;; request.on(&＃39;data&＃39;, (data) &＃61;> { result &＃43;&＃61; data; }); request.on(&＃39;end&＃39;, () &＃61;> { var params &＃61; JSON.parse(postData); console.log(&＃96;数据接收完毕&＃xff1a;${result}&＃96;); }); // 结束本次请求 response.end(); } // 结束本次请求 response.end(JSON.stringify({status: &＃39;success&＃39;}));
});

转换URL字符串与查询字符串

querystring模块&＃xff1a;转换URL中的查询字符串&＃xff08;URL中?之后&＃xff0c;#之前&＃xff09;

querystring.stringify(obj, [sep], [eq])
querystring.parse(str, [sep], [eq], [option])

sep&＃xff1a;分割符&＃xff0c;默认&

eq&＃xff1a;分配字符&＃xff0c;默认&＃61;

options&＃xff1a;{maxKeys: number}指定转换后对象中的属性个数
let str &＃61; querystring.stringify({name: &＃39;ligang&＃39;, age: 27});
console.log(str); // name&＃61;ligang&age&＃61;27
let obj &＃61; querystring.parse(str);
console.log(obj); // { name: &＃39;ligang&＃39;, age: &＃39;27&＃39; }

url模块&＃xff1a;转换完整URL字符串

url.parse(urlStr, [parseQueryString])

parseQueryString&＃xff1a;如果为true&＃xff0c;将查询字符通过querystring转换为对象&＃xff1b;默认false。

url.resolve(from, to);

将二者结合成一个路径&＃xff0c;from、to既可以是相对路径也可以是绝对路径。

// http://ligangblog.com/Javascript/a?a&＃61;1
url.resolve(&＃39;http://ligangblog.com/Javascript/&＃39;, &＃39;a?a&＃61;1&＃39;);
// http://ligangblog.com/a?a&＃61;1
url.resolve(&＃39;http://ligangblog.com/Javascript/&＃39;, &＃39;/a?a&＃61;1&＃39;);

注意&＃xff1a;具体合并规则&＃xff0c;请查看《Node权威指南》— 8.1HTTP服务器。

var urlStr &＃61; &＃39;http://ligangblog.com/Javascript/?name&＃61;lg&uid&＃61;1#a/b/c&＃39;;
console.log(url.parse(urlStr, true));
/*
Url { protocol: &＃39;http:&＃39;, slashes: true, auth: null, host: &＃39;ligangblog.com&＃39;, port: null, hostname: &＃39;ligangblog.com&＃39;, hash: &＃39;#a/b/c&＃39;, search: &＃39;?name&＃61;lg&uid&＃61;1&＃39;, query: { name: &＃39;lg&＃39;, uid: &＃39;1&＃39; }, pathname: &＃39;/Javascript/&＃39;, path: &＃39;/Javascript/?name&＃61;lg&uid&＃61;1&＃39;, href: &＃39;http://ligangblog.com/Javascript/?name&＃61;lg&uid&＃61;1#a/b/c&＃39;
}
*/

发送服务器端响应流

response.writeHead(statusCode, [reasonPhrase], [headers]);
// 或者
response.setHeader(name, value);

响应头中包含的一些常用字段&＃xff1a;

示例&＃xff1a;

response.writeHead(200, {&＃39;Content-Type&＃39;: &＃39;text/plain&＃39;, &＃39;Access-Control-Allow-Origin&＃39;: &＃39;http://localhost&＃39;});
// 或者
response.statusCode &＃61; 200;
response.setHeader(&＃39;Content-Type&＃39;, &＃39;text/plain&＃39;);
response.setHeader(&＃39;Access-Control-Allow-Origin&＃39;, &＃39;http://localhost&＃39;);

writeHead和setHeader区别&＃xff1a;

writeHead&＃xff1a;该方法被调用时发送响应头

setHeader&＃xff1a;write方法第一次被调用时发送响应头

/* 获取响应头中的某个字段值 */
response.getHeader(name);
/* 删除一个响应字段值 */
response.removeHeader(name);
/* 该属性表示响应头是否已发送 */
response.headersSent;
/* 在响应数据的尾部增加一个头信息 */
response.addTrailers(headers);

示例&＃xff1a;

// 必须再响应头中添加Trailer字段&＃xff0c;并且其值设置为追加的响应头中所指定的字段名
response.write(200, {&＃39;Content-Type&＃39;: &＃39;text/plain&＃39;, &＃39;Trailer&＃39;: &＃39;Content-MD5&＃39;});
response.write(&＃39;....&＃39;);
response.addTrailers({&＃39;Content-MD5&＃39;, &＃39;...&＃39;});
response.end();

特别说明&＃xff1a;

当再快速网路且数据量很小的情况下&＃xff0c;Node将数据直接发送到操作系统内核缓存区中&＃xff0c;然后从该内核缓存区中取出数据发送给请求方&＃xff1b;如果网速很慢或者数据量很大&＃xff0c;Node通常会将数据缓存在内存中&＃xff0c;在对方可以接受数据的情况下将内存中的数据通过操作系统内核缓存区发送给请求方。

response.write返回true&＃xff0c;说明直接写到了操作系统内核缓存区中&＃xff1b;返回false&＃xff0c;说明暂时缓存的内存中。每次需要通过调用response.end()来结束响应。

响应超时会触发timeout事件&＃xff1b;response.end()方法调用之前&＃xff0c;如果连接中断&＃xff0c;会触发close事件。

/* 设置请求超时时间2分钟 */
response.setTimeout(2 * 60 * 1000, () &＃61;> { console.error(&＃39;请求超时&＃xff01;&＃39;);
});
// 或者
response.setTimout(2 * 60 * 1000);
response.on(&＃39;timeout&＃39;, () &＃61;> { console.error(&＃39;请求超时&＃xff01;&＃39;);
});
/* 连接中断 */
response.on(&＃39;close&＃39;, () &＃61;> { console.error(&＃39;连接中断&＃xff01;&＃39;);
});

/** * HTTP服务端 * Created by ligang on 17/5/28. */
import http from &＃39;http&＃39;;
var server &＃61; http.createServer();
// 接受客户端请求时触发
server.on(&＃39;request&＃39;, (request, response) &＃61;> { if(request.url !&＃61;&＃61; &＃39;/favicon.ico&＃39;) { response.setTimeout(2 * 60 * 1000, () &＃61;> { console.error(&＃39;请求超时&＃xff01;&＃39;); }); response.on(&＃39;close&＃39;, () &＃61;> { console.error(&＃39;请求中断&＃xff01;&＃39;); }); let result &＃61; &＃39;&＃39;; request.on(&＃39;data&＃39;, (data) &＃61;> { result &＃43;&＃61; data; }); request.on(&＃39;end&＃39;, () &＃61;> { console.log(&＃96;服务器数据接收完毕&＃xff1a;${result}&＃96;); response.statusCode &＃61; 200; response.write(&＃39;收到!&＃39;); response.end(); // 结束本次请求 }); }
});
server.listen(10000, &＃39;localhost&＃39;, 511);
// 开始监听
server.on(&＃39;listening&＃39;, () &＃61;> { console.log(&＃39;开始监听&＃39;);
});
server.on(&＃39;error&＃39;, (e) &＃61;> { if(e.code &＃61;&＃61;&＃61; &＃39;EADDRINUSE&＃39;) { console.log(&＃39;端口被占用&＃39;); }else { console.log(&＃96;发生错误&＃xff1a;${e.code}&＃96;); }
});

HTTP客户端

Node.js可以轻松向任何网站发送请求并读取网站的响应数据。

var req &＃61; http.request(options, callback);
// get请求
var req &＃61; http.get(options, callback);
// 向目标网站发送数据
req.write(chunk, [encoding]);
// 结束本次请求
req.end([chucnk], [encoding]);
// 中止本次请求
req.abort();

其中&＃xff0c;options用于指定目标URL地址&＃xff0c;如果该参数是一个字符串&＃xff0c;将自动使用url模块中的parse方法转换为一个对象。注意&＃xff1a;http.get()方法只能使用Get方式请求数据&＃xff0c;且无需调用req.end()方法&＃xff0c;Node.js会自动调用。

/** * HTTP客户端 * Created by ligang on 17/5/30. */
import http from &＃39;http&＃39;;
const options &＃61; { hostname: &＃39;localhost&＃39;, port: 10000, path: &＃39;/&＃39;, method: &＃39;post&＃39; }, req &＃61; http.request(options);
req.write(&＃39;你好&＃xff0c;服务器&＃39;);
req.end();
req.on(&＃39;response&＃39;, (res) &＃61;> { console.log(&＃96;状态码&＃xff1a;${res.statusCode}&＃96;); let result &＃61; &＃39;&＃39;; res.on(&＃39;data&＃39;, (data) &＃61;> { result &＃43;&＃61; data; }); res.on(&＃39;end&＃39;, () &＃61;> { console.log(&＃96;客户端接受到响应&＃xff1a;${result}&＃96;); })
});
req.setTimeout(60* 1000, () &＃61;> { console.log(&＃39;超时了&＃39;); req.abort();
});
req.on(&＃39;error&＃39;, (error) &＃61;> { if(error.code &＃61;&＃61;&＃61; &＃39;ECONNERSET&＃39;) { console.log(&＃39;socket端口超时&＃39;); }else { console.log(&＃96;发送错误&＃xff1a;${error.code}&＃96;); }
});

代理服务器

/** * HTTP代理 * Created by ligang on 17/5/30. */
import http from &＃39;http&＃39;;
import url from &＃39;url&＃39;;
/** * 服务端 */
const server &＃61; http.createServer(async (req, res) &＃61;> { // req.setEncoding(&＃39;utf-8&＃39;); /* 超时 2分钟 */ res.setTimeout(2 * 60 * 1000, () &＃61;> { // ... }); /* 连接中断 */ res.on(&＃39;close&＃39;, () &＃61;> { // ... }); let options &＃61; {}, result &＃61; ""; options &＃61; await new Promise((resolve, reject) &＃61;> { if(req.method &＃61;&＃61;&＃61; &＃39;GET&＃39;) { options &＃61; url.parse(&＃39;http://localhost:10000&＃39; &＃43; req.url); resolve(options); }else if(req.method &＃61;&＃61;&＃61; &＃39;POST&＃39;) { req.on(&＃39;data&＃39;, (data) &＃61;> { result &＃43;&＃61; data; }); req.on(&＃39;end&＃39;, () &＃61;> { options &＃61; url.parse(&＃39;http://localhost:10000&＃39; &＃43; req.url); // post请求必须制定 options.headers &＃61; { &＃39;content-type&＃39;: &＃39;application/json&＃39;, }; resolve(options); }); } }); options.method &＃61; req.method; let content &＃61; await clientHttp(options, result ? JSON.parse(result) : result); res.setHeader(&＃39;Content-Type&＃39;, &＃39;text/html&＃39;); res.write(&＃39;&＃39;) res.write(content); res.write(&＃39;&＃39;); // 结束本次请求 res.end();
});
server.listen(10010, &＃39;localhost&＃39;, 511);
/* 开始监听 */
server.on(&＃39;listening&＃39;, () &＃61;> { // ...
});
/* 监听错误 */
server.on(&＃39;error&＃39;, (e) &＃61;> { console.log(e.code); // ...
});
/** * 客户端 * &＃64;param options 请求参数 * &＃64;param data 请求数据 */
async function clientHttp(options, data) { let output &＃61; new Promise((resolve, reject) &＃61;> { let req &＃61; http.request(options, (res) &＃61;> { let result &＃61; &＃39;&＃39;; res.setEncoding(&＃39;utf8&＃39;); res.on(&＃39;data&＃39;, function (chunk) { result &＃43;&＃61; chunk; }); res.on(&＃39;end&＃39;, function () { resolve(result); }); }); req.setTimeout(60000, () &＃61;> { console.error(&＃96;连接后台超时 ${options.href}&＃96;); reject(); req.abort(); }); req.on(&＃39;error&＃39;, err &＃61;> { console.error(&＃96;连接后台报错 ${err}&＃96;); if (err.code &＃61;&＃61;&＃61; &＃39;ECONNRESET&＃39;) { console.error(&＃96;socket超时 ${options.href}&＃96;); } else { console.error(&＃96;连接后台报错 ${err}&＃96;); } reject(); req.abort(); }); // 存在请求数据&＃xff0c;发送请求数据 if (data) { req.write(JSON.stringify(data)); } req.end(); }); return await output;
}

注意&＃xff1a;

POST请求必须指定headers信息&＃xff0c;否则会报错socket hang up

获取到options后需要重新指定其methodoptions.method &＃61; req.method;

HTTPS服务器

• HTTPS使用https协议&＃xff0c;默认端口号44&＃xff1b;

• HTTPS需要向证书授证中心申请证书&＃xff1b;

• HTTPS服务器与客户端之间传输是经过SSL安全加密后的密文数据&＃xff1b;

创建公钥、私钥及证书

&＃xff08;1&＃xff09;创建私钥

openssl genrsa -out privatekey.pem 1024

&＃xff08;2&＃xff09;创建证书签名请求

openssl req -new -key privatekey.pem -out certrequest.csr

&＃xff08;3&＃xff09;获取证书&＃xff0c;线上证书需要经过证书授证中心签名的文件&＃xff1b;下面只创建一个学习使用证书

openssl x509 -req -in certrequest.csr -signkey privatekey.pem -out certificate.pem

&＃xff08;4&＃xff09;创建pfx文件

openssl pkcs12 -export -in certificate.pem -inkey privatekey.pem -out certificate.pfx

HTTPS服务

创建HTTPS服务器同HTTP服务器大致相同&＃xff0c;需要增加证书&＃xff0c;创建HTTPS服务器时通过options参数设置。

import https from &＃39;https&＃39;;
import fs from &＃39;fs&＃39;;
var pk &＃61; fs.readFileSync(&＃39;privatekey.pem&＃39;), pc &＃61; fs.readFileSync(&＃39;certificate.pem&＃39;);
var opts &＃61; { key: pk, cert: pc
};
var server &＃61; https.createServer(opts);

opts参数为一个对象&＃xff0c;用于指定创建HTTPS服务器时配置的各种选项&＃xff0c;下面只描述几个必要选项&＃xff1a;

HTTPS客户端

const options &＃61; { hostname: &＃39;localhost&＃39;, port: 1443, path: &＃39;/&＃39;, method: &＃39;post&＃39;, key: fs.readFileSync(&＃39;privatekey.pem&＃39;), cert: fs.readFileSync(&＃39;certificate.pem&＃39;), rejectUnhauthorized: false, agent: false // 从连接池中指定挑选一个当前连接状态为关闭的https.Agent }, req &＃61; https.request(options);
// 或者
const options &＃61; { hostname: &＃39;localhost&＃39;, port: 1443, path: &＃39;/&＃39;, method: &＃39;post&＃39;, key: fs.readFileSync(&＃39;privatekey.pem&＃39;), cert: fs.readFileSync(&＃39;certificate.pem&＃39;), rejectUnhauthorized: false, };
// 显示指定https.Agent对象
options.agent &＃61; new https.Agent(options);
var req &＃61; https.request(options);

说明&＃xff1a; 普通的 HTTPS 服务中&＃xff0c;服务端不验证客户端的证书&＃xff08;但是需要携带证书&＃xff09;&＃xff0c;中间人可以作为客户端与服务端成功完成 TLS 握手&＃xff1b; 但是中间人没有证书私钥&＃xff0c;无论如何也无法伪造成服务端跟客户端建立 TLS 连接。

当然如果你拥有证书私钥&＃xff0c;代理证书对应的 HTTPS 网站当然就没问题了&＃xff0c;所以这里的私钥和公钥只是格式书写&＃xff0c;没有太大意义&＃xff0c;只要将请求回来的数据原原本本交给浏览器来解析就算完成任务。