详解两个Node.js进程是如何通信
前言
两个 Node.js 进程之间如何进行通信呢？这里要分两种场景：
- 不同电脑上的两个 Node.js 进程间通信
- 同一台电脑上两个 Node.js 进程间通信
对于第一种场景，通常使用 TCP 或 HTTP 进行通信，而对于第二种场景，又分为两种子场景：
- Node.js 进程和自己创建的 Node.js 子进程通信
- Node.js 进程和另外不相关的 Node.js 进程通信
前者可以使用内置的 IPC 通信通道，后者可以使用自定义管道，接下来进行详细介绍：
不同电脑上的两个 Node.js 进程间通信
要想进行通信，首先得搞清楚如何标识网络中的进程？网络层的 ip 地址可以唯一标识网络中的主机，而传输层的协议和端口可以唯一标识主机中的应用程序（进程），这样利用三元组（ip 地址，协议，端口）就可以标识网络的进程了。
使用 TCP 套接字
TCP 套接字（socket）是一种基于 TCP/IP 协议的通信方式，可以让通过网络连接的计算机上的进程进行通信。一个作为 server 另一个作为 client，server.js 代码如下：
const net = require('net')
const server = net.createServer(socket => {
console.log('socket connected')
socket.on('close', () => console.log('socket disconnected'))
socket.on('error', err => console.error(err.message))
socket.on('data', data => {
console.log(`receive: ${data}`)
socket.write(data)
console.log(`send: ${data}`)
})
})
server.listen(8888)
client.js 代码：
const net = require('net')
const client = net.connect(8888, '192.168.10.105')
client.on('connect', () => console.log('connected.'))
client.on('data', data => console.log(`receive: ${data}`))
client.on('end', () => console.log('disconnected.'))
client.on('error', err => console.error(err.message))
setInterval(() => {
const msg = 'hello'
console.log(`send: ${msg}`)
client.write(msg)
}, 3000)
运行效果：
$ node server.js client connected receive: hello send: hello $ node client.js connect to server send: hello receive: hello
使用 HTTP 协议
因为 HTTP 协议也是基于 TCP 的，所以从通信角度看，这种方式本质上并无区别，只是封装了上层协议。server.js 代码为：
const http = require('http')
http.createServer((req, res) => res.end(req.url)).listen(8888)
client.js 代码：
const http = require('http')
const options = {
hostname: '192.168.10.105',
port: 8888,
path: '/hello',
method: 'GET',
}
const req = http.request(options, res => {
console.log(`statusCode: ${res.statusCode}`)
res.on('data', d => process.stdout.write(d))
})
req.on('error', error => console.error(error))
req.end()
运行效果：
$ node server.js url /hello $ node client.js statusCode: 200 hello
同一台电脑上两个 Node.js 进程间通信
虽然网络 socket 也可用于同一台主机的进程间通讯（通过 loopback 地址 127.0.0.1），但是这种方式需要经过网络协议栈、需要打包拆包、计算校验和、维护序号和应答等，就是为网络通讯设计的，而同一台电脑上的两个进程可以有更高效的通信方式，即 IPC（Inter-Process Communication），在 unix 上具体的实现方式为 unix domain socket，这是服务器端和客户端之间通过本地打开的套接字文件进行通信的一种方法，与 TCP 通信不同，通信时指定本地文件，因此不进行域解析和外部通信，所以比 TCP 快，在同一台主机的传输速度是 TCP 的两倍。
使用内置 IPC 通道
如果是跟自己创建的子进程通信，是非常方便的，child_process 模块中的 fork 方法自带通信机制，无需关注底层细节，例如父进程 parent.js 代码：
const fork = require("child_process").fork
const path = require("path")
const child = fork(path.resolve("child.js"), [], { stdio: "inherit" });
child.on("message", (message) => {
console.log("message from child:", message)
child.send("hi")
})
子进程 child.js 代码：
process.on("message", (message) => {
console.log("message from parent:", message);
})
if (process.send) {
setInterval(() => process.send("hello"), 3000)
}
运行效果如下：
$ node parent.js message from child: hello message from parent: hi message from child: hello message from parent: hi
使用自定义管道
如果是两个独立的 Node.js 进程，如何建立通信通道呢？在 Windows 上可以使用命名管道（Named PIPE），在 unix 上可以使用 unix domain socket，也是一个作为 server，另外一个作为 client，其中 server.js 代码如下：
const net = require('net')
const fs = require('fs')
const pipeFile = process.platform === 'win32' ? '\\\\.\\pipe\\mypip' : '/tmp/unix.sock'
const server = net.createServer(connection => {
console.log('socket connected.')
connection.on('close', () => console.log('disconnected.'))
connection.on('data', data => {
console.log(`receive: ${data}`)
connection.write(data)
console.log(`send: ${data}`)
})
connection.on('error', err => console.error(err.message))
})
try {
fs.unlinkSync(pipeFile)
} catch (error) {}
server.listen(pipeFile)
client.js 代码如下：
const net = require('net')
const pipeFile = process.platform === 'win32' ? '\\\\.\\pipe\\mypip' : '/tmp/unix.sock'
const client = net.connect(pipeFile)
client.on('connect', () => console.log('connected.'))
client.on('data', data => console.log(`receive: ${data}`))
client.on('end', () => console.log('disconnected.'))
client.on('error', err => console.error(err.message))
setInterval(() => {
const msg = 'hello'
console.log(`send: ${msg}`)
client.write(msg)
}, 3000)
运行效果：
$ node server.js socket connected. receive: hello send: hello $ node client.js connected. send: hello receive: hello
总结
到此这篇关于两个Node.js进程是如何通信的文章就介绍到这了,更多相关两个Node.js进程通信内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
Node.js是一个基于Chrome V8引擎的JavaScript运行环境，它的模块查找、引用和缓存机制是其重要的特性之一。本文将介绍Node.js的模块查找、引用和缓存机制，以及如何利用这些机制来提高应用程序的性能和可维护性。2023-03-03
在开发过程中有时候会遇到老项目和新项目node版本不一致的情况,这篇文章主要给大家介绍了关于NVM管理node版本以及报错解决方法的相关资料,文中通过图文介绍的非常详细,需要的朋友可以参考下2023-12-12
NPM 安装cordova时警告:npm WARN deprecated minimatch@2.0.10: Pleas
这篇文章主要介绍了NPM 安装cordova时警告:npm WARN deprecated minimatch@2.0.10: Please update to minimatch 3.0.2 or higher to的相关资料,需要的朋友可以参考下2016-12-12
Node.js+jade抓取博客所有文章生成静态html文件的实例
下面小编就为大家带来一篇Node.js+jade抓取博客所有文章生成静态html文件的实例。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧2017-09-09
这篇文章主要介绍了Nodejs实现的操作MongoDB数据库功能,结合完整实例形式分析了nodejs针对MongoDB数据库的连接及增删改查基本操作技巧,需要的朋友可以参考下2019-02-02
ExpressJS 4.0中提出了新的路由Router，提供了路由应有的API，本文详细的介绍了ExpressJS 4.0中的新Router的用法，非常具有实用价值，需要的朋友可以参考下2018-11-11
这篇文章主要介绍了ExpressJS入门实例,本文讲解了创建项目、进入目录、安装项目依赖的包、创建应用程序、运行程序等内容,需要的朋友可以参考下2015-01-01
本文主要介绍了NodeJS实现客户端js加密的思路与方法，具有一定的参考价值，下面跟着小编一起来看下吧2017-01-01
这篇文章主要给大家介绍了node.js实现复制文本到剪切板的功能，文中介绍的非常详细，并给出示例代码，相信对大家具有一定的参考借鉴价值，有需要的朋友们下面来一起看看吧。2017-01-01
今天小编就为大家分享一篇利用npm 安装删除模块的方法，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2018-05-05
最新评论