C linux服务器阻塞

Question

服务器：

#include<stdio.h>
#include<string.h>    //strlen
#include<sys/socket.h>
#include<arpa/inet.h> //inet_addr
#include<unistd.h>    //write
#include<stdlib.h>
#include<sys/types.h>
#include<sys/socket.h>
#include<sys/stat.h>
#include<netinet/in.h>
#include<fcntl.h>
#include <netdb.h>
#include <dirent.h>
#include <stdbool.h>
#include <string.h>
#include "shared.h"

char **serverFolderTree;
int serverFoldersNumber;

FILES *fls;
int serverFilesNumber;

void getFolders()
{
    i = 0;
    serverFolderTree = allocateFolderTree();
    serverFoldersNumber = getFolderTree(serverFolderTree, "", SERVER_ROOT);
}

void getFiles()
{
    i=0;
    fls = getFileList(fls, "", SERVER_ROOT);    
    serverFilesNumber = i;
}

int main()
{
    int socket_desc , client_sock , c , read_size;
    struct sockaddr_in server , client;
    char client_message[2000], tmp[2000];

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

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

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

    //Listen
    listen(socket_desc , 3);

    acceptNew:

    //Accept and incoming connection
    printf("\nWaiting for incoming connections...\n");
    c = sizeof(struct sockaddr_in);

    //accept connection from an incoming client
    client_sock = accept(socket_desc, (struct sockaddr *)&client, (socklen_t*)&c);
    if (client_sock < 0)
    {
        perror("accept failed");
        return 1;
    }
    printf("Connection accepted\n");

    //Receive a message from client
    while( (read_size = recv(client_sock , client_message , 2000 , 0)) > 0 )
    {
    if(!strcmp(client_message, FOLDER_TREE_REQ))//folder tree requested
    {
        printf("Recieved: folder tree req\n");
        getFolders();

        //send folder tree nr
        sprintf(tmp,"%d",serverFoldersNumber);
        write(client_sock , tmp , strlen(tmp)+1);

        //send folder tree elements
        int i;
        for(i=0;i<serverFoldersNumber;i++)
        {
        //strcpy(tmp, serverFolderTree[i]);

        sprintf(tmp,"%s",serverFolderTree[i]);
        printf("%s\n", tmp);
        write(client_sock , tmp , 1000);
        }
    }
    }

    if(read_size == 0)
    {
        printf("Client disconnected\n");
        fflush(stdout);
    //goto acceptNew;//listen for another connection
    }
    else if(read_size == -1)
    {
        perror("recv failed");
    }

    return 0;
}

客户：

#include<stdio.h> //printf
#include<string.h>    //strlen
#include<sys/socket.h>    //socket
#include<arpa/inet.h> //inet_addr
#include<stdlib.h>
#include<sys/types.h>
#include<sys/socket.h>
#include<sys/stat.h>
#include<netinet/in.h>
#include<fcntl.h>
#include <netdb.h>
#include <dirent.h>
#include <stdbool.h>
#include <string.h>
#include "shared.h"

char **clientFolderTree, **serverFolderTree;
int clientFoldersNumber, serverFoldersNumber;

FILES *fls;
int clientFilesNumber;

void getFolders()
{
    i = 0;
    clientFolderTree = allocateFolderTree();
    serverFolderTree = allocateFolderTree();
    clientFoldersNumber = getFolderTree(clientFolderTree, "", CLIENT_ROOT);
}

void getFiles()
{
    i=0;
    fls = getFileList(fls, "", CLIENT_ROOT);    
    clientFilesNumber = i;
}

int main()
{
    int sock;
    struct sockaddr_in server;
    char message[1000] , server_reply[2000];
    bool k=true; 

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

    server.sin_addr.s_addr = inet_addr("127.0.0.1");
    server.sin_family = AF_INET;
    server.sin_port = htons( 8888 );

    //Connect to remote server
    if (connect(sock , (struct sockaddr *)&server , sizeof(server)) < 0)
    {
        perror("connect failed. Error");
        return 1;
    }

    printf("Connected\n");

    //req folder tree
    getFolders();

    strcpy(message, FOLDER_TREE_REQ);
    if( send(sock , message , strlen(message) , 0) < 0)
    {
         puts("Send failed");
         return 1;
    }

    //Receive folder tree number
    recv(sock , server_reply , 2000 , 0);
    serverFoldersNumber = atoi(server_reply);

    printf("server fld nr: %d\n", serverFoldersNumber);
    //recieve folder tree
    for(i=0;i<serverFoldersNumber;i++)
    {
    if(recv(sock , server_reply , 2000 , 0) < 0)
    {
      puts("recv failed");
      break;
    }

    printf("Got: %s\n", server_reply);
    }

    close(sock);
    return 0;
}

服务器说他发送了列表（并正确打印）但在客户端它收到folderNumber（打印它并工作它是 10）但是当接收树时它打印“得到：”不到 3 次。

这里有什么问题？

Answer 1

您假设对 recv() 的调用会将单个完整的文件夹字符串加载到 server_reply 缓冲区中，即。您需要调用 recv() 的次数与文件夹字符串的次数相同。

那行不通。

TCP 不知道也不关心空终止的 C 字符串。它只传输八位字节/字节流。例如，如果您有 50 个文件夹名称共占用 8000 个字节，则可能（尽管不太可能）您可能必须调用 recv() 8000 次才能获取所有数据，每次调用仅返回一个字节。

编辑：

发送文件夹不是问题 - 你发送多少字符串，然后是字符串。

向服务器发送请求是个问题：

如果（发送（袜子，消息，strlen（消息），0）

不会发送空终止符。这可能是由于服务器缓冲区数组被初始化为 0 的副作用而第一次起作用。

在服务器接收请求是个问题：

read_size = recv(client_sock , client_message , 2000 , 0)

可以读取所有 FOLDER_TREE_REQ，或其中的一个字符，或介于两者之间的任何内容。

在客户端接收尺寸是个问题：

recv(sock , server_reply , 2000 , 0);

可能返回整个 ASCII 数字，或它的第一个字符，或介于两者之间的任何内容，或整个 ASCII 数字加上文件夹字符串的某些部分。

写(client_sock, tmp, 1000);

将尝试发送整个 1000 字节，开头为以 null 结尾的文件夹名称，结尾为未初始化/剩余字节。

..等等。

您应该修复所有代码，使其不会对超过一个字节的消息做出假设。

您应该修复所有代码，使其不依赖于传输的完整的、以空字符结尾的字符串。

您应该修复所有代码，这样无论在一次 recv() 调用、X recv() 调用还是 >X recv() 调用中接收到 X send() 调用发送的数据都无关紧要。

对不起，如果这看起来很混乱，但这就是 TCP 的生活。如果您不锁定所有内容以使其不会出错，那么即使在您的测试中看起来工作正常，它也可能会在其他人的安装上搞砸。