0

我尝试使用命名管道实现客户端服务器模型。现在,当客户端仅向服务器发送一条消息时,服务器能够识别发送的消息是什么并将其打印出来。现在,如果客户端向同一服务器发送多条消息,则服务器无法区分这些消息并将两个客户端消息一起打印出来,而不是分别打印出两个消息。这是我正在使用的代码:

  Server.c:
    int main(void)
    {
         FILE *fp;
        char readbuf[80];

  /*Create the FIFO if it does not exist */
  umask(0);
  mknod(FIFO_FILE, S_IFIFO|0777, 0);
  while(1)
  {
   fp=fopen(FIFO_FILE, "r");
   fgets(readbuf,80, fp);
   fprintf(stderr,"Received string: %s\n", readbuf);
   fclose(fp);
   fprintf(stderr,"Finished iteration\n");
  }

 return(0);
 }

   Client.c:
     int main()
     {
       FILE *fp;
        char * message1="message1";
        char * message2="message2";
         if((fp = fopen(FIFO_FILE, "w+")) == NULL) {
                perror("fopen");
                     exit(1);
      }

  fprintf(stderr,"Trying to transfer the first message\n");
  fputs(message1, fp);
  fprintf(stderr,"Transferred the first message\n");
  fprintf(stderr,"Trying to transfer the second message\n");
  fputs(message2, fp);
  fprintf(stderr,"Trying to transfer the second message\n");
  fclose(fp);
  return(0);
   }

现在,我知道在服务器端我试图一次读取 80 个字节,这使得它可以一起读取所有字符,但是每当我试图在服务器端一次读取 5 个字节时,它就会进入无限循环。我的概念一定有问题。当我修改服务器端一次读取 5 个字节时,我有一个疑问。它进入无限循环,为什么它在读取客户端发送的所有消息后不阻塞。

4

1 回答 1

0

在管道/流级别没有关于什么构成应用程序协议消息的知识。但是,有两种最常见的方式来分隔流中的消息:

  • 为其大小添加前缀消息并读取那么多字节,或
  • 读取直到找到特定的字节序列(\n对于基于文本的协议,通常是(换行符))。

使用其中一种方法来分隔流中的消息。

于 2016-04-06T17:12:06.663 回答