前端知识点回顾——Nodejs-蒲公英云

Node.js

事件循环机制

1553476197507

setImmediate()是将事件插入到事件队列尾部，主线程和事件队列的函数执行完成之后立即执行setImmediate指定的回调函数，和setTimeout(fn,0)的效果差不多

process.nextTick()方法可以在当前”执行栈”的尾部—>下一次Event Loop（主线程读取”任务队列”）之前—>触发process指定的回调函数。也就是说，它指定的任务总是发生在所有异步任务之前，当前主线程的末尾。

事件触发器模块Events

const EventEmitter = requier("events").EventEmitter; const emitter = new EventEmitter;

emitter.on(‘eventName’, callback) 绑定事件

当事件名为“newListener”时表示监听后续是否添加了新的监听事件，每添加一个新的监听事件都会触发一次并执行回调
emitter.off(‘eventName’, callback) 解绑事件
emitter.emit(‘eventName’) 触发对应的事件，执行绑定在该事件上的回调函数
emitter.once(‘eventName’, callback) 绑定后只触发一次，触发完毕后解绑
emitter.setMaxListeners(number) 设置同一事件名能设置的监听事件最大数,默认为10，超出只会警告而不报错
emitter.getMaxListeners() 返回 EventEmitter 当前的监听器最大限制数的值
emitter.listeners(“eventName”) 返回名为 eventName 的事件的监听器数组的副本

URL模块

URL的解析

const URL = require(“url”).URL; const myUrl = new URL(“https://www.baidu.com/s?ie=utf-8&f=8&rsv_bp=1&rsv_idx=1&tn=baidu&wd=nodejs&oq=nodejs&rsv_pq=d7fa015100007271&rsv_t=aa05WH%2FPArCuBuKN337J%2BU6sVgj9%2BXf95e%2F8rq7tN8CgOI2AwwkmOSAGEvs&rqlang=cn&rsv_enter=1&inputT=366&rsv_sug3=12&rsv_sug1=10&rsv_sug7=100&rsv_sug2=0&rsv_sug4=1165&rsv_sug=1“); //返回一个关于这个url相关的信息的实例对象

myUrl.searchParams 返回一个关于这个url相关信息的map结构，需要使用.get()方法取得属性值，没有值的属性为空字符串

URL的拼接

const resolve = require(“url”).resolve; // url拼接 resolve(“user/wula”, “51-url-fs”); // user/51-url-fs 处在user的同目录下 resolve(“user/wula/“, “51-url-fs”); // user/wula/51-url-fs resolve(“user/wula/“, “/51-url-fs”); // 51-url-fs /表示处在根目录下
URL的序列化与反序列化

const URL = require(“url”).URL; const qs = require(“querystring”); const myUrl = new URL(“https://www.baidu.com/s?ie=utf-8&f=8&rsv_bp=1&rsv_id…”); qs.parse(myUrl.search.slice(1)); //序列化，返回一个对象，里面的键值对为url中的搜索条件 qs.stringify({wula:123, simple:456}); //反序列化， wula=123&simple=456

加密模块crypto

const crypto = require("crypto"); console.log(crypto.getHashes()); //查看hash加密方式有哪些 let pwd = "simple"; const obj = crypto.createHash("sha256"); obj.update(pwd); //通过加密对象对数据进行加密 console.log(obj.digest()); //得到加密数据,得到一个buffer对象（默认为二进制） console.log(obj.digest("hex")); //得到加密数据,以16进制形式表示

文件操控模块fs

const fs = requier('fs');

文件的读取

fs.readFile(“./simple.txt”, “utf8”, (err, data) => { //路径，字符集，回调函数(读取发生错误时候的错误信息，读取成功得到的数据) console.log(err); //err为null表示读取成功，读取失败为对象，里面存储错误信息 console.log(data); //默认以二进制保存的buffer对象，有设置字符集以字符集形式展示 }); fs.readFileSync(“./simple.txt”, “utf8”); //同步方法，返回值为读取得到的数据
文件的写入

let data = “simple”; fs.writeFile(“./test.txt”, data, (err) => { if (err) throw err; }); fs.writeFileSync(“./test.txt”, data); fs.appendFile(“./test.txt”, “添加的内容”, “utf-8”, err => {}); //非覆盖的添加内容
创建文件夹

fs.mkdir(“./01”, err => { //只能创建一个未知的文件夹，且不能创建多个文件夹 });
读取文件夹目录

fs.readdir(“../51”, (err, data) => { if(err) throw err; console.log(data); //data为一个数组，保存的是该目录下所有文件的文件名 });
判断是否为文件

const stat = fs.statSync(“../51”); console.log(stat.isDirectory()); //true为文件夹， false为其他文件 console.log(stat.isFile()); //false为文件夹， true为其他文件
监听文件

fs.watchFile(“./wula.txt”, (a, b) => { //监听路径中的文件内容是否进行修改，会在文件内容修改后触发回调函数 console.log(a); //a为文件修改前的状态对象 console.log(b); //b为文件修改后的状态对象 });

流模块steam

流模块

const fs = require(“fs”); //fs模块继承了stream const read = fs.createReadStream(“./simple.txt”); //创建一个读取流,返回一个对象,为暂停状态 // 流有两个状态：暂停状态释放状态 read.resume(); //改变流的状态为释放状态，只有为释放状态的时候流才会流动 read.setEncoding(“utf-8”); //设置输出数据的字符集 read.on(“data”, data => { //随着流的不断流动会多次触发回调 }); //绑定data事件后可以让流变为释放状态，还会监听流的流动以得到数据（默认为二进制buffer对象） read.on(“end”, () => { }); //监听流的流动，流动结束后触发回调函数
管道服务

const fs =require(“fs”); const read = fs.createReadStream(“./simple.txt”); const write = fs.createWriteStream(“./wula.txt”); read.pipe(write); //让数据流从读取流流向写入流 write.write(“”); //往写入流中写入数据，覆盖的
可读流

const Readable = require(“stream”).Readable; const read = new Readable(); //创建一个可读流对象 read.setEncoding(“utf-8”); read.push(“1”); read.push(“2”); read.push(“3”); read.push(null); //在最后push一个null表示数据放完了，不然会报错

HTTP模块

在node中HTTP服务继承自TCP服务器，它能够与多个客户端保持连接，由于其采用事件驱动的形式，并不为每一个连接创建额外的线程或进程，保持很低的内存占用，所以能实现高并发。下面是一个实例。

const http = require("http"); const fs = require('fs'); //创建一个服务 const server = http.createServer((req, res) => { // req 请求体对象 res:响应体对象 //请求体的属性：req.url req.method req.httpVersion req.headers //req.headers 返回键值对形式的请求头，以供业务逻辑调用 //根据请求方法来进行处理 if (req.method === "GET") { res.writeHead(200, { "Content-Type": "text/html;charset=utf-8" }); //根据请求路径进行页面渲染 switch (req.url) { case "/wula": res.write(fs.readFileSync("./01.html", "utf8")); break; default: res.write(fs.readFileSync("./default.html", "utf8")); break; } } //设置响应头 //设置允许跨域，CROS跨域 res.setHeader("access-control-allow-origin", "*"); //setHeader可多次调用设置，但只有调用writeHead后，报头才会写入到连接中 res.writeHead(200, { "Content-Type" : "text/html;charset=utf-8" }); //text/plain ：纯文本 text/html:标签 //写入响应主体 //res.write可多次调用，res.end调用会先调用write发送数据，然后发送信号告知服务器响应结束 res.end("<div>结束会话</div>"); }); //监听端口号 // server.listen(3000, "127.0.0.1"); server.listen(3000); console.log("开始监听3000端口");

http客户端

在node中通过http.request(options,connect)这个API来构造HTTP客户端

比如说要构建一个代理服务器（3003端口），当我向它发起请求的时候它会返回3000端口的响应，这个时候就需要在服务器上创建一个向3000端口的请求。

const http = require("http"), request = http.request; //得到请求的api let options = { host : "localhost", //服务器域名或IP地址 port : 3000, method : "GET" /* hostname 服务器名字 path 路径 headers 请求头 ... */ }; //调用请求方法，返回一个请求对象 let reqObj = request(options, res => { let dataObj = null; res.setEncoding("utf8"); //设置响应主体流的编码方式 res.on("data", data => { dataObj = data; // console.log(data); //接收到的数据 }); //监听res的end事件 res.on("end", () => { //创建一个服务，等待客户端的请求过来 http.createServer((req, res) => { res.setHeader("Access-Control-Allow-Origin", "*"); res.write(JSON.stringify(dataObj)); res.end(); }).listen(3003, () => { console.log("服务正在监听3003端口"); }); }) }); //如果请求失败，调用err事件 reqObj.on("error", err => { console.log(err); }); //写入请求主体 reqObj.write(""); reqObj.end();