Linux进程间通信的常用方式

Love The Way You Lie 2022-01-12 07:13 187阅读 0赞

### 文章目录 ###

*  1.pipe匿名管道实现进程间通信
 *  2.fifo有名管道进行进程间通信
 *  3.共享内存实现进程间的通信
 *  4.有关于ipcs -q/m/s和ipcrm -q/m/s的用法

# 1.pipe匿名管道实现进程间通信 #

[关于进程间通信的相关概念,请点击这里][Link 1]

pipe实现进程间通信

#include <stdio.h>
    #include <unistd.h>
    #include <string.h>
    #include <sys/types.h>
    #include <sys/stat.h>
    #include <stdlib.h>
    
    int main()
    { 
    //创建两个文件描述符
      int fd[2];
      //用文件描述符创建管道
      int ret=pipe(fd);
      //创建子进程
      pid_t pid=fork();
      //如果是子进程 执行ps aux函数,使用execlp实现进程函数替换
      if(pid==0) { 
      	//实现标准输入输出重定向,dup2函数实现fd[1]对应管道的写端
        dup2(fd[1],1);
        //为了数据安全,在给管道写入数据时最好关闭管道的读端
        close(fd[0]);
        //execlp函数替换程序
        execlp("ps","ps","aux",NULL);
      }
      //如果是父进程,执行 grep | pipe操作 其他操作与子进程基本一致
      else if(pid>0) { 
        dup2(fd[0],0);
        close(fd[1]);
        execlp("grep","grep","pipe","--color=auto",NULL);
      }
      return 0;
    }

# 2.fifo有名管道进行进程间通信 #

FIFO通信写端代码实现

#include <stdio.h>
    #include <unistd.h>
    #include <stdlib.h>
    #include <string.h>
    #include <sys/types.h>
    #include <sys/stat.h>
    #include <fcntl.h>
    
    int main()
    { 
      //使用一个指针来表示创建管道的路径和名称
      char* fifo="./test.fifo";
      //修改掩码值,给管道赋予权限
      umask(0);
      //创建有名管道
      int ret=mkfifo(fifo,0664);
      //判断管道是否创建成功
      if(ret<0) { 
        perror("mkfifo");
        return -1;
      }
      printf("start open fifo\n");
      //打开管道的写端
      int fd=open(fifo,O_WRONLY);
      printf("end open fifo\n");
      if(fd<0) { 
        perror("open");
        return -1;
      }
      printf("open fifo success\n");
      //给管道中写入数据
      while(1) { 
        char buf[1024]={ 0};
        printf("i say:");
        //刷新显示器的缓冲区
        fflush(stdout);
        //获取字符,写入管道
        scanf("%s",buf);
        write(fd,buf,strlen(buf));
      }
      //切记,当完成操作时需要关闭文件
      close(fd);
      return 0;
    }

FIFO通信读端代码实现

#include <stdio.h>
    #include <string.h>
    #include <stdlib.h>
    #include <sys/types.h>
    #include <sys/stat.h>
    #include <fcntl.h>
    #include <unistd.h>
    int main()
    { 
      //写端已经创建好有名管道,读端无需重复创建
      char* fifo="./test.fifo";
      //umask(0);
      //int ret=mkfifo(fifo,0664);
      //if(ret<0) { 
       // perror("mkfifo");
       // return -1;
      //}
      printf("start open fifo\n");
      //打开管道的读权限
      int fd=open(fifo,O_RDONLY);
      printf("end open fifo\n");
      if(fd<0) { 
        perror("open fifo");
        return -1;
      }
      printf("fifo:%d open fifo success\n",fifo);
      //从管道中往出读数据
      while(1) { 
        sleep(5);
        char buf[1024]={ 0};
        //把文件中的数据读到buf中
        read(fd,buf,1023);
        //把buf中的值打印出来
        printf("peer say:%s\n",buf);
      }
      //切记关闭文件
      close(fd);
      return 0;
    }

# 3.共享内存实现进程间的通信 #

共享内存通信写端代码实现

#include <stdio.h>
    #include <stdlib.h>
    #include <unistd.h>
    #include <string.h>
    #include <sys/types.h>
    #include <sys/stat.h>
    #include <sys/shm.h>
    #include <fcntl.h>
    //定义好虚拟地址
    #define IPC_KEY 0x12345678
    int main()
    { 
      int shmid=shmget(IPC_KEY,32,IPC_CREAT|0664);
      if(shmid<0) { 
        perror("shmget");
        return -1;
      }
      void* shm_start=shmat(shmid,NULL,0);
      if(shm_start==(void*)-1){ 
        perror("shmat");
        return -1;
      }
      int i=0;
      while(1) { 
        sprintf(shm_start,"%s-%d","明天很开心~~",i++);
        sleep(1);
      }
      shmdt(shm_start);
      shmctl(shmid,IPC_RMID,NULL);
      return 0;
    }

共享内存通信读端代码实现

#include <stdio.h>
    #include <unistd.h>
    #include <string.h>
    #include <sys/shm.h>
    #include <sys/stat.h>
    #include <fcntl.h>
    #define IPC_KEY 0x12345678
    int main()
    { 
      int shmid=shmget(IPC_KEY,32,IPC_CREAT|0664);
      if(shmid<0) { 
        perror("shmget");
      }
      void* shm_start=shmat(shmid,NULL,0);
      if(shm_start==(void*)-1) { 
        perror("shmat");
        return -1;
      }
      int i=0;
      while(1) { 
        printf("%s\n",shm_start);
        sleep(1);
      }
      shmdt(shm_start);
      shmctl(shmid,IPC_RMID,NULL);
      return 0;
    }

# 4.有关于ipcs -q/m/s和ipcrm -q/m/s的用法 #

ipc -q 查看计算机的消息队列的详细信息  
ipc -m查看计算机共享内存的详细信息  
ipc -s查看计算机中信号量的详细信息

ipcrm -q -id 按id号移除消息队列  
ipcrm -m -id 按id移除共享内存段  
ipcrm -s -id 按id号移除信号量

[Link 1]: https://weihang2020.club/2019/05/22/Linux%E8%BF%9B%E7%A8%8B%E9%97%B4%E9%80%9A%E4%BF%A1-%E7%AE%A1%E9%81%93/#more