[网络协议]【nodejs基础】I/OBufferhttp模块stream

I/O处理

关于 I/O ，有一个很经典的响水壶解释。

• 隔壁王大爷有个水壶，王大爷经常用它来烧开水。
• 同步阻塞：王大爷把水壶放到火上烧，然后啥也不干在那等，直到水开了王大爷再去搞别的事情。
• 同步非阻塞：王大爷觉得自己有点憨，不打算等了。把水壶放上去之后大爷就是去看电视，时不时来瞅一眼有没有开。
• 异步阻塞：王大爷去买了个响水壶，他把响水壶放在火上，然后也是等着水开，水开的时候水壶会发出声响。
• 异步非阻塞：王大爷又觉得自己有点憨，他把响水壶放在火上然后去看电视，这时他不用是不是来瞅一眼，因为水开 的时候水壶会发出声音通知大爷。
• 上面四个例子里，阻塞非阻塞说明的是大爷的状态，同步非同步说明的是水壶的调用姿势。水壶能在烧好的时候主动响起，就等同于我们异步的定义，能在结束时通知主线程并且回调。所以异步一般配合非阻塞，才能发挥其作用。

promisify

• 使用 promisify 可以让一个回调函数风格的异步方法变成 promise 风格。
• 利用一个自执行函数，就可以使用 async await 风格书写代码。

(async () => {
  const fs = require("fs")
  // 使用 promisify 可以让一个回调函数形式的异步方法 变成 promise 形式 从而可以使用 async await
  const { promisify } = require("util")
  // 将 fs.readFile 方法 包装成 promise
  const readFile = promisify(fs.readFile)
  // 读取的是个 buffer 对象 ,是 js 用来描述二进制的东西
  const data = await readFile("./test.js")
  // toString方法解析字符串
  console.log("data", data.toString())
})()

Buffer

• 读取数据类型为 Buffer 。
• 用于在 TCP 流、文件系统操作、以及其他上下文中与八位字节流进行交互。 八位字节组成的数组，可以有效的在 JS 中存储二进制数据。

// 创建一个长度为 10 字节以 0 填充的 Buffer
const buf1 = Buffer.alloc(10)
console.log('🚀🚀~ buf1:', buf1);

// 创建一个 Buffer 包含 ascii.
const buf2 = Buffer.from("a")
console.log('🚀🚀~ buf2:', buf2);

// 创建Buffer包含UTF-8字节 
// UFT-8：一种变长的编码方案，使用 1~6 个字节来存储； 
// UFT-32：一种固定长度的编码方案，不管字符编号大小，始终使用 4 个字节来存储； 
// UTF-16：介于 UTF-8 和 UTF-32 之间，使用 2 个或者 4 个字节来存储，长度既固定又可变。
const buf3 = Buffer.from('中')
console.log('🚀🚀~ buf3:', buf3);

// 写入 Buffer 数据 
buf1.write('hello'); 
console.log(buf1); 

// 读取 Buffer 数据 
console.log(buf3.toString());

// 合并 Buffer 数据 
const buf4 = Buffer.concat([buf2, buf3])
console.log('🚀🚀~ buf4:', buf4, buf4.toString());

http模块

• writeHead 可以同时书写 statusCode 和 setHeader 。
• 判断 req.headers.accept 是否包含 image/* 可以判断是不是请求图片。

const http = require("http")
const fs = require("fs")
// 创建服务
const server = http.createServer((req, res) => {
  const { url, method, headers } = req
  if (url === '/' && method === 'GET') {
    fs.readFile("./src/03-http/index.html", (err, data) => {
      if (err) {
        res.writeHead(500, { 'Content-Type': 'text/plain;charset=utf-8' })
        res.end("500 服务器错误")
        return
      }
      res.statusCode = 200
      res.setHeader('Content-Type', 'text/html')
      res.end(data)
    })
  }
  else if (url === '/getUser' && method === 'GET') {
    res.writeHead(200, { 'Content-Type': 'application/json' })
    res.end(JSON.stringify({ name: "warbler" }))
  }
  // Accept代表发送端（客户端）希望接受的数据类型。 比如：Accept：text/xml; 代表客户端希望 接受的数据类型是xml类型。 
  // Content-Type代表发送端（客户端|服务器）发送的实体数据的数据类型。 比如：ContentType：text/html; 代表发送端发送的数据格式是html。 
  // 二者合起来， Accept:text/xml； Content-Type:text/html ，即代表希望接受的数据类型是xml格 式，本次请求发送的数据的数据格式是html。
  else if (method === 'GET' && headers.accept.indexOf("image/*") !== -1) {
    // 统一描述所有的图片请求
    fs.createReadStream(`./src/03-http/${url}`).pipe(res)
  }
  else {
    res.statusCode = 404
    res.setHeader('Content-Type', 'text/plain;charset=utf-8')
    res.end("404 页面未找到")
  }
})
server.listen(3000, () => {
  console.log('🚀🚀~ sever at 3002');
})

stream

const fs = require("fs")

// 读流
const rs = fs.createReadStream('./src/04-stream/main.jpg')

// 写流
const ws = fs.createWriteStream('./src/04-stream/main2.jpg')

// 连接导管 可以复制图片到指定目录
rs.pipe(ws)

参考资料

开课吧全栈架构师课程