[转载]进程通信模块child_process——nodejs中间件系列

作者：小伟 | 来源：互联网 | 2023-08-26 20:49

从零开始nodejs系列文章，将介绍如何利Javascript做为服务端脚本，通过Nodejs框架web开发。Nodejs框架是基于V8的引擎，是目前速度最快的Javascript

从零开始nodejs系列文章，将介绍如何利Javascript做为服务端脚本，通过Nodejs框架web开发。Nodejs框架是基于V8的引擎，是目前速度最快的Javascript引擎。chrome浏览器就基于V8，同时打开20-30个网页都很流畅。Nodejs标准的web开发框架Express，可以帮助我们迅速建立web站点，比起PHP的开发效率更高，而且学习曲线更低。非常适合小型网站，个性化网站，我们自己的Geek网站！！

关于作者

张丹(Conan), 创业者，程序员(Java,R,Javascript/Nodejs)
weibo：@Conan_Z
blog: http://blog.fens.me
email: bsspirit@gmail.com

转载请注明出处：
http://blog.fens.me/nodejs-child-process/

技术分享

前言

Node.js是一种单线程的编程模型，对Node.js的赞美和诟病的也都是因为它的单线程模型，所有的任务都在一个线程中完成（I/O等例外）。单线程模型，不仅让代码非常简洁，更是直接避免了线程调度的复杂性；同样也是因为单线程，让CPU密集型计算应用，完全不适用。

在Node.js的内核中，给了我们一种新的选择，通过child_process模块创建新进程，从而实现多核并行计算。

child_process介绍
child_process的基本使用：spawn, exec, execFile, fork

1. child_process介绍

child_process是Node.js的一个十分重要的模块，通过它可以实现创建多进程，以利用单机的多核计算资源。虽然，Nodejs天生是单线程单进程的，但是有了child_process模块，可以在程序中直接创建子进程，并使用主进程和子进程之间实现通信，等到子进程运行结束以后，主进程再用回调函数读取子进程的运行结果。

本文仅从使用上对child_process模块进行介绍，对于深入的内容请参考官方文档，https://nodejs.org/api/child_process.html

关于Node.js线程不错的文章：https://cnodejs.org/topic/518b679763e9f8a5424406e9

2. child_process的基本使用

child_process模块，在v0.12.0版本主要包括4个异步进程函数(spawn,exec,execFile,fork)和3个同步进程函数(spawnSync,execFileSync,execSync)。以异步函数中spawn是最基本的创建子进程的函数，其他三个异步函数都是对spawn不同程度的封装。spawn只能运行指定的程序，参数需要在列表中给出，而exec可以直接运行复杂的命令。

比如要运行 du -sh /disk1 命令，使用spawn函数需要写成spawn(‘du ‘, [‘-sh ‘, ‘/disk1’])，而使用exec函数时，可以直接写成exec(‘du -sh /disk1’)。exec是会先进行Shell语法解析，因此用exec函数可以更方便的使用复杂的Shell命令，包括管道、重定向等。下面我们就针对每个异步函数，进行测试一下。

系统环境

Linux Ubuntu 14.04.1 LTS 64bit
Nodejs:v0.13.0-pre
Npm:1.4.28

创建项目

1 ~ cd /disk1/demo
2 ~ mkdir nodejs-childprocess && cd nodejs-childprocess

2.1 spawn函数

spawn从定义来看，有3个参数。

1 child_process.spawn(command[, args][, options])

command: 只执行的命令
args: 参数列表，可输入多的参数
options: 环境变量对象

其中环境变量对象包括7个属性：

cwd: 子进程的当前工作目录
env: 环境变量键值对
stdio: 子进程 stdio 配置
customFds: 作为子进程 stdio 使用的文件标示符
detached: 进程组的主控制
uid: 用户进程的ID.
gid: 进程组的ID.

首先，我们运行一下，上文提到的du的命令。直接在命令行，运行的结果。

1 ~ du -sh /disk1
2 582M    /disk1

新建文件spawn.js

 1 ~ vi spawn.js
 2 
 3 var child = require(‘child_process‘);
 4 var du = child.spawn(‘du‘, [‘-sh‘, ‘/disk1‘]);
 5 du.stdout.on(‘data‘, function (data) {
 6     console.log(‘stdout: ‘ + data);
 7 });
 8 du.stderr.on(‘data‘, function (data) {
 9     console.log(‘stderr: ‘ + data);
10 });
11 du.on(‘exit‘, function (code) {
12     console.log(‘child process exited with code ‘ + code);
13 });

通过node运行的结果

1 ~ node spawn.js
2 
3 stdout: 582M    /disk1
4 child process exited with code 0

输出的结果是一样的，这样我们就可以很方便地以异步的方式调用系统命令了，spawn是不支持callback函数的，通过stream的方式发数据传给主进程，从而实现了多进程之间的数据交换。

这个功能的直接用应用场景就是“系统监控”。在Linux下，我们有很多命令行工具，可以实时监控CPU,内存,IO,网络等数据，那么用Node的child_process模块可以很容易地把这些数据采集的我们自己的应用中。

比如，我们用mpstat命令，监控用户CPU的使用情况。先看看mpstat命令直接使用的效果。

 1 ~ mpstat 1
 2 Linux 3.13.0-32-generic (ape3)  03/20/2015      _x86_64_        (4 CPU)
 3 11:45:56 AM  CPU    %usr   %nice    %sys %iowait    %irq   %soft  %steal  %guest  %gnice   %idle
 4 11:45:57 AM  all   96.50    0.00    3.50    0.00    0.00    0.00    0.00    0.00    0.00    0.00
 5 11:45:58 AM  all   96.50    0.00    3.25    0.00    0.25    0.00    0.00    0.00    0.00    0.00
 6 11:45:59 AM  all   96.50    0.00    3.50    0.00    0.00    0.00    0.00    0.00    0.00    0.00
 7 11:46:00 AM  all   96.50    0.00    3.50    0.00    0.00    0.00    0.00    0.00    0.00    0.00
 8 11:46:01 AM  all   96.26    0.00    3.24    0.00    0.25    0.00    0.25    0.00    0.00    0.00
 9 11:46:02 AM  all   96.75    0.00    3.25    0.00    0.00    0.00    0.00    0.00    0.00    0.00
10 11:46:03 AM  all   96.51    0.00    3.24    0.00    0.25    0.00    0.00    0.00    0.00    0.00
11 ^C
12 Average:     all   96.50    0.00    3.35    0.00    0.11    0.00    0.04    0.00    0.00    0.00

我们新建文件mpstat.js，读取mpstat命令的数据，然后只输出%usr的数据。

 1 ~ vi mpstat.js
 2 
 3 var child = require(‘child_process‘);
 4 var mpstat = child.spawn(‘mpstat‘, [‘1‘]);
 5 
 6 //Linux 3.13.0-32-generic (ape3)  03/20/2015      _x86_64_        (4 CPU)
 7 //11:27:12 AM  CPU    %usr   %nice    %sys %iowait    %irq   %soft  %steal  %guest  %gnice   %idle
 8 //11:27:13 AM  all   96.50    0.00    3.50    0.00    0.00    0.00    0.00    0.00    0.00    0.00
 9 
10 var line = 0;
11 var cols = ["time","day","CPU","%usr","%nice","%sys","%iowait","%irq","%soft","%steal","%guest","%gnice","%idle"];
12 mpstat.stdout.on(‘data‘, function (data) {
13     var str = data.toString();
14     if(line > 2) {
15         var arr = str.split(/\s+/);
16         console.log(arr[0]+" "+cols[3]+" "+arr[3]);
17     }else{
18        line++;
19     }
20 });
21 mpstat.stderr.on(‘data‘, function (data) {
22     console.log(‘stderr: ‘ + data);
23 });
24 mpstat.on(‘exit‘, function (code) {
25     console.log(‘child process exited with code ‘ + code);
26 });

运行程序：

1 ~ node mpstat.js
2 11:47:57 %usr 96.75
3 11:47:58 %usr 96.52
4 11:47:59 %usr 96.75
5 11:48:00 %usr 96.25
6 11:48:01 %usr 96.74
7 11:48:02 %usr 96.51
8 11:48:03 %usr 96.74
9 11:48:04 %usr 96.51

这样就完成系统数据的采集，我们可以把采集到的数据存储到数据库中，通过websocket等协议直接输出的浏览器前端进行数据的展示。监控系统的例子，可以参考我之前写过的一篇文章：websocket服务器监控

2.2 exec函数

exec函数是对spawn的一种友好封装，增加Shell命令解析，可以直接嵌入复杂的命令，比如，管道用法 cat spawn.js exec.js | wc。

我先试用wc命令来统计一下当前目录的文件字数，分别对应3列为字节数、字数、行数。

1 ~ wc *
2    9   29  275 exec.js
3   25   95  878 mpstat.js
4   16   41  343 spawn.js
5   50  165 1496 total
6 
7 ~ cat *.js | wc
8      50     165    1496

接下来，我们使用exec函数，来使用Linux管道命令。

 1 ~ vi exec.js
 2 
 3 var childProcess = require(‘child_process‘);
 4 
 5 var ls = childProcess.exec(‘cat *.js | wc‘, function (error, stdout, stderr) {
 6    if (error) {
 7      console.log(error.stack);
 8      console.log(‘Error code: ‘+error.code);
 9    }
10    console.log(‘Child Process STDOUT: ‘+stdout);
11 });

运行程序：

1 ~ node exec.js
2 Child Process STDOUT:      50     165    1496

输出结果与Linux命令类似，而且用exec时，命令可以写成一个完整的字符串了，不用像spawn函数时分开写成多个参数数组的形式。最后通过一个callback函数来返回，更符合Javascript的函数调用习惯，通常情况我们可以用exec来替换spawn的使用。

2.3 execFile函数

execFile函数会直接执行特定的程序，参数作为数组传入，不会被bash解释，因此具有较高的安全性。execFile与spawn的参数相似，也需要分别指定执行的命令和参数，但可以接受一个回调函数，与exec的回调函数相同。

我们看一个execFile函数的例子。

1 ~ vi execFile.js
2 
3 var childProcess = require(‘child_process‘);
4 var path = ".";
5 childProcess.execFile(‘/bin/ls‘, [‘-l‘, path], function (err, result) {
6     console.log(result)
7 });

运行程序

1 ~ node execFile.js
2 total 16
3 -rw-r--r-- 1 root root 527 Mar 20 13:23 execFile.js
4 -rw-r--r-- 1 root root 275 Mar 20 13:11 exec.js
5 -rw-r--r-- 1 root root 878 Mar 20 11:53 mpstat.js
6 -rw-r--r-- 1 root root 343 Mar 20 11:11 spawn.js

那么，什么时候使用exec，什么时候使用execFile呢？

如果命令参数是由用户来输入的，对于exec函数来说是有安全性风险的，因为Shell会运行多行命令，比如’ls -l .;pwd，如逗号分隔，之后的命令也会被系统运行。但使用exeFile命令时，命令和参数分来，防止了参数注入的安全风险。

我们用程序测试一下。

 1 ~ vi execFile.js
 2 
 3 // exec
 4 var cmd = ‘ls -l .;pwd‘
 5 var ls = childProcess.exec(cmd, function (error, stdout, stderr) {
 6    if (error) {
 7      console.log(error.stack);
 8      console.log(‘Error code: ‘+error.code);
 9    }
10    console.log(‘Child Process STDOUT: ‘+stdout);
11 });
12 
13 // execFile
14 var path = ".;pwd";
15 childProcess.execFile(‘/bin/ls‘, [‘-l‘, path], function (err, result) {
16     console.log(result)
17 });

运行程序

 1 ~  node execFile.js
 2 
 3 { [Error: Command failed: /bin/ls -l .;pwd
 4 /bin/ls: cannot access .;pwd: No such file or directory
 5 ] killed: false, code: 2, signal: null, cmd: ‘/bin/ls -l .;pwd‘ }
 6 
 7 Child Process STDOUT: total 16
 8 -rw-r--r-- 1 root root 547 Mar 20 13:31 execFile.js
 9 -rw-r--r-- 1 root root 275 Mar 20 13:11 exec.js
10 -rw-r--r-- 1 root root 878 Mar 20 11:53 mpstat.js
11 -rw-r--r-- 1 root root 343 Mar 20 11:11 spawn.js
12 /disk1/demo/nodejs-childprocess

从输出结果看到，exec函数被正常执行，而execFile函数，则提示参数错误。

2.4 fork

fork函数，用于在子进程中运行的模块，如 fork(‘./son.js’) 相当于 spawn(‘node’, [‘./son.js’]) 。与spawn方法不同的是，fork会在父进程与子进程之间，建立一个通信管道，用于进程之间的通信。

我们一个主进程和子进程通信的例子，主进程文件main.js和子进程文件son.js。

新建主进程文件。

1 ~ main.js
2 
3 var childProcess = require(‘child_process‘);
4 var n = childProcess.fork(‘./son.js‘);
5 
6 n.on(‘message‘, function(m) {
7   console.log(‘Main Listen: ‘, m);
8 });
9 n.send({ hello: ‘son‘ });

新建子进程文件。

1 ~ vi son.js
2 
3 process.on(‘message‘, function(m) {
4   console.log(‘Son Listen:‘, m);
5 });
6 process.send({ Hello: ‘conan‘ });

运行程序：

1 ~ node main.js
2 Main Listen:  { Hello: ‘conan‘ }
3 Son Listen: { hello: ‘son‘ }

通过main.js启动子进程son.js，通过process在两个进程之间传递数据。我们对系统进程进行检查，看看是否确实有两个进程。

1 ~ ps -aux|grep node
2 root     22777  0.2  0.1 603240 13252 pts/3    Sl+  14:25   0:00 node main.js
3 root     22782  0.2  0.1 603540 13516 pts/3    Sl+  14:25   0:00 /usr/local/bin/node ./son.js

有2个node进程分别是node main.js和node ./son.js。

掌握了进程之间的通信，我们可以做的事情就比较多了，比如自己做一个Node.js多进程管理器，调度器之类。相对于Java的多线程管理或者进程调度来说，Node程序是如此简单明了的。我已经非常明显的感觉到了编程语言在进步！！

转载请注明出处：
http://blog.fens.me/nodejs-child-process

[转载]进程通信模块child_process——nodejs中间件系列

推荐阅读

go
知识图谱——机器大脑中的知识库

本文介绍了知识图谱在机器大脑中的应用，以及搜索引擎在知识图谱方面的发展。以谷歌知识图谱为例，说明了知识图谱的智能化特点。通过搜索引擎用户可以获取更加智能化的答案，如搜索关键词"Marie Curie"，会得到居里夫人的详细信息以及与之相关的历史人物。知识图谱的出现引起了搜索引擎行业的变革，不仅美国的微软必应，中国的百度、搜狗等搜索引擎公司也纷纷推出了自己的知识图谱。 ... [详细]

蜡笔小新 2023-12-14 10:06:19
php
Java验证码——kaptcha的使用配置及样式

本文介绍了如何使用kaptcha库来实现Java验证码的配置和样式设置，包括pom.xml的依赖配置和web.xml中servlet的配置。 ... [详细]

蜡笔小新 2023-12-13 13:58:25
php
asp.net微信公众平台开发目录汇总陆续更新的相关内容

本文内容为asp.net微信公众平台开发的目录汇总，包括数据库设计、多层架构框架搭建和入口实现、微信消息封装及反射赋值、关注事件、用户记录、回复文本消息、图文消息、服务搭建（接入）、自定义菜单等。同时提供了示例代码和相关的后台管理功能。内容涵盖了多个方面，适合综合运用。 ... [详细]

蜡笔小新 2023-12-14 22:40:22
php
Linux进程控制块PCBtask_struct结构体结构及作用详解

本文详细介绍了Linux中进程控制块PCBtask_struct结构体的结构和作用，包括进程状态、进程号、待处理信号、进程地址空间、调度标志、锁深度、基本时间片、调度策略以及内存管理信息等方面的内容。阅读本文可以更加深入地了解Linux进程管理的原理和机制。 ... [详细]

蜡笔小新 2023-12-13 21:31:18
php
java 线程死锁模拟

1，关于死锁的理解死锁，我们可以简单的理解为是两个线程同时使用同一资源，两个线程又得不到相应的资源而造成永无相互等待的情况。 2，模拟死锁背景介绍：我们创建一个朋友 ... [详细]

蜡笔小新 2023-12-13 19:12:25
php
后台获取视图对应的字符串

1.帮助类后台获取视图对应的字符串publicclassViewHelper{将View输出为字符串(注：不会执行对应的ac ... [详细]

蜡笔小新 2023-12-13 18:03:01
php
《数据结构》学习笔记3——串匹配算法性能评估

本文主要讨论串匹配算法的性能评估，包括模式匹配、字符种类数量、算法复杂度等内容。通过借助C++中的头文件和库，可以实现对串的匹配操作。其中蛮力算法的复杂度为O(m*n)，通过随机取出长度为m的子串作为模式P，在文本T中进行匹配，统计平均复杂度。对于成功和失败的匹配分别进行测试，分析其平均复杂度。详情请参考相关学习资源。 ... [详细]

蜡笔小新 2023-12-13 16:16:05
php
动态规划算法的基本步骤及最长递增子序列问题详解

本文详细介绍了动态规划算法的基本步骤，包括划分阶段、选择状态、决策和状态转移方程，并以最长递增子序列问题为例进行了详细解析。动态规划算法的有效性依赖于问题本身所具有的最优子结构性质和子问题重叠性质。通过将子问题的解保存在一个表中，在以后尽可能多地利用这些子问题的解，从而提高算法的效率。 ... [详细]

蜡笔小新 2023-12-13 15:38:19
php
高质量SQL书写的30条建议

本文提供了30条关于优化SQL的建议，包括避免使用select *，使用具体字段，以及使用limit 1等。这些建议是基于实际开发经验总结出来的，旨在帮助读者优化SQL查询。 ... [详细]

蜡笔小新 2023-12-13 13:24:33
php
指针的引用以及在什么情况下使用指针的引用

本文介绍了指针的概念以及在函数调用时使用指针作为参数的情况。指针存放的是变量的地址，通过指针可以修改指针所指的变量的值。然而，如果想要修改指针的指向，就需要使用指针的引用。文章还通过一个简单的示例代码解释了指针的引用的使用方法，并思考了在修改指针的指向后，取指针的输出结果。 ... [详细]

蜡笔小新 2023-12-13 12:54:29
php
工程中添加Android Dependencies

在project.properties添加#Projecttarget.targetandroid-19android.library.reference.1..Sliding ... [详细]

蜡笔小新 2023-12-13 12:08:09
php
CentOS 7部署KVM虚拟化环境之一架构介绍

本文介绍了CentOS 7部署KVM虚拟化环境的架构，详细解释了虚拟化技术的概念和原理，包括全虚拟化和半虚拟化。同时介绍了虚拟机的概念和虚拟化软件的作用。 ... [详细]

蜡笔小新 2023-12-12 21:38:57
php
解析GRE报文长度的方法及实现步骤

本文介绍了一种解析GRE报文长度的方法，通过分析GRE报文头中的标志位来计算报文长度。具体实现步骤包括获取GRE报文头指针、提取标志位、计算报文长度等。该方法可以帮助用户准确地获取GRE报文的长度信息。 ... [详细]

蜡笔小新 2023-12-12 20:55:05
php
PDF内容编辑的两种小方法，你知道怎么操作吗？

本文介绍了两种PDF内容编辑的方法：迅捷PDF编辑器和Adobe Acrobat DC。使用迅捷PDF编辑器，用户可以通过选择需要更改的文字内容并设置字体形式、大小和颜色来编辑PDF文件。而使用Adobe Acrobat DC，则可以通过在软件中点击编辑来编辑PDF文件。PDF文件的编辑可以帮助办公人员进行文件内容的修改和定制。 ... [详细]

蜡笔小新 2023-12-12 19:37:50
php
CentOS 6.5安装VMware Tools及共享文件夹显示问题解决方法

本文介绍了在CentOS 6.5上安装VMware Tools及解决共享文件夹显示问题的方法。包括清空CD/DVD使用的ISO镜像文件、创建挂载目录、改变光驱设备的读写权限等步骤。最后给出了拷贝解压VMware Tools的操作。 ... [详细]

蜡笔小新 2023-12-12 18:18:49

小伟

这个家伙很懒，什么也没留下！

Tags | 热门标签

RankList | 热门文章