我有一个服务器应用程序和一个客户端应用程序，它们都是用 C 语言编写的。两者都在 tcp 套接字上进行通信。我想从客户端向服务器以及从服务器向客户端发送大量数据。

我已经针对最大 2262 字节进行了测试。

我发现当我从服务器(运行 debian 7)向客户端(运行 ubuntu 14.04 LTS)发送 2262 个字节时，我能够一次接收所有字节(两者都在通过 wlan 通信的本地网络中)。

但是当我尝试从客户端向服务器发送相同数量的字节时，我只能读取 1448 个字节(经常)和几次 3000 个字节(3000 个字节是我想从文件中读取的最大字节数描述符)一次在服务器上。

我还发现，如果我在同一台机器上同时运行服务器和客户端应用程序，我能够同时从服务器到客户端以及从客户端到服务器发送和接收 2262 字节。在提出这个问题之前，我对所有案例都进行了多次测试。

我还引用了 Beejs 指南，我首先发现我必须确保我一次发送准确的字节数。我用发送和写入函数检查了这一点，发现我只一次发送所有字节。

我在那本书中也发现了与 MTU 主题相同的问题。

我的第一个问题是，如果最大传输单元是原因，那么为什么我能够从服务器向客户端发送相同数量的数据，而不能从客户端向服务器接收数据？

我的第二个问题是，如果不能同时从服务器和客户端发送或接收数据 block (绝对小于 10 KB)，Beej 为此建议了一种数据封装子方法。除了 Beej 建议的这种方法之外，还有其他方法可以一次发送和接收数据(最多 10 KB 或可能更多)吗？

客户端代码只是不断地在服务器套接字上写入 2262 字节。 这是服务器代码。

 #include<stdio.h>
 #include<string.h>    //strlen
 #include<stdlib.h>    //strlen
 #include<sys/socket.h>
 #include<arpa/inet.h> //inet_addr
 #include<unistd.h>    //write
 #include<pthread.h> //for threading , link with lpthread

 #define MAX_SIZE 3000 

//the thread function
void *connection_handler(void *);

int main(int argc , char *argv[])
{
int socket_desc , client_sock , c , *new_sock;
struct sockaddr_in server , client;

//Create socket
socket_desc = socket(AF_INET , SOCK_STREAM , 0);
if (socket_desc == -1)
{
    printf("Could not create socket");
}
puts("Socket created");

//Prepare the sockaddr_in structure
server.sin_family = AF_INET;
server.sin_addr.s_addr = INADDR_ANY;
server.sin_port = htons( 6000 );

//Bind
if( bind(socket_desc,(struct sockaddr *)&server , sizeof(server)) < 0)
{
    //print the error message
    perror("bind failed. Error");
    return 1;
}
puts("bind done");

//Listen
listen(socket_desc , 3);

//Accept and incoming connection
puts("Waiting for incoming connections...");
c = sizeof(struct sockaddr_in);

while( (client_sock = accept(socket_desc, (struct sockaddr *)&client, (socklen_t*)&c)) )
{
    puts("Connection accepted");

    pthread_t sniffer_thread;
    new_sock = malloc(1);
    *new_sock = client_sock;

    if( pthread_create( &sniffer_thread , NULL ,  connection_handler , (void*) new_sock) < 0)
    {
        perror("could not create thread");
        return 1;
    }

    //Now join the thread , so that we dont terminate before the thread
    //pthread_join( sniffer_thread , NULL);
    puts("Handler assigned");
}

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

return 0;
}

/*
 * This will handle connection for each client
* */
void *connection_handler(void *socket_desc)
{
//Get the socket descriptor
int sock = *(int*)socket_desc;
int read_size, i;
uint8_t message[MAX_SIZE];

//Receive a message from client
while( (read_size = read(sock , message , sizeof(message))) > 0 )
{
i = 0;
printf("bytes read- %d\n", read_size);

}

if(read_size == 0)
{
    puts("Client disconnected");
    fflush(stdout);
}
else if(read_size == -1)
{
    perror("recv failed");
}

//Free the socket pointer
free(socket_desc);

return 0;
}

最佳答案

引自http://linux.die.net/man/2/read

Return Value

On success, the number of bytes read is returned (zero indicates end of file), and the file position is advanced by this number. It is not an error if this number is smaller than the number of bytes requested; this may happen for example because fewer bytes are actually available right now (maybe because we were close to end-of-file, or because we are reading from a pipe, or from a terminal), or because read() was interrupted by a signal

所以 read 并没有像您期望的那样工作。它不保证它会在一次调用中返回您请求的金额。您指定的数量只是您收到的实际数据的上限。

关于c - 在本地网络中读取 tcp 套接字上的完整数据，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/34511321/