Linux进程通信

共享内存mmap(父子进程)

main.cpp

#include <sys/mman.h>
#include <sys/types.h>
#include <fcntl.h>
#include <unistd.h>
#include <stdio.h>
#include <string.h>

typedef struct{
  char name[16];
  int  age;
}people;

const char *names[]={"tom","lily","jerry","david","garrett"};

int main(int argc, char** argv)
{
  int i;
  people *p_map;

  p_map=(people*)mmap(NULL,sizeof(people)*10,PROT_READ|PROT_WRITE,
       MAP_SHARED|MAP_ANONYMOUS,-1,0);

  if(fork() == 0)//儿子进程
  {
        sleep(2);
        for(i = 0;i<5;i++)
          printf("child read: the %d people's age is %d,name is %s\n",i+1,(*(p_map+i)).age,
           p_map[i].name);
        (*p_map).age = 100;
        munmap(p_map,sizeof(people)*10); //实际上，进程终止时，会自动解除映射。
        return 0;
  }
  else
  {
      for(i = 0;i<5;i++)
      {
        memcpy((*(p_map+i)).name, names[i],strlen(names[i]));
        (*(p_map+i)).age=20+i;
      }
      sleep(5);
      printf( "parent read: the first people's age is %d\n",(*p_map).age );
      printf("umap\n");
      munmap( p_map,sizeof(people)*10 );
      printf( "umap ok\n" );
      return 0;
  }
}

makefile:

overpassb:main.o 
    g++ -g -o  overpassb main.o
main.o:main.cpp
    g++ -g -c main.cpp -o main.o
clean:
    rm -f *.o overpassb

共享内存posix(父子进程)

main.cpp

#include<stdio.h>
#include<unistd.h>
#include<stdlib.h>
#include<string.h>

#include<time.h>
#include<signal.h>
#include<sys/ipc.h>
#include<sys/shm.h>
#include<sys/types.h>

int shmID;
char * buf;
 
void finalize(int signo)
{
 shmctl(shmID,IPC_RMID,NULL);
 
 exit(0);
}

int main()
{
 int i = 1;  
 key_t shmKey;
 
 signal(SIGINT,finalize);
 signal(SIGTERM,finalize);
 
 if(fork() == 0) //子进程
 {  
  shmKey = ftok("/dev/null",1);  //可以使用任何大于0的数字，如果名字和数相同，则产生的key相同。
  if(shmKey == -1)
  {
   printf("create key error\n");
   exit(-1);
  }
  
  shmID = shmget(shmKey,20,IPC_CREAT | IPC_EXCL | 0666);
  if(shmID == -1)
  {
   printf("create shamID error\n");
   exit(-1);
  }
  
  //sleep(2); //等待父进程执行，好显示第一行为空。
  while(1)
  {
   buf = (char *)shmat(shmID,NULL,0);//shmat负责把共享的物理内存attach到当前进程空间buf
   srandom(time(NULL));
   sprintf(buf,"%ld",random()%100); 
   shmdt(buf); //shmdt负责把共享内存从当前进程空间detach
  }
 }
 else  //父进程
 {
  sleep(1); //让子进程先执行，以建立内存映射。
  
  shmKey = ftok("/dev/null",1);  //可以使用任何大于0的数字，如果名字和数相同，则产生的key相同。
  if(shmKey == -1)
  {
   printf("create key error\n");
   exit(-1);
  }
  
  shmID = shmget(shmKey,20,0); //得到shmKey表示的共享内存的ID，0表示如果shmKey映射的不存在则报错。
  if(shmID == -1)
  {
   printf("create shmID error\n");
   exit(-1);
  }
  
  while(1)
  { 
   buf = (char *)shmat(shmID,NULL,0);
   printf("%d. the content of the shared memory is: %s\n",i++,buf);
   shmdt(buf);
   sleep(1);
  }
 } 

 return 0;
}

makefile:

overpass:main.o 
    g++ -g -o  overpass main.o
main.o:main.cpp
    g++ -g -c main.cpp -o main.o
clean:
    rm -f *.o overpass

共享内存posix（两个进程）

main.cpp

#include<stdio.h>
#include<unistd.h>
#include<stdlib.h>
#include<string.h>

#include<time.h>
#include<signal.h>
#include<sys/ipc.h>
#include<sys/shm.h>
#include<sys/types.h>

int shmID;
char * buf;
 
void finalize(int signo)
{
 shmctl(shmID,IPC_RMID,NULL);
 
 exit(0);
}

int main()
{
 int i = 1;  
 key_t shmKey;
 
 signal(SIGINT,finalize);
 signal(SIGTERM,finalize);
 
  shmKey = ftok("/dev/null",1);  //可以使用任何大于0的数字，如果名字和数相同，则产生的key相同。
  if(shmKey == -1)
  {
   printf("create key error\n");
   exit(-1);
  }
  
  shmID = shmget(shmKey,20,IPC_CREAT | IPC_EXCL | 0666);
  if(shmID == -1)
  {
   printf("create shamID error\n");
   exit(-1);
  }
  
  //sleep(2); //等待父进程执行，好显示第一行为空。
  while(1)
  {
   buf = (char *)shmat(shmID,NULL,0);//shmat负责把共享的物理内存attach到当前进程空间buf
   srandom(time(NULL));
   sprintf(buf,"%ld",random()%100); 
   shmdt(buf); //shmdt负责把共享内存从当前进程空间detach
  }
  

 return 0;
}

makefile:

overpass1:main.o 
    g++ -g -o  overpass1 main.o
main.o:main.cpp
    g++ -g -c main.cpp -o main.o
clean:
    rm -f *.o overpass

=============================
main.cpp

#include<stdio.h>
#include<unistd.h>
#include<stdlib.h>
#include<string.h>

#include<time.h>
#include<signal.h>
#include<sys/ipc.h>
#include<sys/shm.h>
#include<sys/types.h>

int shmID;
char * buf;
 
void finalize(int signo)
{
 shmctl(shmID,IPC_RMID,NULL);
 
 exit(0);
}

int main()
{
 int i = 1;  
 key_t shmKey;
 
 signal(SIGINT,finalize);
 signal(SIGTERM,finalize);
 
  
  sleep(1); //让子进程先执行，以建立内存映射。
  
  shmKey = ftok("/dev/null",1);  //可以使用任何大于0的数字，如果名字和数相同，则产生的key相同。
  if(shmKey == -1)
  {
   printf("create key error\n");
   exit(-1);
  }
  
  shmID = shmget(shmKey,20,0); //得到shmKey表示的共享内存的ID，0表示如果shmKey映射的不存在则报错。
  if(shmID == -1)
  {
   printf("create shmID error\n");
   exit(-1);
  }
  
  while(1)
  { 
   buf = (char *)shmat(shmID,NULL,0);
   printf("%d. the content of the shared memory is: %s\n",i++,buf);
   shmdt(buf);
   sleep(1);
  }

 return 0;
}

makefile:

overpass2:main.o 
    g++ -g -o  overpass2 main.o
main.o:main.cpp
    g++ -g -c main.cpp -o main.o
clean:
    rm -f *.o overpass

管道通信

a进程
main.cpp

#include<stdio.h>
#include<stdlib.h>
#include<string.h>
#include<fcntl.h>
#include<sys/types.h>
#include<sys/stat.h>
#include <unistd.h>
int main(int argc,char *argv[])
{
    int fd;
    char buf[20] = "hello world!!!\n";
    remove("/tmp/my_fifo");
    if((mkfifo("/tmp/my_fifo", O_CREAT|O_RDWR|0666)) < 0)
    {
        perror("mkfifo");
        exit(1);
    }
    if((fd = open("/tmp/my_fifo" , O_WRONLY)) < 0)
    {
        perror("open");
        exit(1);
    }
    if((write(fd,buf,strlen(buf))) < 0)
    {
        perror("write");
        exit(1);
    }
    close(fd);
    return 0;
            
}

makefile:

overpassa:main.o 
    g++ -g -o  overpassa main.o 
main.o:main.cpp
    g++ -g -c main.cpp -o main.o
clean:
    rm -f *.o overpassa

=========================
b进程
main.cpp

#include<stdio.h>
#include<stdlib.h>
#include<fcntl.h>
#include<sys/types.h>
#include<sys/stat.h>
#include <unistd.h>

int main(int argc,char *argv[])
{
    int fd;
    char buf[20] = "";
    if((fd = open("/tmp/my_fifo" , O_RDONLY)) < 0)
    {
        perror("open");
        exit(1);
    }
    if((read(fd,buf,20)) < 0)
    {
        perror("read");
        exit(1);
    }
    printf("%s" , buf);
    close(fd);
    return 0;
            
}

makefile

overpassb:main.o 
    g++ -g -o  overpassb main.o 
main.o:main.cpp
    g++ -g -c main.cpp -o main.o
clean:
    rm -f *.o overpassb

匿名管道（父子进程）

main.cpp

#include<stdio.h> 
#include<stdlib.h>
#include<unistd.h>
#include <string.h>

int main() 
{ 
    int n,fd[2]; // fd[0]:read,fd[1]:write 这里的fd是文件描述符的数组，用于创建管道做准备的 
    int fd2[2];
    pid_t pid; 
    char line[100]={0}; 
    char buff[100]={0};
    if(pipe(fd)<0 || pipe(fd2)<0) // 创建匿名管道 
    {
        printf("pipe create error\n");
        return -1;
    }
    if(fork()==0)
    { 
        //close(fd[1]); //这里是子进程，先关闭管道的写入端，然后在管道的读出端读出数据 
        n= read(fd[0],line,100); 
        
        //close(fd2[0]);
        write(fd2[1],"child:hello world\n",strlen("child:hello world\n")+1);
        printf("\n%s",line);
        return 0;
    } 
    else 
    { //这里是父进程，先关闭管道的读出端，然后在管道的写端写入“hello world" 
        //close(fd[0]); 
        write(fd[1],"parent:hello word\n",strlen("parent:hello word\n")+1); 
        
        //close(fd2[1]);
        read(fd2[0],buff,100);
        printf("\n%s",buff);
        return 0;
    } 
}

makefile:

overpass:main.o 
    g++ -g -o  overpass main.o
main.o:main.cpp
    g++ -g -c main.cpp -o main.o
clean:
    rm -f *.o overpass

信号量通信(父子进程)

main.cpp

#include <stdio.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/sem.h>
#include <stdlib.h>
#include <unistd.h>

#define MAXNUMS 15

 union semun 
 {
    int              val;    /* Value for SETVAL */
    struct semid_ds *buf;    /* Buffer for IPC_STAT, IPC_SET */
    unsigned short  *array;  /* Array for GETALL, SETALL */
    struct seminfo  *__buf;  /* Buffer for IPC_INFO                                         (Linux specific) */
};
           

int get_sem_val(int sid,int semnum)//取得当前信号量
{
    return(semctl(sid,semnum,GETVAL,0));
}

int main(void)
{
    int sem_id;
    int pid;
    int rc;
    struct sembuf sem_op;//信号集结构
    union semun sem_val;//信号量数值
    
    
    //建立信号量集，其中只有一个信号量，从0开始计数，第1个信号量
    sem_id=semget(IPC_PRIVATE,1,IPC_CREAT|0600);//IPC_PRIVATE私有，只有本用户使用，如果为正整数，则为公共的；1为信号集的数量,一般总为1；
    if (sem_id==-1){
        printf("create sem error!\n");
        exit(1);    
    }
    printf("create %d sem success!\n",sem_id);    
    //信号量初始化
    sem_val.val=1;
    rc=semctl(sem_id,0,SETVAL,sem_val);//设置信号量,0为第一个信号量，1为第二个信号量,...以此类推；SETVAL表示设置
    if (rc==-1){
        printf("initlize sem error!\n");
        exit(1);    
    }
    //创建进程
    pid=fork();
    if (pid==-1){
        printf("fork error!\n");
        exit(1);           
    }
    else if(pid==0){//一个子进程，消费者，P操作
        sleep(20);
        for (int i=0;i<MAXNUMS;i++){
            sem_op.sem_num=0;
            sem_op.sem_op=-1;
            sem_op.sem_flg=0;
            //P操作信号量，每次-1,当sem_id中的值减到0之后，P操作阻塞
            semop(sem_id,&sem_op,1);               
            printf("\n%d consumer: %d",i,get_sem_val(sem_id,0));
        }     
    }
    else{//父进程，生产者
        for (int i=0;i<MAXNUMS;i++){
            sem_op.sem_num=0;
            sem_op.sem_op=1;
            sem_op.sem_flg=0;
            semop(sem_id,&sem_op,1);//V操作信号量，每次+1                
            printf("%d producer: %d\n",i,get_sem_val(sem_id,0));
            
        }     
    }
    exit(0);
}

makefile:

overpass:main.o 
    g++ -g -o  overpass main.o
main.o:main.cpp
    g++ -g -c main.cpp -o main.o
clean:
    rm -f *.o overpass

信号量通信(不同进程)

a进程
main.cpp

#include <stdio.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/sem.h>
#include <stdlib.h>
#include <unistd.h>

#define MAXNUMS 15

 union semun 
 {
    int              val;    /* Value for SETVAL */
    struct semid_ds *buf;    /* Buffer for IPC_STAT, IPC_SET */
    unsigned short  *array;  /* Array for GETALL, SETALL */
    struct seminfo  *__buf;  /* Buffer for IPC_INFO                                         (Linux specific) */
};
           

int get_sem_val(int sid,int semnum)//取得当前信号量
{
    return(semctl(sid,semnum,GETVAL,0));
}

void sem_lock(int sem_id,struct sembuf *sem_op)
{
    sem_op->sem_num=0;
    sem_op->sem_op=-1;
    sem_op->sem_flg=0;
    //P操作信号量，每次-1,当sem_id中的值减到0之后，P操作阻塞
    semop(sem_id,sem_op,1); 
}

void sem_unlock(int sem_id,struct sembuf *sem_op)
{
    sem_op->sem_num=0;
    sem_op->sem_op=1;
    sem_op->sem_flg=0;
    semop(sem_id,sem_op,1);//V操作信号量，每次+1   
}

int main(void)
{
    int sem_id;
    int pid;
    int rc;
    struct sembuf sem_op;//信号集结构
    union semun sem_val;//信号量数值
    key_t semKey;
    
    semKey = ftok("/dev/null",1);  //可以使用任何大于0的数字，如果名字和数相同，则产生的key相同。
    if(semKey == -1)
    {
       printf("create key error\n");
       exit(-1);
     }
    
    //建立信号量集，其中只有一个信号量，从0开始计数，第1个信号量
    sem_id=semget(semKey,1,IPC_CREAT|0600);//IPC_PRIVATE私有，只有本用户使用，如果为正整数，则为公共的；1为信号集的数量,一般总为1；
    if (sem_id==-1){
        printf("create sem error!\n");
        exit(1);    
    }
    printf("create %d sem success!\n",sem_id);    
    //信号量初始化
    sem_val.val=1;
    rc=semctl(sem_id,0,SETVAL,sem_val);//设置信号量,0为第一个信号量，1为第二个信号量,...以此类推；SETVAL表示设置
    if (rc==-1){
        printf("initlize sem error!\n");
        exit(1);    
    }
    printf("waiting for the lock in process1\n");
    sem_lock(sem_id, &sem_op);
    
    printf("locked in process1\n");
    sleep(25);
    
    sem_unlock(sem_id,&sem_op);
    printf("unlocked in process1\n");
  
  //进程1生产者
  /*
   for (int i=0;i<MAXNUMS;i++){
            sem_op.sem_num=0;
            sem_op.sem_op=1;
            sem_op.sem_flg=0;
            semop(sem_id,&sem_op,1);//V操作信号量，每次+1                
            printf("%d producer: %d\n",i,get_sem_val(sem_id,0));
            
   }   
   */   

    exit(0);
}

makefile:

overpass1:main.o 
    g++ -g -o  overpass1 main.o
main.o:main.cpp
    g++ -g -c main.cpp -o main.o
clean:
    rm -f *.o overpass

==============
b进程
main.cpp

#include <stdio.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/sem.h>
#include <stdlib.h>
#include <unistd.h>

#define MAXNUMS 15

 union semun 
 {
    int              val;    /* Value for SETVAL */
    struct semid_ds *buf;    /* Buffer for IPC_STAT, IPC_SET */
    unsigned short  *array;  /* Array for GETALL, SETALL */
    struct seminfo  *__buf;  /* Buffer for IPC_INFO                                         (Linux specific) */
};
    
void sem_lock(int sem_id,struct sembuf *sem_op)
{
    sem_op->sem_num=0;
    sem_op->sem_op=-1;
    sem_op->sem_flg=0;
    //P操作信号量，每次-1,当sem_id中的值减到0之后，P操作阻塞
    semop(sem_id,sem_op,1); 
}

void sem_unlock(int sem_id,struct sembuf *sem_op)
{
    sem_op->sem_num=0;
    sem_op->sem_op=1;
    sem_op->sem_flg=0;
    semop(sem_id,sem_op,1);//V操作信号量，每次+1   
}   

int get_sem_val(int sid,int semnum)//取得当前信号量
{
    return(semctl(sid,semnum,GETVAL,0));
}

int main(void)
{
    int sem_id;
    int pid;
    int rc;
    struct sembuf sem_op;//信号集结构
    
    key_t semKey;
    
    semKey = ftok("/dev/null",1);  //可以使用任何大于0的数字，如果名字和数相同，则产生的key相同。
    if(semKey == -1)
    {
       printf("create key error\n");
       exit(-1);
     }
    
    //建立信号量集，其中只有一个信号量，从0开始计数，第1个信号量
    sem_id=semget(semKey,1,IPC_CREAT|0600);//IPC_PRIVATE私有，只有本用户使用，如果为正整数，则为公共的；1为信号集的数量,一般总为1；
    if (sem_id==-1){
        printf("create sem error!\n");
        exit(1);    
    }
    printf("create %d sem success!\n",sem_id); 
    
    printf("waiting for the lock in process2\n");
    sem_lock(sem_id, &sem_op);
    
    printf("locked in process2\n");
    sleep(25);
    
    sem_unlock(sem_id,&sem_op);
    printf("unlocked in process2\n");

    /*
    for (int i=0;i<MAXNUMS;i++){
            sem_op.sem_num=0;
            sem_op.sem_op=-1;
            sem_op.sem_flg=0;
            //P操作信号量，每次-1,当sem_id中的值减到0之后，P操作阻塞
            semop(sem_id,&sem_op,1);               
            printf("\n%d consumer: %d",i,get_sem_val(sem_id,0));
    } 
    */    
    
    exit(0);
}

makefile:

overpass2:main.o 
    g++ -g -o  overpass2 main.o
main.o:main.cpp
    g++ -g -c main.cpp -o main.o
clean:
    rm -f *.o overpass
最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 204,590评论 6赞 478
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 86,808评论 2赞 381
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 151,151评论 0赞 337
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 54,779评论 1赞 277
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 63,773评论 5赞 367
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 48,656评论 1赞 281
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 38,022评论 3赞 398
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 36,678评论 0赞 258
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 41,038评论 1赞 299
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,659评论 2赞 321
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,756评论 1赞 330
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 33,411评论 4赞 321
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 39,005评论 3赞 307
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,973评论 0赞 19
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,203评论 1赞 260
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 45,053评论 2赞 350
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 42,495评论 2赞 343