多个客户端与服务器端发送消息案例

案例：用消息队列实现许多客户端和服务器端的通信，要求是，许多客户端都可以向服务器端发送消息，服务器端在接受这些消息之后，再将消息回发给对应的客户端。

解决思路：所有客户端都往1号通道上发送消息，并且在发送的内容的最前面放上自己进程的进程号，那么当服务器端收到中众多客户端发来的消息之后，通过解析主要内容的最前面内容，拿出对应客户端进程号，将其作为发送通道发送给对应的客户端，那么客户端接受的消息就来自以自己进程号为通道号的消息，服务器在1号通道等待接受数据，没有数据就阻塞。

注意：

（1）发送消息的，提前设定要发的通道号（buf.channel=1,就说明要发送的通道号是1号）；而接受消息时直接将接受通道号作为参数传过去。

（2）每次接受前，读前都要刷新缓冲区

（3）因为客户端把自己的进程号放在发送消息的前面，（假如是进程号为3,0011，小端存储1100，那么用strlen()计算长度，遇到0会结束，因此用巧妙手

段：strlen(buf.mtext+sizeof(long))+sizeof(long),0)）

代码：

客户端：

      #include <stdio.h>  
      #include <stdlib.h>  
      #include <fcntl.h>  
      #include <sys/ipc.h>  
      #include <sys/msg.h>  
      #include <string.h>  
       
     //消息队列发送数据的要求，以一个结构体  
     struct mybuf  
     {  
         long channel;//通道号  
         char mtext[100];//一块缓冲区，装发送数据  
     };  
       
     int main()  
     {  
         int id=msgget(1234,0);//打开1234这个消息队列  
         if(id==-1)  
         {  
             perror("msgget\n");  
             exit(1);  
         }  
         struct mybuf buf;//在内存中创建一个用来传递消息的结构体  
       
         //客户端  
         while(1)  
         {  
             memset(&buf,0x00,sizeof(buf));  
             //首先客户端要发送内容到1号通道  
             buf.channel=1;  
             //把要发送的内容前面放成自己的进程号  
             *(long*)buf.mtext=(long)getpid();  
             printf("请输入要发送的消息：");  
             scanf("%s",buf.mtext+sizeof(long));//把要发送的内容输入到buf对应的位置  
             //发送  
             msgsnd(id,&buf,strlen(buf.mtext+sizeof(long))+sizeof(long),0);  
             //每次接受前，读取前，清空缓冲区  
             memset(&buf,0x00,sizeof(buf));  
             //接受从自己进程号作为通道的信息  
             msgrcv(id,&buf,100,getpid(),0);  
             printf("客户端接受：%s\n",buf.mtext + sizeof(long) );  
       
         }  
       
         return 0;  
     }  

服务器端：

  #include <stdio.h>  
  #include <stdlib.h>  
  #include <fcntl.h>  
  #include <sys/ipc.h>  
  #include <sys/msg.h>  
  #include <string.h>  
    
 //消息队列发送数据的要求，以一个结构体  
 struct mybuf  
 {  
     long channel;//通道号  
     char mtext[100];//一块缓冲区，装发送数据  
 };  
   
 int main()  
 {  
     int id=msgget(1234,IPC_CREAT|0644);//打开1234这个消息队列  
     if(id==-1)  
     {  
         perror("msgget\n");  
         exit(1);  
     }  
     struct mybuf buf;//在内存中创建一个用来传递消息的结构体  
   
     //服务器  
     while(1)  
     {  
         memset(&buf,0x00,sizeof(buf));//清空缓冲区  
   
         //服务器从id这个消息队列的1号通道接受100大小数据放在buf中，没数据等待  
         msgrcv(id,&buf,100,1,0);  
     //服务器接受到客户端发来的内容，要从其中解析出客户端的进程号,以备返回给该进程  
         buf.channel=*(long*)buf.mtext;  
         msgsnd(id,&buf,strlen(buf.mtext+sizeof(long))+sizeof(long),0);  
         printf("fu send is ok\n");  
     }  
   
     return 0;  
 }