深入node.js 3 模板引擎原理 事件 文件操作 可读流的实现原
模板引擎是基于new Function + with 实现的。
ejs使用
实现：
思路：借助fs的readFile先读取文件内容，然后使用正则表达式替换掉即可。
打印的结果是一样的。
复杂的情况呢？拼接字符串，拼成想要的代码
主要难点就是在字符串的拼接，第二部分，将全文分为三部分，然后拼接对应的，如
let str = ""
with(obj){
str+= `<!DOCTYPE html>
<html lang="en">
<head>
<meta charset="UTF-8">
<meta http-equiv="X-UA-Compatible" content="IE=edge">
<meta name="viewport" content="width=device-width, initial-scale=1.0">
<title>Document</title>
</head>
<body>
`
arr.forEach(item=>{
str+=`
<li>
${item}
</li>
`
})
str+=`
</body>
</html>`}
return str
登录后复制
这就是拼出来的字符串，然后再new Function,包裹一层函数，将with的obj传入，返回str。
大概长这样。
效果就是：
所以本质就是将获取到的内容，使用正则表达式匹配，拼接字符串成我们想要的内容，用with包裹，改变内部作用域，再通过new Function将str包装成一个函数，传入对应的值给obj。然后运行之后str就能正常通过作用域获取值赋值。
buffer
在服务端，需要一个东西来标识内存，但不能是字符串，因为字符串无法标识图片。node中使用buffer来标识内存的数据。他把内存转换成了16进制来显示（16进制比较短）buffer每个字节的取值范围就是0-0xff(十进制的255).
node中buffer可以和字符串任意的转换（可能出现乱码）
编码规范：ASCII ->GB8030/GBK ->unicode ->UTF8
Buffer代表的是内存，内存是一段固定空间，产生的内存是固定大小，不能随意增加。
扩容：需要动态创建一个新的内存，把内容迁移过去。
创建一个长度为5的buffer，有点像数组，但是数组可以扩展，而buffer不可以扩展。
还有一种声明buffer。
Buffer.form。
一般使用alloc来声明一个buffer，或者把字符串转换成Buffer使用。文件操作也是采用Buffer形式。
buffer使用
无论是二进制还是16进制，表现得东西是一样的。
base64编码：
base64可以放在任何路劲的链接里，可以减少请求次数。但是文件大小会变大。比如webpack中的asset/type，把一些小的文件转换成了Base64编码内嵌到了文件当中，虽然可以减少请求次数，但也增大了文件的大小。
base64的来源就是将每个字节都转化为小于64的值。没有加密功能，因为规则很简单。如
第一步：将buffer中每个位置的值转为二进制。如上。
一个字节有八位，八位的最大值是255，有可能超过64。而base64编码是要将每个字节转化为小于64的值。所以就取每个字节的6位。6位的最大值就是2*6 - 1 = 63。也就是：
第二步：将38的形式转成64的，保证每个字节小于64。将其转为十进制。
第三步，通过特定的编码规则转换即完成。
将我们获取到的十进制传入，因为每个字节都是小于64的，所以不超过。
完成。
buffer的常用方法
除了form和alloc还有
slice
// slice
const a = Buffer.from([1,2,3,4,5])
const d = a.slice(0,2)
d[1] = 4
console.log(d)
console.log(a)
登录后复制
与数组的用法相同，但是他并不是浅复制，而是直接关联在一起。改变d也会改变a。而数组的slice是浅复制。改变原始数据的值不会改变。
copy
将Buffer的数据拷贝到另一个数据上。
const a = Buffer.from([1, 2, 3, 4, 5])
const d = Buffer.alloc(5)
a.copy(d, 1, 2, 3)//四个参数，拷贝到哪里？从d的第一个开始拷贝 a的a[2]->a[3]
console.log(d)
登录后复制
copy四个参数，分别是拷贝的目标d。从d的第几个长度开始。拷贝a的第2到第3位。
所以应该是 <Buffer 00 03 00 00 00 >
concat
用于拼接buffer
Buffer.concat(arr, index)
第二个参数是拼接出来的Buffer的长度，如果大于原本的长度，用00填写。
Buffer.myConcat = function (
bufferList,
length = bufferList.reduce((a, b) =>a + b.length, 0)
) {
let bigBuffer = Buffer.alloc(length)
let offset = 0
bufferList.forEach((item) =>{
//使用copy每次拷贝一份然后offset向下走。
item.copy(bigBuffer, offset)
offset += item.length
})
return bigBuffer
}
登录后复制
借助copy，逐个拷贝一份即可。
文件操作
fs模块有两种基本api，同步，异步。
io操作，input，output，输入输出。
读取时默认是buffer类型。
写入的时候，默认会将内容以utf8格式写入，如果文件不存在则创建。
读取的data是Buffer类型，写入的是utf8格式。
这种读写适合小文件
读取文件某段内容的办法
fs.open用于打开一个文件。fs.read用来读取内容并且写入到buffer中。
fs.write用于将内容写入某个文件之中。如上，打开了b.txt，然后用fs.wirte。五个参数，分别是fd，buffer，从buffer的第0个位置，到buffer的第0个位置，从b.txt的第0位开始写，回调函数。
写入成功。
这种写法也不太美观，每次都需要fs.open然后fs.read或者fs.wirte，容易造成回调地狱。
流 Stream的出现
源码的实现步骤：
fs的CreateReadStrem是new了一个ReadStream，他是基于Stream的Readable类的，然后自己实现了_read方法。供Stream.prototype.read调用。
1 内部会先open文件，然后直接直接继续读取操作，默认是调用了pause暂停。
2 监听用户是否绑定了data事件，resume，是的话开始读取事件
3 调用fs.read 将数据读取出来。
4 调用this.push去emit data事件，然后判断是否可以读取更多再去读取。
第一种： fs.readFile（需要将文件读取到磁盘中，占用内容）=>fs.wirteFile
第二种： fs.open =>fs.read =>fs.write 回调地狱。
实现读取三个字节写入三个字节。采用fs.open fs.read fs.write的方法。
实现copy方法。
看实现：
首先创建一个三字节的Buffer。
然后使用fs.open打开要读取和要写入的文件。
因为我们是每三个每三个读取，所以需要采用递归方式，一直读取文件。
直到读取完毕，调用回调函数。fs.read和fs.write的参数都是类似的，即fd,buffer,buffer的start,buffer的end，读取文件/写入文件的start、回调函数（err，真正读取到的个数/真正写入的个数）
现在基本实现了读一部分，写一部分，但是读写的逻辑写在一起了，需要把他拆开。
流 Stream模块
可读流
不是一下子把文件都读取完毕，而是可以控制读取的个数和读取的速率。
流的概念跟fs没有关系，fs基于stream模块底层扩展了一个文件读写方法。
所以fs.open,fs.read等需要的参数，createReadStream也需要、
返回一个对象，获取需要监听data事件。
close事件在end事件之后触发。
由此可以看出：流的内部基于 fs.open fs.close fs.read fs.write以及事件机制。
暂停是不再触发data事件
rs.resume()是恢复。
实现readStream
从vscode调试源码得知
实现思路：
createReadStream内部new了一个ReadStream的实例，ReadStream是来自于Stream模块。
做一系列参数默认后， 调用this.open方法，这个方法会去调用fs.open去打开文件，打开之后触发事件，从回调的形式发布订阅模式，然后监听事件，当发现有用户注册了data事件之后，调用fs.read，j监听open事件，在open之后再去读取文件等等。
这样我们的读写逻辑就分离开了，从回调的形式变成了发布订阅模式，有利于解耦。
第一步：
第一步：参数初始化，并调用fs.open
open打开之后会触发open事件，注意，这里是异步的
第二步： 监听用户注册的data事件，当用户注册了data事件才去调用fs.read。调用this.read的时候open还没完成。
所以第一次read的时候需要判断，然后只监听一次open事件，重复打开read事件。
这个end和start配合，表示读取文件从哪到哪的位置，但是end是包后的，比如上面的end为4，实际上读取到的是5。
创建buffer存放读取的内容，再判断应该读取多少内容，以哪个小为准。
然后打开fs.read。将读取到的buffer发布出去。再次调用this.read去继续读取。
start=1,end=4，读取到2345的内容，正确。
不给end，每次3个3个的读取。
接着实现暂停，需要一个开关。
这样就基本完成了。
总结：
一开始实现的的copy方法，也是利用fs.open, fs.read, fs.write等，通过回调的形式完成的，这样虽能完成，但是内聚度较高，容易形成回调地狱。
而基于fs模块，和events模块，实现的可读流，可以有效的解耦刚才的代码，通过发布订阅模式，在一开始订阅事件，在每个时间点对应发布事件，然后代码执行，各司其职。
open和close是文件流独有的，
可读流具备：on (‘data’ | ‘end’ | ‘error’), resume, pause这些方法。
相关代码：
// copy
const fs = require("fs")
const path = require("path")
// let buf = Buffer.alloc(3)
// //open打开一个文件，第一个参数是路劲，第二个参数是打开文件用途，第三个是回调函数。
// fs.open(path.resolve(__dirname, "a.txt"), "r", function (err, fd) {
// // fd 是file descriptor文件描述
// console.log("fd", fd)
// //读取a.txt的内容，并且将内容写入buf中的第0个位置到3第三个位置，从a.txt的第六个位置开始
// fs.read(fd, buf, 0, 3, 3, function (err, data) {
// fs.open(path.resolve(__dirname, "./b.txt"), "w", function (err, fd2) {
// fs.write(fd2, buf, 0, 3, 0, function (err, data2) {
// console.log("buf", buf)
// console.log("data2", data2)
// })
// })
// })
// })
function copy(source, target, cb) {
const BUFFER_SIZE = 3
const buffer = Buffer.alloc(BUFFER_SIZE)
//每次读入文件的位置
let r_offset = 0
//每次写入新文件的位置
let w_offset = 0
//读取一部分数据，写入一部分数据
//第三个参数可以是权限 权限有三个组合 rwx 可读可写可执行 r的权限是4，w的权限是2，x的权限是1 421 = 777 可写可读可执行
// 0o666表示最大的权限，默认不用写。
//读取的文件必须要存在。写入文件不存在会创建，如果文件有内容会清空。
fs.open(source, "r", function (err, fd1) {
//打开写的文件
fs.open(target, "w", function (err, fd2) {
//每次读取三个写入三个，回调的方式实现的功能，需要用递归
// 同步代码则可以采用while循环
function next() {
fs.read(
fd1,
buffer,
0,
BUFFER_SIZE,
r_offset,
function (err, bytesRed) {
// bytesRed真正读取到的个数
if (err) {
cb("读取失败")
return
}
if (bytesRed) {
//将读取到的内容写入target目标
fs.write(
fd2,
buffer,
0,
bytesRed,
w_offset,
function (err, written) {
if (err) retrun
// written 真正写入的个数
r_offset += bytesRed//每次写入之后，下一次读取的内容就该往前进
w_offset += written
next()
}
)
} else {
//读取内容为空，结束
fs.close(fd1, () =>{})
fs.close(fd2, () =>{})
cb()
}
}
)
}
next()
})
})
}
copy("./a.txt", "b.txt", (err, data) =>{
console.log("copy success")
})
登录后复制
createStream的实现
const EventMitter = require("events")
const fs = require("fs")
class ReadStream extends EventMitter {
constructor(path, options = {}) {
super()
this.path = path
//操作
this.flags = options.flags || "r"
this.encoding = options.encoding || null
this.autoClose = options.autoClose || true
this.start = options.start || 0
this.end = options.end || Infinity//读取的个数，包后的，如果是1 ，就可能读取到0，1，2
this.highWaterMark = options.highWaterMark || 64 * 1024
this.emitClose = options.emitClose || false
this.offset = this.start// 每次读取文件的位移数
this.flowing = true//暂停继续开关
this.open()// 文件操作，注意这个方法是异步的。
// events可以监听newListener，可以获取注册的所有事件
this.on("newListener", function (type) {
if (type === "data") {
//用户订阅了data事件，才去读取。
this.read()//这时候文件还没open，fd为undefined。
}
})
}
pause() {
//暂停
this.flowing = false
}
resume() {
//继续
if (!this.flowing) {
this.flowing = true
this.read()
}
}
destory(err) {
if (err) {
this.emit("error", err)
}
if (this.autoClose) {
fs.close(this.fd, () =>{
this.emit("close")
})
}
}
read() {
//希望在open之后打开
if (typeof this.fd !== "number") {
this.once("open", (fd) =>{
//之前实现的copy这段逻辑是写在了fs.open里面，换成发布订阅模式之后就可以分离出来。
this.read()//第二次read的时候，fd有值了
})
} else {
//判断每次读取多少。因为this.end是包后的，比如start = 0, end = 1, 那么读取的就是 0 , 1, 2所以需要+1
const howMutchToRead = Math.min(
this.end - this.offset + 1,
this.highWaterMark
)
const buffer = Buffer.alloc(howMutchToRead)
fs.read(
this.fd,
buffer,
0,
howMutchToRead,
this.offset,
(err, byteRead) =>{
if (err) {
this.destory(err)
} else {
if (byteRead) {
//读取到文件，发布data事件,发送真正读取到的内容
this.offset += byteRead
this.emit("data", buffer.slice(0, byteRead))
this.flowing &&this.read()
} else {
this.emit("end")
if (this.autoClose) {
this.destory()
}
}
}
}
)
}
}
open() {
fs.open(this.path, this.flags, (err, fd) =>{
if (err) {
//报错：
this.destory(err)
}
//从回调的形式变成了发布订阅模式
this.fd = fd
this.emit("open", fd)
})
}
}
const rs = new ReadStream("./a.txt", {
flags: "r", //创建可读流。
encoding: null, //默认Buffer
autoClose: true, //自动关闭，相当于读取完毕调用fs.close
emitClose: true, //触发close事件
start: 0, //从文件哪里开始读取
highWaterMark: 3, //每次读取的数据个数，默认是64*1025字节。
//end: 4, // 比如这个就会读取 1到5的内容
})
rs.on("open", () =>{
console.log("文件打开了")
})
// rs.on("data", (data) =>{
// console.log("监听Data事件", data)
// })
// //底层还是 fs.open fs.read fs.close
// const rs = fs.createReadStream("./a.txt", {
// flags: "r", //创建可读流。
// encoding: null, //默认Buffer
// autoClose: true, //自动关闭，相当于读取完毕调用fs.close
// emitClose: true, //触发close事件
// start: 0, //从文件哪里开始读取
// highWaterMark: 3, //每次读取的数据个数，默认是64*1025字节。
// })//返回一个对象
//没监听前，是非流动模式，监听后，是流动模式。
//监听data事件，并且不停触发
rs.on("data", function (chunk) {
console.log(chunk)
//暂停
rs.pause()
})
rs.on("end", function () {
console.log("读取完毕")
})
rs.on("close", function () {
console.log("文件关闭")
})
setInterval(() =>{
console.log("一秒后")
rs.resume()
}, 1000)
1. 项目名称：轻量级 B2C 商城系统项目简介：本项目是一个拥有 PC 端 + H5 移动端的超轻量，功能强大的 B2C 商城系统。
技术实现：
核心框架：基于全新超轻量高性能Speed框架
JS框架：jQuery 1.10.2
移动端JS框架：Zepto 1.2.0
图表库：Flot 0.8.3
富文本编辑器：百度 精简版 UMeditor
JS模板引擎：Juicer 0.6.8
运行环境：
操作系统： Windows / Linux / Unix
Web 服务器：Apache / Nginx / IIS
PHP 版本：5.2 及以上
MySQL 版本：5.0 及以上
生产环境推荐：Linux + Nginx + PHP5.5 + MySQL5.6
项目地址：cigery/verydows - 码云
2、项目名称：基于 PHP 的轻量级路由器
项目简介：非常轻量级的路由器。无依赖、简洁、速度快、自定义性强。
轻量级且速度快，查找速度不受路由数量的影响。
支持路由参数定义，以及路由选项(比如设定 domains、schema 等检查限制)。
支持请求方法：GET POST PUT DELETE HEAD OPTIONS ...
支持事件： found notFound execStart execEnd execError，当触发事件时你可以做一些事情(比如记录日志等)。
支持动态获取 action 名。支持设置方法执行器(actionExecutor)，通过方法执行器来自定义调用真实请求方法。
支持自动匹配路由到控制器就像 yii 一样，请参看配置项 autoRoute。
支持通过方法 SRouter::dispatch($path, $method) 手动调度一个路由。
你也可以不配置任何东西，它也能很好的工作。
项目地址：inhere/php-srouter - 码云
3. 项目名称：轻量级论坛社区系统
项目简介：本项目是一个基于 CodeIgniter 框架开发的 PHP 新型社区系统，她轻量小巧、简单易用、强大高效，又简称 ”STB（烧饼 BBS）。
项目地址：烧饼/startbbs - 码云
4. 项目名称：基于 PHP 的三维验证码
<img src="https://pic2.zhimg.com/50/v2-9ca452bb7063269c91d2c498419adedd_hd.png" data-rawwidth="360" data-rawheight="80" class="content_image" width="360">
项目简介：打破传统的，基于 PHP 的 3d 英文字母验证码，图片粒子化，机器难以识别边界，破解难度极大。
项目地址：Quekie/Safe 3D Identifying Code
5. 项目名称：基于 PHP 的多进程网络爬虫框架
<img src="https://pic4.zhimg.com/50/v2-84fcb4f09302a1f8356ee7ca8ed8857f_hd.jpg" data-rawwidth="650" data-rawheight="800" class="origin_image zh-lightbox-thumb" width="650" data-original="https://pic4.zhimg.com/v2-84fcb4f09302a1f8356ee7ca8ed8857f_r.jpg">
项目简介：Beanbun 是一个简单可扩展的爬虫框架，支持分布式，支持守护进程模式与普通模式，守护进程模式基于 Workerman，下载器基于 Guzzle。
特点：
支持守护进程与普通两种模式（守护进程模式只支持 Linux 服务器）
默认使用 guzzle 进行爬取
支持分布式
支持内存、Redis 等多种队列方式
支持自定义URI过滤
支持广度优先和深度优先两种爬取方式
遵循 PSR-4 标准
爬取网页分为多步，每步均支持自定义动作（如添加代理、修改 user-agent 等）
灵活的扩展机制，可方便的为框架制作插件：自定义队列、自定义爬取方式...
项目地址：Kiddyu/Beanbun - 码云
你描述的比较乱，不过我大概能理解你的意思。
因为没有具体的代码，所以也只能说说思路。
按我的理解，重新描述你现在的问题是：
通过模板渲染，或者 ajax 异步载入的 html 内容，会通过 innerHTML 或者一定的 DOM 操作，插入到文档中。你希望在这段文档碎片插入后，执行一些脚本。但是遇到的问题是：插入的脚本无法执行。
那么我的建议的解决方法有以下几种：
1、第一种方法，通过设置定时检查，来判断内容是否完成载入。
在 {{data.content}} 中放一个 “标识”。例如：
<!-- 你正常的 content 内容 --><p>。。。。。</p>
<!-- 特殊的标识 -->
<span id="a_special_id"></span>
然后在整个页面的脚本中，加一个定时检查器 (下面代码放在整个页面的 head 里)：
var flag = false // 一个状态标记，记录需要进行的脚本是否执行过// 用来检查的函数
function check(){
// 如果脚本已执行过，则退出，避免重复执行。
if (flag) return
// 尝试获取 {{data.content}} 中的 “标识”
var obj = document.getElementById('a_special_id')
// 如果获取成功，说明代码已经完成载入
if (obj) {
// 这里放上你想要进行的操作，例如你问题中的：
jQuery(document).ready(function() {
jQuery('.media-frame-content').css("height",winheight)
})
// 设置状态标记，避免脚本重复执行
flag = true
} else {
// 如果代码没有完成载入
// 设置定时器，过一段时间再次检查
setTimeout(check, 100)
}
}
// 开始检查
check()
2、 第二种方法，是针对为什么插入的脚本不能执行来解决的。
一般来说，通过 innerHTML 或者 DOM 方法插入的 script 脚本都不能正常执行。
那么应该在你的模板解析函数中，进行一定的判断处理。
例如 ajax 获得服务器返回的数据后，检查有无 script 块，如果有，则提取其内容，并通过 eval 来执行。
示例代码：
// 伪代码，假设下面是一个通过 ajax 获取 get.php 页面得到返回数据的模式$.ajax('get.php', function(data){
var reg = /<script>([\s\S]+)<\/script>/i // 正则
var sc
if (reg.test(data)) {
sc = data.match(reg)[1] // 提取脚本
data = data.replace(reg, '') // 移除脚本
}
container.innerHTML = data // 将 html 内容输出到当前页面
if (sc) eval(sc) // 如果有脚本，则执行脚本
})
以上，请采纳，请给分。
