我正在尝试制作一个带有服务器的程序，多个客户端可以通过预定义的端口号连接到该服务器。顺便说一句，这是 C 中的 TCP。我在下面有以下 server 代码:

服务器代码:

#include <stdio.h>
#include <string.h>    
#include <stdlib.h>    
#include <sys/socket.h>
#include <arpa/inet.h> 
#include <unistd.h>    
#include <pthread.h> 

void *connection_handler(void *);

int main(int argc , char *argv[])
{
    int listenfd , connfd , c , *new_sock;
    struct sockaddr_in servaddr , cliaddr;
    listenfd = socket(PF_INET , SOCK_STREAM , 0);
    if (listenfd == -1)
        puts("SOCKET CREATION ERROR!");
        puts("Socket created");

    bzero(&servaddr, sizeof(servaddr));
    servaddr.sin_family = AF_INET;
    servaddr.sin_addr.s_addr = htonl(INADDR_ANY);
    servaddr.sin_port = htons(54321);
    bind(listenfd, (struct sockaddr*) &servaddr, sizeof(servaddr) );
    listen(listenfd,2);;
    c = sizeof(struct sockaddr_in);

    while( (connfd = accept(listenfd, (struct sockaddr *)&cliaddr, (socklen_t*)&c)) ){
            puts("Connection accepted");
        pthread_t sniffer_thread;
            new_sock = malloc(1);
            *new_sock = connfd;

            if( pthread_create( &sniffer_thread , NULL ,  connection_handler , (void*) new_sock) < 0)
        {
                perror("Thread Error Connection");
            return 1;
            }
            puts("Handler assigned");
        }

    if (connfd < 0)
    {
            perror("accept failed");
            return 1;
    }
        return 0;
}


void *connection_handler(void *socket_desc)
{
    int sock = *(int*)socket_desc;
    int read_size;
    char client_message[51]="";

    while( (read_size = recv(sock , client_message , 50, 0)) > 0 )
    {
            printf("%s",client_message);
        }

        if(read_size == 0)
        {
            puts("Client disconnected");
            fflush(stdout);
        }
        free(socket_desc);
    return 0;
}

客户端代码:

#include <stdio.h>
#include <string.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>



int main(int argc, char **argv)
{
  int sockfd;
  struct sockaddr_in servaddr;
  socklen_t len = sizeof(servaddr);
  char mesg[1024];

  if(argc!=2){ 
      printf("Usage: %s <ip_addr>\n",argv[0]);
      exit(1);
  }

  sockfd = socket(PF_INET,SOCK_STREAM,0);
  bzero(&servaddr, sizeof(servaddr));
  servaddr.sin_family = AF_INET;
  servaddr.sin_port = htons(54321);
  inet_pton(AF_INET,argv[1],&servaddr.sin_addr);
  connect(sockfd,(struct sockaddr *)&servaddr,sizeof(servaddr));

  while(1){
    fgets(mesg,sizeof(mesg),stdin);
    sendto(sockfd,mesg,strlen(mesg),0,(const struct sockaddr *)&servaddr,len);
  }
  close(sockfd);
  return 0;
}

我得到以下输出:

Socket created
Connection accepted
Handler assigned
Hello There!
What could be the problem?
I don't know?
the problem?
Hey!
't know?
the problem?

我在客户端输入了以下字符串:

Hello There!
What could be the problem?
I don't know?
Hey!

问题是当我键入第三个字符串时，输出是第三个字符串，但第二个字符串的某些部分仍然出现。可能是什么问题呢？谢谢!

最佳答案

1. TCP 是面向流的。

2. 您不能期望 write() 写入您告诉它写入的数据，同样您也不能期望 read()读取您告诉它读取的数据量。

这两者放在一起意味着要通过套接字传输 N 个字节，对 read() 的调用次数不一定需要与对 write().

根据这个结论，读者唯一能知道的就是从它创建的那一刻起它读了多少。

读写器之间仅有的两个同步点是连接的创建和关闭。可以调用 session 的时间段。

因此，如果要在一个 session 期间传输读取器未知的多个不同大小的数据 block ，则需要在 session 期间建立额外的同步点，这使得读取检测到已收到一个完整的 block 。

这样做是在实现某种协议(protocol)。

协议(protocol)的外观有无穷无尽的可能性。协议(protocol)的详细设计取决于应用程序应涵盖的用例。

假设只传输文本数据，一个简单的协议(protocol)可以是用 \n 终止每个数据 block 。

编写器循环write()直到所有数据发送完毕，最后发送一个\n。

阅读器循环 read() 直到收到 \n。

关于c - TCP 客户端/服务器打印额外的字符串，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/18845303/