看流星社区

 找回密码
 注册账号
查看: 1601|回复: 0

Linux进程通信例子

[复制链接]

该用户从未签到

发表于 2017-6-1 12:52:08 | 显示全部楼层 |阅读模式
Linux进程通信例子
1.共享内存
使用:mmap
  1. /*-------------map_normalfile1.c-----------*/
  2. #include <sys/mman.h>
  3. #include <sys/types.h>
  4. #include <fcntl.h>
  5. #include <unistd.h>
  6. typedef struct{
  7.   char name[4];
  8.   int  age;
  9. }people;
  10. main(int argc, char** argv) // map a normal file as shared mem:
  11. {
  12.   int fd,i;
  13.   people *p_map;
  14.   char temp;
  15.   
  16.   fd=open(argv[1],O_CREAT|O_RDWR|O_TRUNC,00777);
  17.   lseek(fd,sizeof(people)*5-1,SEEK_SET);
  18.   write(fd,"",1);
  19.   
  20.   p_map = (people*) mmap( NULL,sizeof(people)*10,PROT_READ|PROT_WRITE,
  21.         MAP_SHARED,fd,0 );
  22.   close( fd );
  23.   temp = 'a';
  24.   for(i=0; i<10; i++)
  25.   {
  26.     temp += 1;
  27.     memcpy( ( *(p_map+i) ).name, &temp,2 );
  28.     ( *(p_map+i) ).age = 20+i;
  29.   }
  30.   printf(" initialize over \n ");
  31.   sleep(10);
  32.   munmap( p_map, sizeof(people)*10 );
  33.   printf( "umap ok \n" );
  34. }
  35. /*-------------map_normalfile2.c-----------*/
  36. #include <sys/mman.h>
  37. #include <sys/types.h>
  38. #include <fcntl.h>
  39. #include <unistd.h>
  40. typedef struct
  41. {
  42.   char name[4];
  43.   int  age;
  44. }people;
  45. void main(int argc, char** argv)  // map a normal file as shared mem:
  46. {
  47.   int fd,i;
  48.   people *p_map;
  49.   fd=open( argv[1],O_CREAT|O_RDWR,00777 );
  50.   p_map = (people*)mmap(NULL,sizeof(people)*10,PROT_READ|PROT_WRITE,
  51.        MAP_SHARED,fd,0);
  52.   for(i = 0;i<10;i++)
  53.   {
  54.   printf( "name: %s age %d;\n",(*(p_map+i)).name, (*(p_map+i)).age );
  55.   }
  56.   munmap( p_map,sizeof(people)*10 );
  57. }
复制代码

3.管道
mkfifo

  1. #include<stdio.h>
  2. #include<stdlib.h>
  3. #include<string.h>
  4. #include<fcntl.h>
  5. #include<sys/types.h>
  6. #include<sys/stat.h>
  7. int main(int argc,char *argv[])
  8. {
  9.         int fd;
  10.         char buf[20] = "hello world!!!/n";
  11.         if((mkfifo("my_fifo", O_CREAT|O_RDWR|0666)) < 0)
  12.         {
  13.                 perror("mkfifo");
  14.                 exit(1);
  15.         }
  16.         if((fd = open("my_fifo" , O_WRONLY)) < 0)
  17.         {
  18.                 perror("open");
  19.                 exit(1);
  20.         }
  21.         if((write(fd,buf,strlen(buf)-1)) < 0)
  22.         {
  23.                 perror("write");
  24.                 exit(1);
  25.         }
  26.         return 0;
  27.                        
  28. }
  29. #include<stdio.h>
  30. #include<stdlib.h>
  31. #include<fcntl.h>
  32. #include<sys/types.h>
  33. #include<sys/stat.h>
  34. int main(int argc,char *argv[])
  35. {
  36.         int fd;
  37.         char buf[20] = "";
  38.         if((fd = open("my_fifo" , O_RDONLY)) < 0)
  39.         {
  40.                 perror("open");
  41.                 exit(1);
  42.         }
  43.         if((read(fd,buf,20)) < 0)
  44.         {
  45.                 perror("read");
  46.                 exit(1);
  47.         }
  48.         printf("%s" , buf);
  49.         return 0;
  50.                        
  51. }
复制代码



Makefile
  1. overpass:main.o
  2.         g++ -g -o  overpass main.o -L. -lhiredis -lpthread -lcurl -lrt -lcrypto -lidn -lssl
  3. main.o:main.cpp
  4.         g++ -g -c main.cpp -o main.o
  5. clean:
  6.         rm -f *.o overpass
复制代码


4.信号量
  1. #include <stdio.h>
  2. #include <linux/sem.h>
  3. #define MAXNUMS 15
  4. int get_sem_val(int sid,int semnum)//取得当前信号量
  5. {
  6.     return(semctl(sid,semnum,GETVAL,0));
  7. }
  8. int main(void)
  9. {
  10.     int sem_id;
  11.     int pid;
  12.     int rc;
  13.     struct sembuf sem_op;//信号集结构
  14.     union semun sem_val;//信号量数值
  15.    
  16.    
  17.     //建立信号量集,其中只有一个信号量
  18.     sem_id=semget(IPC_PRIVATE,1,IPC_CREAT|0600);//IPC_PRIVATE私有,只有本用户使用,如果为正整数,则为公共的;1为信号集的数量;
  19.     if (sem_id==-1){
  20.         printf("create sem error!\n");
  21.         exit(1);   
  22.     }
  23.     printf("create %d sem success!\n",sem_id);   
  24.     //信号量初始化
  25.     sem_val.val=1;
  26.     rc=semctl(sem_id,0,SETVAL,sem_val);//设置信号量,0为第一个信号量,1为第二个信号量,...以此类推;SETVAL表示设置
  27.     if (rc==-1){
  28.         printf("initlize sem error!\n");
  29.         exit(1);   
  30.     }
  31.     //创建进程
  32.     pid=fork();
  33.     if (pid==-1){
  34.         printf("fork error!\n");
  35.         exit(1);           
  36.     }
  37.     else if(pid==0){//一个子进程,消费者
  38.         for (int i=0;i<MAXNUMS;i++){
  39.             sem_op.sem_num=0;
  40.             sem_op.sem_op=-1;
  41.             sem_op.sem_flg=0;
  42.             semop(sem_id,&sem_op,1);//操作信号量,每次-1               
  43.             printf("%d 消费者: %d\n",i,get_sem_val(sem_id,0));
  44.         }     
  45.     }
  46.     else{//父进程,生产者
  47.         for (int i=0;i<MAXNUMS;i++){
  48.             sem_op.sem_num=0;
  49.             sem_op.sem_op=1;
  50.             sem_op.sem_flg=0;
  51.             semop(sem_id,&sem_op,1);//操作信号量,每次+1                 
  52.             printf("%d 生产者: %d\n",i,get_sem_val(sem_id,0));
  53.             
  54.         }     
  55.     }
  56.     exit(0);
  57. }
复制代码


Makefile
  1. overpass:main.o
  2.         g++ -g -o  overpass main.o -L. -lhiredis -lpthread -lcurl -lrt -lcrypto -lidn -lssl
  3. main.o:main.cpp
  4.         g++ -g -c main.cpp -o main.o
  5. clean:
  6.         rm -f *.o overpass
复制代码



一般是用管道即可
更多参考:http://www.cnblogs.com/linshui91/archive/2010/09/29/1838770.html
点击按钮快速添加回复内容: 支持 高兴 激动 给力 加油 苦寻 生气 回帖 路过 感恩
您需要登录后才可以回帖 登录 | 注册账号

本版积分规则

小黑屋|手机版|Archiver|看流星社区 |网站地图

GMT+8, 2024-3-19 11:39

Powered by Kanliuxing X3.4

© 2010-2019 kanliuxing.com

快速回复 返回顶部 返回列表