Node.js Stream(流)(三)
1、管道流
管道提供了一个数据从输出流到输入流的机制。
我们使用管道可以从一个流中获取数据并将数据传递到另外一个流中。
举例:复制文件
我们把文件比作装水的桶,而水就是文件里的内容,我们用一根管子 (pipe) 连接两个桶使得水从一个桶流入另一个桶,这样就慢慢的实现了大文件的复制过程。
var fs = require("fs"); // 创建一个可读流 var readerStream = fs.createReadStream('input.txt'); // 创建一个可写流 var writerStream = fs.createWriteStream('output.txt'); // 管道读写操作 // 读取 input.txt 文件内容,并将内容写入到output.txt 文件中 readerStream.pipe(writerStream);
2、链式流
链式是通过连接输出流到另外一个流并创建多个流操作链的机制。
pipe() 方法的返回值是目标流。
var fs = require("fs"); var zlib = require('zlib'); // 压缩 input.txt 文件为 input.txt.gz fs.createReadStream('input.txt').pipe(zlib.createGzip()).pipe(fs.createWriteStream('input.txt.gz') );
var fs = require("fs"); var zlib = require('zlib'); // 解压 input.txt.gz 文件为 input.txt fs.createReadStream('input.txt.gz').pipe(zlib.createGunzip()).pipe(fs.createWriteStream('input.txt'));
Node.js http模块
HTTP 核心模块是 Node.js 网络的关键模块。
使用该模块可以创建web服务器。
1、引入http模块
const http = require('http')
2、创建 Web 服务器
//返回 http.Server 类的新实例 //req是个可读流 //res是个可写流 const server=http.createServer( function (req, res) { res.writeHead(200, { 'Content-Type': 'text/plain; charset=utf-8' }); res.write('服务器响应了,这是响应内容') res.end() })
3、启动服务器并监听某个端口
server.listen('3030',function(){ console.log('服务器已做好准备,正在监听3030端口') })
Node.js GET/POST请求(一)
1、获取 POST 请求内容
<!-- test.html --> <form id="form1" action="http://localhost:3030" method="post"> 姓名:<input type="text" name="name"><br /> 年龄:<input type="text" name="age"><br /> <input type="submit" value="提交" /> </form>
//test.js const http=require('http') const querystring = require('querystring') const server = http.createServer((req, res) => { var bodyStr = '' req.on('data', function (chunk) { bodyStr += chunk }) req.on('end', function () { const body = querystring.parse(bodyStr); // 设置响应头部信息及编码 res.writeHead(200, {'Content-Type': 'text/html; charset=utf-8'}); if(body.name && body.age) { res.write("姓名:" + body.name); res.write("<br>"); res.write("年龄:" + body.age); } res.end() }); }) server.listen('3030',function(){ console.log('服务器正在监听3030端口') })
Node.js GET/POST请求(二)
1、获取Get请求内容
//浏览器访问地址 http://localhost:3030/?name=%27baizhan%27&&age=10
const http = require('http') const url = require('url') const server = http.createServer(function (req, res) { res.writeHead(200, { 'Content-Type': 'text/plain; charset=utf-8' }); //使用url.parse将路径里的参数解析出来 const { query = {} } = url.parse(req.url, true) for ([key, value] of Object.entries(query)) { res.write(key + ':' + value) } res.end(); }) server.listen('3030', function () { console.log('服务器正在监听3030端口') })
Node.js【GET/POST请求、http模块、路由、创建客户端、作为中间层、文件系统模块】(二)-全面详解(学习总结---从入门到深化)(下):https://developer.aliyun.com/article/1420282