node进程间如何通信?下面本篇文章带大家了解node进程的通信方式,以及在node中如何实现这些方式的通信,希望对大家有所帮助!
通信其实涵盖开发的各个层面,常见的有客户端和服务端通过各种通信协议进行通信,rpc通信,开发过程中各个模块之间的相互通信,electron主进程和渲染进程之间的通信等等;
本文主要是尝试总结下nodejs(单线程,多线程,多进程)通信的方式,使用场景,实现等。
通信的实现方式一般进程通信的实现方式如下:
1、shared memory(内存共享);
2、socket(套接字);
3、管道(非命名管道pipe, 命名管道fifo);
4、signal(信号);
5、message queue(消息队列);
下面我们看下在node中如何实现这些方式的通信
一、shared memory(内存共享)单机下(客户端内单线程,单进程里多线程,单台服务器内多进程),通过内存共享实现通信的方式最为常见。
shared memory(内存共享)-单线程从操作系统层面来看,进程内所有线程内存都是共享的,但前提是需要知道内存的访问地址。
但从语言层面(node或者说是v8的实现层面),我们没有直接接触内存的管理,而是间接从v8提供的语法/api进行内存操作。v8提供三种方式给我们共享内存(也许叫共享变量更恰当):全局变量, 局部变量, 共享传参(call by sharing);
v8在执行代码之前会先将代码通过estree规范转化为抽象语法树后再进行解释编译执行,在抽象语法树中(关于抽象语法树可查看我另外一篇文章)是有scope的,而内存读取是通过标志符(变量命名)逐级往上回溯查找。所以如果你需要在两个方法之间共享某个内存,可以在他们共同的作用域下进行创建。
shared memory(内存共享)-多线程在客户端环境或node环境,我们都可以实现多线程,两者方式也类似(node通过worker_threads实现,浏览器通过worker实现)。这里的内存共享主要是借助内存操作的api(sharedarraybuffer)实现的。先看下浏览器实现的例子:
// 主线程const buffer = new sharedarraybuffer(1024)const typedarr = new int16array(buffer)const newworker = new worker('./worker.js')typedarr[0] = 20newworker.postmessage(buffer)newworker.onmessage= (data) => { console.group('[the main thread]'); console.log('data received from the main thread: %i', typedarr[0]); console.groupend();}// 子线程addeventlistener('message', ({ data }) => { const arr = new int16array(data) console.group('[the worker thread]') console.log('data received from the main thread: %i', arr[0]) console.groupend() arr[0] = 18 postmessage('updated')})// 结果[the worker thread] data received from the main thread: 20[the main thread] data received from the main thread: 18
shared memory(内存共享)-多进程因为进程启动后内存是无法相互读取的(系统层面的限制),进程之间的内存共享实际是通过新开辟一段shared memory实现的。但node暂时没有支持shared memory,只能通过低级语言来实现,例如: c++实现的 shared-memory-disruptor addon插件(另外文章介绍)。
二、socket(套接字)socket 分两种实现:
1、tcp socket;
2、unix domain socket;
两者的主要区别如下:
tcp socket适用于单机,c/s架构等.但unix domain socket只适用于单机。 unix domain socket不需要经过一系列的网络中转(协议,分包,校验等等),性能更高,稳定性更好。
tcp socket概念: tcp socket是应用层与tcp/ip协议族通信的中间抽象层,是一种操作系统提供的进程间通信机制;
tcp socket通信应该是我们日常开发(c/s架构)中最常见的通信方式之一,在我们日常开发中最常见的就是各种应用层协议(http,websocket,rpc,ftp等)的使用,node中http模块也是基于net模块实现的。
注:其实udp也属于tcp分层(并不是严格的指tcp通信,而是网络通信层中的tcp/ip层),node有提供'dgram'模块来实现,但在实际应用中没有接触过,所以不进行了解。
net在node中,tcp socket是由net模块实现的,net模块主要提供了以下功能:
1、上层的ipc支持(实际上是管道通信的实现,后面管道通信再详细说明);
2、net.server类;
// 服务端通过net.createserver创建服务,会返回net.server对象,可以通过返回值进行各种事件监听,端口监听const net = require('net')net.createserver((server => { server.end(`hello world!\n`)})).listen(3302, () => { console.log(`running ...`)})
3、net.socket类;
const net = require('net')const socket = net.createconnection({port: 3302})socket.on('data', data => { console.log(data.tostring())})
unix domain socketunix domain socket是通过创建一个文件描述符,不同进程之间的通信通过读写这个文件描述符进行通信(可以分为创建进程和其他进程,其他进程之间的相互通信可以通过创建进程作为中转)。e.g.
// 创建进程const net = require('net')const unixsocketserver = net.createserver(server => { server.on('data', data => { console.log(`receive data: ${data}`) })})unixsocketserver.listen('/tmp/test', () => { console.log('listening...')})// 其他进程const net = require('net')const socket = net.createconnection({path: '/tmp/test'})socket.on('data', data => { console.log(data.tostring())})socket.write('my name is vb')// 输出结果listening...receive data: my name is vb
三、管道管道通信分两种,非命名管道和命名管道。
非命名管道的实现方式和unix domain socket一样,都是通过创建文件描述符进行通信。
命名管道是通过固定的文件描述符进行通信:
"\\\\.\\pipe\\" + pipe_name;
源码可参考stackoverflow(https://stackoverflow.com/questions/11750041/how-to-create-a-named-pipe-in-node-js)
目前理解的管道通信和unix domain socket实现基本一致,只是管道通信规范了读写权限,半双工通信,unix domain socket更加自由一些。
四、signal(信号)signal是操作系统在终止进程前给进程发送的信号。在node中可以通过process.kill(pid, signal)/child_process.kill(pid, signal)接口实现,e.g.
// 要被终止的http守护进程const koa = require('koa')const app = new koa()app.listen(3004, () => { console.log(`process pid is : ${process.pid}`) // process pid is : 75208})// 操作进程process.kill(75208, 'sighup') // 'sighup'是一般结束进程的信号,还有更多其他的信号参考 [标识](https://blog.csdn.net/houjixin/article/details/71430489)
但这里的前提是你需要获取到被终止的进程pid,更多pid的内容可阅读我之前关于进程的文章。
五、message queue(消息队列)一开始我以为是redis,各种mq之类的基于tcp的消息队列。但其实是操作系统内的消息队列,node暂时没有提供相关的上层接口,需要更底层实现,e.g. svmq
更多node相关知识,请访问:nodejs 教程!!
以上就是详解node中进程通信的几种实现方式的详细内容。