进程间怎么进行通信？下面本篇文章给大家介绍一下Nodejs进程间通信的原理，希望对大家有所帮助！
|
进程间怎么进行通信？下面本篇文章给大家介绍一下Node进程间通信的原理，希望对大家有所帮助！
前置知识文件描述符在 Linux 系统中，一切都看成文件，当进程打开现有文件时，会返回一个文件描述符。 文件描述符是操作系统为了管理已经被进程打开的文件所创建的索引，用来指向被打开的文件。 当我们的进程启动之后，操作系统会给每一个进程分配一个 PCB 控制块，PCB 中会有一个文件描述符表，存放当前进程所有的文件描述符，即当前进程打开的所有文件。 ? 进程中的文件描述符是如何和系统文件对应起来的？ 在内核中，系统会维护另外两种表
文件描述符就是数组的下标，从0开始往上递增，0/1/2 默认是我们的输入/输出/错误流的文件描述符 在 PCB 中维护的文件描述表中，可以根据文件描述符找到对应了文件指针，找到对应的打开文件表 打开文件表中维护了：文件偏移量(读写文件的时候会更新)；对于文件的状态标识；指向 i-node 表的指针 想要真正的操作文件，还得靠 i-node 表，能够获取到真实文件的相关信息 他们之间的关系
图解
总结
文件描述符的重定向每次读写进程的时候，都是从文件描述符下手，找到对应的打开文件表项，再找到对应的 i-node 表 ?如何实现文件描述符重定向？ 因为在文件描述符表中，能够找到对应的文件指针，如果我们改变了文件指针，是不是后续的两个表内容就发生了改变 例如：文件描述符1指向的显示器，那么将文件描述符1指向 log.txt 文件，那么文件描述符 1 也就和 log.txt 对应起来了 shell 对文件描述符的重定向> 是输出重定向符号，< 是输入重定向符号，它们是文件描述符操作符 > 和 < 通过修改文件描述符改变了文件指针的指向，来能够实现重定向的功能 我们使用
c函数对文件描述符的重定向dupdup 函数是用来打开一个新的文件描述符，指向和 oldfd 同一个文件，共享文件偏移量和文件状态 int main(int argc, char const *argv[])
{
int fd = open("log.txt");
int copyFd = dup(fd);
//将fd阅读文件置于文件末尾，计算偏移量。
cout << "fd = " << fd << " 偏移量： " << lseek(fd, 0, SEEK_END) << endl;
//现在我们计算copyFd的偏移量
cout << "copyFd = " << copyFd << "偏移量：" << lseek(copyFd, 0, SEEK_CUR) << endl;
return 0;
}
调用 dup(3) 的时候，会打开新的最小描述符，也就是4，这个4指向了3所指向的文件，操作任意一个 fd 都是修改的一个文件 dup2dup2 函数，把指定的 newfd 也指向 oldfd 指向的文件。执行完dup2之后，newfd 和 oldfd 同时指向同一个文件，共享文件偏移量和文件状态 int main(int argc, char const *argv[])
{
int fd = open("log.txt");
int copyFd = dup(fd);
//将fd阅读文件置于文件末尾，计算偏移量。
cout << "fd = " << fd << " 偏移量： " << lseek(fd, 0, SEEK_END) << endl;
//现在我们计算copyFd的偏移量
cout << "copyFd = " << copyFd << "偏移量：" << lseek(copyFd, 0, SEEK_CUR) << endl;
return 0;
}
Node中通信原理Node 中的 IPC 通道具体实现是由 libuv 提供的。根据系统的不同实现方式不同，window 下采用命名管道实现，*nix 下采用 Domain Socket 实现。在应用层只体现为 message 事件和 send 方法。【相关教程推荐：nodejs视频教程】
父进程在实际创建子进程之前，会创建 IPC 通道并监听它，等到创建出真实的子进程后，通过环境变量(NODE_CHANNEL_FD)告诉子进程该 IPC 通道的文件描述符。 子进程在启动的过程中，会根据该文件描述符去连接 IPC 通道，从而完成父子进程的连接。 建立连接之后可以自由的通信了，IPC 通道是使用命名管道或者 Domain Socket 创建的，属于双向通信。并且它是在系统内核中完成的进程通信
?? 只有在启动的子进程是 Node 进程时，子进程才会根据环境变量去连接对应的 IPC 通道，对于其他类型的子进程则无法实现进程间通信，除非其他进程也按着该约定去连接这个 IPC 通道。 unix domain socket是什么我们知道经典的通信方式是有 Socket，我们平时熟知的 Socket 是基于网络协议的，用于两个不同主机上的两个进程通信，通信需要指定 IP/Host 等。 但如果我们同一台主机上的两个进程想要通信，如果使用 Socket 需要指定 IP/Host，经过网络协议等，会显得过于繁琐。所以 Unix Domain Socket 诞生了。 UDS 的优势：
如何实现流程图
Server 端int main(int argc, char *argv[])
{
int server_fd ,ret, client_fd;
struct sockaddr_un serv, client;
socklen_t len = sizeof(client);
char buf[1024] = {0};
int recvlen;
// 创建 socket
server_fd = socket(AF_LOCAL, SOCK_STREAM, 0);
// 初始化 server 信息
serv.sun_family = AF_LOCAL;
strcpy(serv.sun_path, "server.sock");
// 绑定
ret = bind(server_fd, (struct sockaddr *)&serv, sizeof(serv));
//设置监听，设置能够同时和服务端连接的客户端数量
ret = listen(server_fd, 36);
//等待客户端连接
client_fd = accept(server_fd, (struct sockaddr *)&client, &len);
printf("=====client bind file:%s\n", client.sun_path);
while (1) {
recvlen = recv(client_fd, buf, sizeof(buf), 0);
if (recvlen == -1) {
perror("recv error");
return -1;
} else if (recvlen == 0) {
printf("client disconnet...\n");
close(client_fd);
break;
} else {
printf("recv buf %s\n", buf);
send(client_fd, buf, recvlen, 0);
}
}
close(client_fd);
close(server_fd);
return 0;
}Client 端int main(int argc, char *argv[])
{
int client_fd ,ret;
struct sockaddr_un serv, client;
socklen_t len = sizeof(client);
char buf[1024] = {0};
int recvlen;
//创建socket
client_fd = socket(AF_LOCAL, SOCK_STREAM, 0);
//给客户端绑定一个套接字文件
client.sun_family = AF_LOCAL;
strcpy(client.sun_path, "client.sock");
ret = bind(client_fd, (struct sockaddr *)&client, sizeof(client));
//初始化server信息
serv.sun_family = AF_LOCAL;
strcpy(serv.sun_path, "server.sock");
//连接
connect(client_fd, (struct sockaddr *)&serv, sizeof(serv));
while (1) {
fgets(buf, sizeof(buf), stdin);
send(client_fd, buf, strlen(buf)+1, 0);
recv(client_fd, buf, sizeof(buf), 0);
printf("recv buf %s\n", buf);
}
close(client_fd);
return 0;
}命名管道(Named Pipe)是什么命名管道是可以在同一台计算机的不同进程之间，或者跨越一个网络的不同计算机的不同进程之间的可靠的单向或者双向的数据通信。 创建命名管道的进程被称为管道服务端(Pipe Server)，连接到这个管道的进程称为管道客户端(Pipe Client)。 命名管道的命名规范：\server\pipe[\path]\name
怎么实现流程图
Pipe Servervoid ServerTest()
{
HANDLE serverNamePipe;
char pipeName[MAX_PATH] = {0};
char szReadBuf[MAX_BUFFER] = {0};
char szWriteBuf[MAX_BUFFER] = {0};
DWORD dwNumRead = 0;
DWORD dwNumWrite = 0;
strcpy(pipeName, "\\\\.\\pipe\\shuangxuPipeTest");
// 创建管道实例
serverNamePipe = CreateNamedPipeA(pipeName,
PIPE_ACCESS_DUPLEX|FILE_FLAG_WRITE_THROUGH,
PIPE_TYPE_BYTE|PIPE_READMODE_BYTE|PIPE_WAIT,
PIPE_UNLIMITED_INSTANCES, 0, 0, 0, NULL);
WriteLog("创建管道成功...");
// 等待客户端连接
BOOL bRt= ConnectNamedPipe(serverNamePipe, NULL );
WriteLog( "收到客户端的连接成功...");
// 接收数据
memset( szReadBuf, 0, MAX_BUFFER );
bRt = ReadFile(serverNamePipe, szReadBuf, MAX_BUFFER-1, &dwNumRead, NULL );
// 业务逻辑处理 （只为测试用返回原来的数据）
WriteLog( "收到客户数据:[%s]", szReadBuf);
// 发送数据
if( !WriteFile(serverNamePipe, szWriteBuf, dwNumRead, &dwNumWrite, NULL ) )
{
WriteLog("向客户写入数据失败:[%#x]", GetLastError());
return ;
}
WriteLog("写入数据成功...");
}Pipe Clientvoid ClientTest()
{
char pipeName[MAX_PATH] = {0};
HANDLE clientNamePipe;
DWORD dwRet;
char szReadBuf[MAX_BUFFER] = {0};
char szWriteBuf[MAX_BUFFER] = {0};
DWORD dwNumRead = 0;
DWORD dwNumWrite = 0;
strcpy(pipeName, "\\\\.\\pipe\\shuangxuPipeTest");
// 检测管道是否可用
if(!WaitNamedPipeA(pipeName, 10000)){
WriteLog("管道[%s]无法打开", pipeName);
return ;
}
// 连接管道
clientNamePipe = CreateFileA(pipeName,
GENERIC_READ|GENERIC_WRITE,
0,
NULL,
OPEN_EXISTING,
FILE_ATTRIBUTE_NORMAL,
NULL);
WriteLog("管道连接成功...");
scanf( "%s", szWritebuf );
// 发送数据
if( !WriteFile(clientNamePipe, szWriteBuf, strlen(szWriteBuf), &dwNumWrite, NULL)){
WriteLog("发送数据失败,GetLastError=[%#x]", GetLastError());
return ;
}
printf("发送数据成功:%s\n", szWritebuf );
// 接收数据
if( !ReadFile(clientNamePipe, szReadBuf, MAX_BUFFER-1, &dwNumRead, NULL)){
WriteLog("接收数据失败,GetLastError=[%#x]", GetLastError() );
return ;
}
WriteLog( "接收到服务器返回:%s", szReadBuf );
// 关闭管道
CloseHandle(clientNamePipe);
}Node 创建子进程的流程Unix
对于创建子进程、创建管道、重定向管道均是在 c++ 层实现的 创建子进程int main(int argc,char *argv[]){
pid_t pid = fork();
if (pid < 0) {
// 错误
} else if(pid == 0) {
// 子进程
} else {
// 父进程
}
}创建管道使用 socketpair 创建管道，其创建出来的管道是全双工的，返回的文件描述符中的任何一个都可读和可写 int main ()
{
int fd[2];
int r = socketpair(AF_UNIX, SOCK_STREAM, 0, fd);
if (fork()){ /* 父进程 */
int val = 0;
close(fd[1]);
while (1){
sleep(1);
++val;
printf("发送数据: %d\n", val);
write(fd[0], &val, sizeof(val));
read(fd[0], &val, sizeof(val));
printf("接收数据: %d\n", val);
}
} else { /*子进程*/
int val;
close(fd[0]);
while(1){
read(fd[1], &val, sizeof(val));
++val;
write(fd[1], &val, sizeof(val));
}
}
}当我们使用 socketpair 创建了管道之后，父进程关闭了 fd[1]，子进程关闭了 fd[0]。子进程可以通过 fd[1] 读写数据；同理主进程通过 fd[0]读写数据完成通信。
child_process.fork 的详细调用fork 函数开启一个子进程的流程
句柄传递setupChannel 主要是完成了处理接收的消息、发送消息、处理文件描述符传递等 function setipChannel(){
channel.onread = function(arrayBuffer){
//...
}
target.on('internalMessage', function(message, handle){
//...
})
target.send = function(message, handle, options, callback){
//...
}
target._send = function(message, handle, options, callback){
//...
}
function handleMessage(message, handle, internal){
//...
}
}
进程间消息传递
更多node相关知识，请访问：nodejs 教程！ 以上就是一文聊聊Node中的进程间通信的详细内容，更多请关注模板之家(www.mb5.com.cn)其它相关文章！
|
