node.js中使用http模块创建服务器和客户端

const http = require(‘http‘);//创建一个http服务器let server = http.createServer();//监听端口server.listen(8888, ‘0.0.0.0‘);//设置超时时间server.setTimeout(2 * 60 * 1000);//服务器监听时触发server.on(‘listening‘, function () { ???console.log(‘监听开始‘);});//接收到客户端请求时触发server.on(‘request‘, function (req, res) { ???//req表示客户端请求对象，是http.IncomingMessage类的实例，可读流。 ???//res表示服务端响应对象，是http.ServerResponse类的实例，可写流。 ???//请求方法 ???console.log(req.method); ???//请求url ???console.log(req.url); ???//请求的头信息 ???console.log(req.headers); ???//请求的http版本 ???console.log(req.httpVersion); ???//请求对象的socket对象 ???console.log(req.socket); ???res.end(‘hello‘);});//连接建立时触发server.on(‘connection‘, function (socket) { ???console.log(‘建立连接‘);});//客户端向服务器发送CONNECT请求时触发server.on(‘connect‘, function (req, socket, head) { ???console.log(‘客户端connect‘);});//服务器关闭时触发，调用 close() 方法。server.on(‘close‘, function () { ???console.log(‘服务器关闭‘);});//发生错误时触发server.on(‘error‘, function (err) { ???console.log(err);});//如果连接超过指定时间没有响应，则触发。//超时后，不可再复用已建立的连接，需发请求重新建立连接server.on(‘timeout‘, function (socket) { ???console.log(‘连接已超时‘);});

const http = require(‘http‘);const url = require(‘url‘);//创建一个http服务器let server = http.createServer();//监听端口server.listen(8888, ‘0.0.0.0‘);//接收到客户端请求时触发server.on(‘request‘, function (req, res) { ???//解析url返回一个url对象 ???//如果参数二设为true，则url对象中的query属性将通过querystring.parse()生成一个对象 ???let params = url.parse(req.url, true); ???//完整url地址 ???console.log(‘href‘, params.href); ???//主机名，包含端口 ???console.log(‘host‘, params.host); ???//主机名，不包含端口 ???console.log(‘hostname‘, params.hostname); ???//端口 ???console.log(‘port‘, params.port); ???//协议 ???console.log(‘protocol‘, params.protocol); ???//路径，包含查询字符串 ???console.log(‘path‘, params.path); ???//路径，不包含查询字符串 ???console.log(‘pathname‘, params.pathname); ???//查询字符串，不包含 ? ???console.log(‘query‘, params.query); ???//查询字符串，包含 ? ???console.log(‘search‘, params.search); ???//散列字符串，包含 # ???console.log(‘hash‘, params.hash); ???res.end(‘end‘);});

const http = require(‘http‘);const url = require(‘url‘);//创建一个http服务器let server = http.createServer();//监听端口server.listen(8888, ‘0.0.0.0‘);//接收到客户端请求时触发server.on(‘request‘, function (req, res) { ???//设置响应头信息 ???res.setHeader(‘Content-Type‘, ‘text/html;charset=utf-8‘); ???//获取响应头信息 ???res.getHeader(‘Content-Encoding‘); ???res.setHeader(‘test‘, ‘test‘); ???//删除响应头信息 ???res.removeHeader(‘test‘); ???//判断响应头是否已发送 ???console.log(res.headersSent ? ‘已发送‘ : ‘未发送‘); ???//注意writeHead()与setHeader()的区别，setHeader()并不会立即发送响应头。 ???//而writeHead()会发送，writeHead()设置的响应头比setHeader()的优先。 ???res.writeHead(200, { ???????‘aaa‘: ‘aaa‘ ???}); ???//判断响应头是否已发送 ???console.log(res.headersSent ? ‘已发送‘ : ‘未发送‘); ???//如何不发送日期 Date，设置为false将不发送Date ???res.sendDate = false; ???//设置响应的超时时间 ???res.setTimeout(30 * 1000); ???res.on(‘timeout‘, function () { ???????console.log(‘响应超时‘); ???}); ???//向客户端发送数据 ???//由于res响应对象也是一个流，所以可以使用write()来写数据 ???res.write(Buffer.from(‘你好‘)); ???res.write(Buffer.from(‘欢迎‘)); ???res.end(‘end‘);});

const http = require(‘http‘);const zlib = require(‘zlib‘);let client = http.request({ ???//协议 ???‘protocol‘: ‘http:‘, ???//主机名或IP ???‘hostname‘: ‘www.baidu.com‘, ???//端口 ???‘port‘: 80, ???//请求方式 ???‘method‘: ‘GET‘, ???//请求路径和查询字符串 ???‘path‘: ‘/‘, ???//请求头对象 ???‘headers‘: { ???????‘Accept-Encoding‘: ‘gzip, deflate, br‘ ???}, ???//超时时间 ???‘timeout‘: 2 * 60 * 1000});//发送请求client.end();//响应被接收到时触发client.on(‘response‘, function (res) { ???console.log(‘状态吗:‘ + res.statusCode); ???console.log(‘响应头:‘ + JSON.stringify(res.headers)); ???//头信息的名称为小写 ???let encoding = res.headers[‘content-encoding‘]; ???//判断响应头中的内容编码，是否有过压缩，如果有则进行解压 ???if (encoding.match(/\bgzip\b/)) { ???????res.pipe(zlib.createGunzip()).pipe(process.stdout); ???} else if (encoding.match(/\bdeflate\b/)) { ???????res.pipe(zlib.createInflate()).pipe(process.stdout); ???} else { ???????res.pipe(process.stdout); ???}});//请求过程中出错了触发client.on(‘error‘, function (err) { ???console.log(err);});//当 socket 被分配到请求后触发client.on(‘socket‘, function (socket) { ???socket.setTimeout(2 * 60 * 1000); ???socket.on(‘timeout‘, function () { ???????//终止本次请求 ???????client.abort() ???});});

const http = require(‘http‘);//会自动调用 req.end()，默认为 get 请求。http.get(‘http://www.baidu.com‘, function (res) { ???res.on(‘data‘, function (data) { ???????console.log(data.toString()); ???});});