Chinaunix首页 | 论坛 | 博客

ARM+Linux挖掘机hclenblog.blog.chinaunix.net

首页　| 　博文目录　| 　关于我

hclen90615

  • 博客访问： 130480
  • 博文数量： 30
  • 博客积分： 972
  • 博客等级： 中士
  • 技术积分： 332
  • 用 户 组： 普通用户
  • 注册时间： 2012-02-08 10:04
文章分类

全部博文（30）

文章存档

2012年（30）

我的朋友
最近访客
推荐博文
相关博文
利用消息队列进行多人聊天

分类： LINUX

2012-06-21 09:48:07


 

点击(此处)折叠或打开

  1. /*********************Bob************************************/
  2. #include <stdio.h>
  3. #include <stdlib.h>
  4. #include <unistd.h>
  5. #include <string.h>
  6. #include <sys/types.h>
  7. #include <sys/msg.h>
  8. #include <sys/ipc.h>
  9. typedef struct msg
  10. {
  11.  int type;
  12.  char text[100];
  13.  char name[20];
  14. }MSG;
  15. int main(int argc, char *argv[])
  16. {
  17.  pid_t pid;
  18.  char buf[50]="";
  19.  key_t key;
  20.  MSG temp;
  21.  int msg_id;
  22.  key=ftok(".",2);
  23.  msg_id=msgget(key,IPC_CREAT|0666);
  24.  if(msg_id < 0)
  25.  {
  26.  perror("msgget");
  27.  exit(-1);
  28.  }
  29.  if((pid=fork()) < 0)
  30.   {
  31.    perror("fork");
  32.    exit(-1);
  33.   }
  34.  if(pid == 0)
  35.   {
  36.    while(1)
  37.    {
  38.    printf("Bob:");
  39.    fflush(stdout);
  40.    fgets(buf,50,stdin);
  41.    temp.type=(int)*buf;
  42.    strcpy(temp.text,buf+2);
  43.    strcpy(temp.name,"Bob");
  44.    msgsnd(msg_id,&temp,sizeof(temp)-4,0);
  45.    }
  46.   }
  47.  if(pid > 0)
  48.   {
  49.    while(1)
  50.    {
  51.     msgrcv(msg_id,&temp,sizeof(temp)-4,'B',0);
  52.     printf("\r%s:%s",temp.name,temp.text);
  53.     fflush(stdout);
  54.     printf("Bob:");
  55.     fflush(stdout);
  56.    }
  57.   }
  58.  msgctl(msg_id,IPC_RMID,NULL);
  59.  return 0;
  60. }


  63. /**********Lucy.c***********/

  65. #include <stdio.h>
  66. #include <stdlib.h>
  67. #include <unistd.h>
  68. #include <string.h>
  69. #include <sys/types.h>
  70. #include <sys/msg.h>
  71. #include <sys/ipc.h>
  72. typedef struct msg
  73. {
  74.  int type;
  75.  char text[100];
  76.  char name[20];
  77. }MSG;
  78. int main(int argc, char *argv[])
  79. {
  80.  pid_t pid;
  81.  char buf[50]="";
  82.  key_t key;
  83.  MSG temp;
  84.  int msg_id;
  85.  key=ftok(".",2);
  86.  msg_id=msgget(key,IPC_CREAT|0666);
  87.  if(msg_id < 0)
  88.  {
  89.  perror("msgget");
  90.  exit(-1);
  91.  }
  92.  if((pid=fork()) < 0)
  93.   {
  94.    perror("fork");
  95.    exit(-1);
  96.   }
  97.  if(pid == 0)
  98.   {
  99.    while(1)
  100.    {
  101.    printf("Lucy:");
  102.    fflush(stdout);
  103.    fgets(buf,50,stdin);
  104.    temp.type=(int)buf[0];
  105.    strcpy(temp.text,buf+2);
  106.    strcpy(temp.name,"Lucy");
  107.    msgsnd(msg_id,&temp,sizeof(temp)-4,0);
  108.    }
  109.   }
  110.  if(pid > 0)
  111.   {
  112.    while(1)
  113.    {
  114.     msgrcv(msg_id,&temp,sizeof(temp)-4,'L',0);
  115.     printf("\r%s:%s",temp.name,temp.text);
  116.     fflush(stdout);
  117.     printf("Lucy:");
  118.     fflush(stdout);
  119.    }
  120.   }
  121.  msgctl(msg_id,IPC_RMID,NULL);
  122.  return 0;
  123. }


  126. /*****************Peter.c******************/
  127. #include <stdio.h>
  128. #include <stdlib.h>
  129. #include <unistd.h>
  130. #include <string.h>
  131. #include <sys/types.h>
  132. #include <sys/msg.h>
  133. #include <sys/ipc.h>
  134. typedef struct msg
  135. {
  136.  int type;
  137.  char text[100];
  138.  char name[20];
  139. }MSG;
  140. int main(int argc, char *argv[])
  141. {
  142.  pid_t pid;
  143.  char buf[50]="";
  144.  key_t key;
  145.  MSG temp;
  146.  int msg_id;
  147.  key=ftok(".",2);
  148.  msg_id=msgget(key,IPC_CREAT|0666);
  149.  if(msg_id < 0)
  150.  {
  151.  perror("msgget");
  152.  exit(-1);
  153.  }
  154.  if((pid=fork()) < 0)
  155.   {
  156.    perror("fork");
  157.    exit(-1);
  158.   }
  159.  if(pid == 0)
  160.   {
  161.    while(1)
  162.    {
  163.    printf("Peter:");
  164.    fflush(stdout);
  165.    fgets(buf,50,stdin);
  166.    temp.type=(int)*buf;
  167.    strcpy(temp.text,buf+2);
  168.    strcpy(temp.name,"Peter");
  169.    msgsnd(msg_id,&temp,sizeof(temp)-4,0);
  170.    }
  171.   }
  172.  if(pid > 0)
  173.   {
  174.    while(1)
  175.    {
  176.     msgrcv(msg_id,&temp,sizeof(temp)-4,'P',0);
  177.     printf("\r%s:%s",temp.name,temp.text);
  178.     fflush(stdout);
  179.     printf("Peter:");
  180.     fflush(stdout);
  181.    }
  182.   }
  183.  msgctl(msg_id,IPC_RMID,NULL);
  184.  return 0;
  185. }


 

阅读(1627) | 评论(0) | 转发(0) |
0

上一篇：堆和栈的区别（转过无数次的文章）

下一篇：利用信号量与互斥搭建出---生产者与消费者模型

给主人留下些什么吧！~~
关于我们 | 关于IT168 | 联系方式 | 广告合作 | 法律声明 | 免费注册

Copyright 2001-2010 ChinaUnix.net All Rights Reserved 北京皓辰网域网络信息技术有限公司. 版权所有

感谢所有关心和支持过ChinaUnix的朋友们

16024965号-6