IPC sample

蓝色键盘

经常有人问IPC的问题，下面是一些简单的例子。有空看看！
System V信号量

1. 
   
2. #define PERMS S_IRUSR|S_IWUSR
   
3. 
   
4. void init_semaphore_struct(struct sembuf *sem,int semnum,
   
5. int semop,int semflg)
   
6. {
   
7. /* 初始话信号灯结构 */
   
8. sem->;sem_num=semnum;
   
9. sem->;sem_op=semop;
   
10. sem->;sem_flg=semflg;
    
11. }
    
12. 
    
13. int del_semaphore(int semid)
    
14. {
    
15. /* 信号灯并不随程序的结束而被删除,如果我们没删除的话(将1改为0)
    
16. 可以用ipcs命令查看到信号灯,用ipcrm可以删除信号灯的
    
17. */
    
18. #if 1
    
19. return semctl(semid,0,IPC_RMID);
    
20. #endif
    
21. }
    
22. 
    
23. int main(int argc,char **argv)
    
24. {
    
25. char buffer[MAX_CANON],*c;
    
26. int i,n;
    
27. int semid,semop_ret,status;
    
28. pid_t childpid;
    
29. struct sembuf semwait,semsignal;
    
30. 
    
31. if((argc!=2)||((n=atoi(argv[1]))<1))
    
32. {
    
33. fprintf(stderr,"Usage:%s number\n\a",argv[0]);
    
34. exit(1);
    
35. }
    
36. 
    
37. /* 使用IPC_PRIVATE 表示由系统选择一个关键字来创建 */
    
38. /* 创建以后信号灯的初始值为0 */
    
39. if((semid=semget(IPC_PRIVATE,1,PERMS))==-1)
    
40. {
    
41. fprintf(stderr,"[%d]:Acess Semaphore Error:%s\n\a",
    
42. getpid(),strerror(errno));
    
43. exit(1);
    
44. }
    
45. 
    
46. /* semwait是要求资源的操作(-1) */
    
47. init_semaphore_struct(&semwait,0,-1,0);
    
48. 
    
49. /* semsignal是释放资源的操作(+1) */
    
50. init_semaphore_struct(&semsignal,0,1,0);
    
51. 
    
52. /* 开始的时候有一个系统资源(一个标准错误输出) */
    
53. if(semop(semid,&semsignal,1)==-1)
    
54. {
    
55. fprintf(stderr,"[%d]:Increment Semaphore Error:%s\n\a",
    
56. getpid(),strerror(errno));
    
57. if(del_semaphore(semid)==-1)
    
58. fprintf(stderr,"[%d]:Destroy Semaphore Error:%s\n\a",
    
59. getpid(),strerror(errno));
    
60. exit(1);
    
61. }
    
62. 
    
63. /* 创建一个进程链 */
    
64. for(i=0;i if(childpid=fork()) break;
    
65. 
    
66. sprintf(buffer,"[i=%d]-->;[Process=%d]-->;[Parent=%d]-->;[Child=%d]\n",
    
67. i,getpid(),getppid(),childpid);
    
68. c=buffer;
    
69. 
    
70. /* 这里要求资源,进入原子操作 */
    
71. while(((semop_ret=semop(semid,&semwait,1))==-1)&&(errno==EINTR));
    
72. if(semop_ret==-1)
    
73. {
    
74. fprintf(stderr,"[%d]:Decrement Semaphore Error:%s\n\a",
    
75. getpid(),strerror(errno));
    
76. }
    
77. else
    
78. {
    
79. while(*c!='\0')fputc(*c++,stderr);
    
80. /* 原子操作完成,赶快释放资源 */
    
81. while(((semop_ret=semop(semid,&semsignal,1))==-1)&&(errno==EINTR));
    
82. if(semop_ret==-1)
    
83. fprintf(stderr,"[%d]:Increment Semaphore Error:%s\n\a",
    
84. getpid(),strerror(errno));
    
85. }
    
86. 
    
87. /* 不能够在其他进程反问信号灯的时候,我们删除了信号灯 */
    
88. while((wait(&status)==-1)&&(errno==EINTR));
    
89. /* 信号灯只能够被删除一次的 */
    
90. if(i==1)
    
91. if(del_semaphore(semid)==-1)
    
92. fprintf(stderr,"[%d]:Destroy Semaphore Error:%s\n\a",
    
93. getpid(),strerror(errno));
    
94. exit(0);
    
95. }
    

复制代码

SystemV消息队列

1. 
   
2. #define MSG_FILE "server.c"
   
3. #define BUFFER 255
   
4. #define PERM S_IRUSR|S_IWUSR
   
5. 
   
6. struct msgtype {
   
7. long mtype;
   
8. char buffer[BUFFER+1];
   
9. };
   
10. 
    
11. int main()
    
12. {
    
13. struct msgtype msg;
    
14. key_t key;
    
15. int msgid;
    
16. 
    
17. if((key=ftok(MSG_FILE,'a'))==-1)
    
18. {
    
19. fprintf(stderr,"Creat Key Error:%s\a\n",strerror(errno));
    
20. exit(1);
    
21. }
    
22. 
    
23. if((msgid=msgget(key,PERM|IPC_CREAT|IPC_EXCL))==-1)
    
24. {
    
25. fprintf(stderr,"Creat Message Error:%s\a\n",strerror(errno));
    
26. exit(1);
    
27. }
    
28. 
    
29. while(1)
    
30. {
    
31. msgrcv(msgid,&msg,sizeof(struct msgtype),1,0);
    
32. fprintf(stderr,"Server Receive:%s\n",msg.buffer);
    
33. msg.mtype=2;
    
34. msgsnd(msgid,&msg,sizeof(struct msgtype),0);
    
35. }
    
36. exit(0);
    
37. }
    
38. 
    
39. 
    
40. --------------------------------------------------------------------------------
    
41. 
    
42. 客户端(client.c)
    
43. 
    
44. #include
    
45. #include
    
46. #include
    
47. #include
    
48. #include
    
49. #include
    
50. #include
    
51. #include
    
52. #define MSG_FILE "server.c"
    
53. #define BUFFER 255
    
54. #define PERM S_IRUSR|S_IWUSR
    
55. 
    
56. struct msgtype {
    
57. long mtype;
    
58. char buffer[BUFFER+1];
    
59. };
    
60. 
    
61. int main(int argc,char **argv)
    
62. {
    
63. struct msgtype msg;
    
64. key_t key;
    
65. int msgid;
    
66. 
    
67. if(argc!=2)
    
68. {
    
69. fprintf(stderr,"Usage:%s string\n\a",argv[0]);
    
70. exit(1);
    
71. }
    
72. 
    
73. if((key=ftok(MSG_FILE,'a'))==-1)
    
74. {
    
75. fprintf(stderr,"Creat Key Error:%s\a\n",strerror(errno));
    
76. exit(1);
    
77. }
    
78. 
    
79. if((msgid=msgget(key,PERM))==-1)
    
80. {
    
81. fprintf(stderr,"Creat Message Error:%s\a\n",strerror(errno));
    
82. exit(1);
    
83. }
    
84. 
    
85. msg.mtype=1;
    
86. strncpy(msg.buffer,argv[1],BUFFER);
    
87. msgsnd(msgid,&msg,sizeof(struct msgtype),0);
    
88. memset(&msg,'\0',sizeof(struct msgtype));
    
89. msgrcv(msgid,&msg,sizeof(struct msgtype),2,0);
    
90. fprintf(stderr,"Client receive:%s\n",msg.buffer);
    
91. exit(0);
    
92. }
    

复制代码

SystemV共享内存

1. 
   
2. #define PERM S_IRUSR|S_IWUSR
   
3. 
   
4. int main(int argc,char **argv)
   
5. {
   
6. 
   
7. int shmid;
   
8. char *p_addr,*c_addr;
   
9. if(argc!=2)
   
10. {
    
11. fprintf(stderr,"Usage:%s\n\a",argv[0]);
    
12. exit(1);
    
13. }
    
14. 
    
15. if((shmid=shmget(IPC_PRIVATE,1024,PERM))==-1)
    
16. {
    
17. fprintf(stderr,"Create Share Memory Error:%s\n\a",strerror(errno));
    
18. exit(1);
    
19. }
    
20. if(fork())
    
21. {
    
22. p_addr=shmat(shmid,0,0);
    
23. memset(p_addr,'\0',1024);
    
24. strncpy(p_addr,argv[1],1024);
    
25. exit(0);
    
26. }
    
27. else
    
28. {
    
29. c_addr=shmat(shmid,0,0);
    
30. printf("Client get %s",c_addr);
    
31. exit(0);
    
32. }
    
33. }
    

复制代码

一颗流星

哈哈，太好了，结合实例理解加深不少呢！
我自己编程实现的都是单个进程间的：）

蓝色键盘

SYSTEM V MSG


请求方程序

1. 
   
2. static struct msgbuf1{
   
3. 
   
4. long mtype;
   
5. 
   
6. char mtext[100];
   
7. 
   
8. } sndbuf, rcvbuf, *msgp ;
   
9. 
   
10. extern int errno;
    
11. 
    
12. main(int argc, char **argv)
    
13. 
    
14. { int rtrn, msqid ;
    
15. 
    
16. char name[10];
    
17. 
    
18. double balance;
    
19. 
    
20. if (argc!=2){ fprintf(stderr,
    
21. 
    
22. "msgreq [01-99]\n"); exit(-1); }
    
23. 
    
24. if ( (msqid = msgget(0x888, IPC_CREAT|0660)) == -1 ){
    
25. 
    
26. fprintf(stderr, "msgget 888 failed !\n"); exit(-1);
    
27. 
    
28. }
    
29. 
    
30. msgp=&
    
31. 
    
32. sprintf(sndbuf.mtext,"%2.2s",argv[1]);
    
33. 
    
34. printf("输入4位帐号:");
    
35. 
    
36. scanf("%s",&sndbuf.mtext[2]);
    
37. 
    
38. sndbuf.mtext[6]=0;
    
39. 
    
40. msgp->;mtype=666;
    
41. 
    
42. rtrn=msgsnd(msqid,msgp, strlen(sndbuf.mtext), 0);
    
43. 
    
44. if (rtrn==-1){
    
45. 
    
46. perror("msgsnd"); exit(-1);
    
47. 
    
48. }
    
49. 
    
50. msgp=&
    
51. 
    
52. fprintf(stderr,"等待后台数据处理进程的回答....");
    
53. 
    
54. rtrn=msgrcv(msqid,msgp, 100, atoi(argv[1]), 0);
    
55. 
    
56. if(rtrn==-1){ perror("msgrcv"); exit(-1); }
    
57. 
    
58. sscanf(rcvbuf.mtext,"%[^|]|%lf",name,&balance);
    
59. 
    
60. printf("\n姓名=%s\n",name);
    
61. 
    
62. printf("余额=%lf\n",balance);
    
63. 
    
64. }
    

复制代码

服务方程序

1. 
   
2. static struct msgbuf1{
   
3. 
   
4. long mtype;
   
5. 
   
6. char mtext[100];
   
7. 
   
8. } sndbuf, rcvbuf , *msgp;
   
9. 
   
10. extern int errno;
    
11. 
    
12. main()
    
13. 
    
14. { int rtrn, msgqid ;
    
15. 
    
16. char strbuf[100];
    
17. 
    
18. if ( (msqid = msgget(0x888, IPC_CREAT|0600)) == -1 ){
    
19. 
    
20. fprintf(stderr, "msgget 888 failed !\n"); exit(-1);
    
21. 
    
22. }
    
23. 
    
24. while(1) {
    
25. 
    
26. msgp=&
    
27. 
    
28. fprintf(stderr,"等待前台进程的请求....");
    
29. 
    
30. rtrn=msgrcv(msqid, msgp, 100, 666 ,MSG_NOERROR);
    
31. 
    
32. if(rtrn==-1){ perror("msgrcv");exit(-1); }
    
33. 
    
34. msgp=&
    
35. 
    
36. sprintf(strbuf,"%2.2s\0",rcvbuf.mtext);
    
37. 
    
38. msgp->;mtype=atoi(strbuf);
    
39. 
    
40. printf("\n输入帐号=%4.4s的帐户姓名:",&rcvbuf.mtext[2]);
    
41. 
    
42. scanf("%s",sndbuf.mtext);
    
43. 
    
44. strcat(sndbuf.mtext,"|");
    
45. 
    
46. printf("输入该帐户余额:");
    
47. 
    
48. scanf("%s",strbuf);
    
49. 
    
50. strcat(sndbuf.mtext,strbuf);
    
51. 
    
52. rtrn=msgsnd(msqid,msgp, strlen(sndbuf.mtext), 0);
    
53. 
    
54. if (rtrn==-1){ perror("msgsnd"); exit(-1); }
    
55. 
    
56. }
    
57. 
    
58. }
    
59. 
    
60. 
    
61. 
    

复制代码

一颗流星

我觉得这是个好东东，藏在后面怕有人看不见。所以
UP

superzhang

往上顶一顶，不错，够热心的。

sz00

太好了!
谢谢!
强烈UP!

walkandsee

good,up

towerjt

up

unixgood

sscanf(rcvbuf.mtext,"%[^|]|%lf",name,&balance);
这句话看不懂，,"%[^|]|%lf",是什么意思噢？

jsean

好！