带你一块儿撸一遍 nodejs 经常使用核心模块（三）

时间  2019-11-17
标签 一块儿 一遍 nodejs 经常 使用 核心 模块 繁體版
原文   原文链接

压缩模块

zlib 能够用来实现对 HTTP 中定义的 gzip 和 deflate 内容编码机制的支持。 HTTP 的 Accept-Encoding 头字段用来标记客户端接受的压缩编码。 使用 zlib 编码成本会很高, 结果应该被缓存。（下面的演示代码只演示压缩）node

//compresss方法实现压缩 
compress(req, res, statObj, realPat) {    //实现压缩功能
    let encoding = req.headers['accept-encoding'];   //浏览器请求头会自动带上accept-encoding 告诉 服务器支持哪几种压缩格式
    if (encoding) {
        if (encoding.match(/\bgzip\b/)) {
            res.setHeader('content-encoding','gzip')
            return zlib.createGzip()    //返回压缩流  let zip = compress(req, res, statObj, realPat); 
            //经过fs.createReadStream(realPath).pipe(zip).pipe(res) 返回给客户端
        } else if (encoding.match(/\bdeflate\b/)) {
            res.setHeader('content-encoding', 'deflate')
            return zlib.createDeflate();  //返回压缩流  let zip = compress(req, res, statObj, realPat); 
            //经过fs.createReadStream(realPath).pipe(zip).pipe(res) 返回给客户端
        } else {
            return false
        }
    } else {
        return false
    }
}
复制代码

加密和摘要算法

crypto 模块提供了加密功能，包含对 OpenSSL 的哈希、HMAC、加密、解密、签名、以及验证功能的一整套封装.算法

let crypto = require('crypto');
console.log(crypto.getHashes());
[ 'DSA',
  'DSA-SHA',
  'DSA-SHA1',
  'DSA-SHA1-old',
  'RSA-MD4',
  'RSA-MD5',
  'RSA-MDC2',
  'RSA-RIPEMD160',
  'RSA-SHA',
  'RSA-SHA1',
  'RSA-SHA1-2',
  'RSA-SHA224',
  'RSA-SHA256',
  'RSA-SHA384',
  'RSA-SHA512',
  'dsaEncryption',
  'dsaWithSHA',
  'dsaWithSHA1',
  'dss1',
  'ecdsa-with-SHA1',
  'md4',
  'md4WithRSAEncryption',
  'md5',
  'md5WithRSAEncryption',
  'mdc2',
  'mdc2WithRSA',
  'ripemd',
  'ripemd160',
  'ripemd160WithRSA',
  'rmd160',
  'sha',
  'sha1',
  'sha1WithRSAEncryption',
  'sha224',
  'sha224WithRSAEncryption',
  'sha256',
  'sha256WithRSAEncryption',
  'sha384',
  'sha384WithRSAEncryption',
  'sha512',
  'sha512WithRSAEncryption',
  'shaWithRSAEncryption',
  'ssl2-md5',
  'ssl3-md5',
  'ssl3-sha1',
  'whirlpool' ]
复制代码
//几种经常使用的
let crypto = require('crypto');

// console.log(crypto.getHashes());
// 摘要算法
let str = 'hello';
let r = crypto.createHash('md5').update(str).digest('hex');
console.log(r)

let crypto = require('crypto');
let r2 = crypto.createHash('md5').update('hello').digest('hex')
console.log(r2)
let r1 = crypto.createHash('md5').update('h').update('ell').update('o').digest('hex')
console.log(r1)

// 加盐算法
let mac = crypto.createHmac('sha256', 'xl');  //用哈希算法，以一个密钥和一个消息为输入，生成一个消息摘要做为输出
let r = mac.update('hello').digest('hex')
console.log(r)
复制代码

process - 进程

进程（Process）是计算机中的程序关于某数据集合上的一次运行活动，是系统进行资源分配和调度的基本单位，是操做系统结构的基础。进程是线程的容器。程序是指令、数据及其组织形式的描述，进程是程序的实体。数组

process 对象是一个全局变量，它提供当前 Node.js 进程的有关信息，以及控制当前 Node.js 进程。浏览器

  1. 'exit' 事件

两种状况下 'exit' 事件会被触发：缓存

  • 显式调用 process.exit() 方法，使得 Node.js 进程即将结束；
  • Node.js 事件循环数组中再也不有额外的工做，使得 Node.js 进程即将结束。
  1. 'message' 事件

消息经过 childprocess.send() 发送），会触发 'message' 事件。具体用法演示下面额外管道 ipc模式有. 3. 'kill' 事件 -- 注意只有父进程才能够kill子进程bash

process.kill(pid[, signal]) //pid 进程id 能够经过process.pid获取服务器

child_process - 子进程

父子进程之间创建管道有三种模式 pipe/0,1,2/ignore，post

  1. 默认状况下，子进程的 stdin、 stdout 和 stderr 会重定向到 ChildProcess 对象上相应的 subprocess.stdin、 subprocess.stdout 和 subprocess.stderr 流
  2. 0,1,2是共享输入输出（继承父进程输入输出）的再也不演示
  3. ignore

额外的 fd 能够被指定来建立父进程和子进程之间的额外管道学习

1.额外管道pipe模式ui

//pipe模式

//主进程
let {spawn} = require('child_process');
let path = require('path');
// 启动一个子进程
let child = spawn('node', ['sub_process1.js', '--port', '3000'], {
    cwd: path.join(__dirname, 'test'),            //sub_prpcesss1.js文件路径
    stdio:[0,1,2,'pipe']          //默认pipe  (stdin、stdout 和 stderr  --> 0、1 和 2  ==>共享标准输入，标准输出，错误输出)
})
child.stdout.on('data', function (data) {  //接收子进程的数据
    console.log(data.toString())
})

//被启动的子进程
console.log(process.argv)  //子进程输出数据
process.stdout.write('123')   //
---------------------------------------------------
//最终在控制台打出的结果
[ 'C:\\Program Files\\nodejs\\node.exe',
  'c:\\Users\\Administrator\\Desktop\\growth_plan\\Everest4\\22.process\\test\\sub_process1.js',
  '--port',
  '3000' ]
复制代码
  1. 额外管道 ipc模式
// on  send

//主进程
let {spawn} = require('child_process');
let path = require('path');

let child = spawn('node', ['03.ipc.js',],{
    cwd:path.join(__dirname, 'test'),
    stdio:[0,1,2,'ipc']  
})
child.on('message', function(data){
    console.log(data);
    child.send('world');
    // process.kill(child.pid)   //主进程能够强制杀死子进程
})

// 子进程 03.ipc.js
process.send('hello');

process.on('message',function(data){
    console.error(data);
    process.exit();   //执行完退出进程
})
复制代码

另外经常使用的fork其实就是衍生一个新的 Node.js 进程，并经过创建 IPC 通信通道来调用指定的模块，该通道容许父进程与子进程之间相互发送信息。

//主进程
let {fork} = require('child_process');
let path = require('path');
let child = fork('04.fork.js',['a','b'],{
    cwd:path.join(__dirname,'test'),
    silent:false                           // 若是为 true，则子进程中的 stdin、 stdout 和 stderr 会被导流到父进程中，不然它们会继承自父进程。
})

child.send('hello')
child.on('message', function(data) {
    console.log(data)
})
//子进程 04.fork.js
process.send('end')
process.on('message', function(data) {
    console.log(data)
    process.exit()
})
复制代码

集群

为了提升服务器的利用率，能不能多核的来处理呢？因而就有了cluster模块。 cluster模块能够轻松实现运行在同一机器不一样进程上的TCP或HTTP服务器集群。它们仍使用相同的底层套接字，从而在相同的IP地址和端口组合上处理请求。

进程并非开的越多越好，通常是服务器有几核通常开几个进程；

let cluster = require('cluster');
let http = require('http');

let len = require('os').cpus().length;   //获取cpu的核数
if (cluster.isMaster) {//主进程 
    for(let i = 0; i<len; i++) {     //有几核就开几个子进程   
        cluster.fork()     
    }
} else {
    http.createServer(function(req, res) {
        res.end('child'+process.pid)
    }).listen(3000)
}
复制代码
//主进程
let os = require('os');

let {fork} = require('child_process');
let path = require('path');
let http = require('http');

let server = http.createServer(function(req, res) {
    res.end('xxx');
})
server.listen(3000)    //开了一个3000端口
for(let i = 0; i<os.cpus().length;i++){
    let child = fork('1.server.js',{
        cwd: path.join(__dirname),
        silent:false
    });

    child.send('server', server)    //公用服务
}
//子进程 1.server.js
let http = require('http');
process.on('message',function(data,server){
    http.createServer(function(req,res){
        res.end('child'+process.pid)
    }).listen(server); // 子进程公用这个服务
});
复制代码

以上就是nodejs的经常使用核心模块的一部分，由于涉及的内容比较多并无深刻进去，特别是加密和摘要算法这一块，我也仅仅是会用，其实每一个部分均可以展开里面有不少知识，不少深刻的知识我本人也不是很了解，但愿上面的一些核心内容可以帮助到你，固然有不少不足之处但愿朋友们提出指正。也但愿和各位朋友一块儿学习分享！

相关内容：

  1. nodejs经常使用核心模块(一)
  2. nodejs经常使用核心模块(二)

后记:

nodejs经常使用核心模块到这里就结束了，可能有不少零零散散的一些知识点没有提到，但愿你们看完这一系列的文章有一些收获，同时有不足之处和经常使用可是没有提到的知识点但愿朋友们提出指正，互相交流，共同进步！

相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程