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 不知道也不关心以 null 结尾的 C 字符串。它仅传输八位字节/字节流。比方说，如果您有 50 个文件夹名称，总共占用 8000 个字节，则可能(尽管不太可能)您可能必须调用 recv() 8000 次才能获取所有数据，每次调用仅返回一个字节。

编辑:

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

向服务器发送请求出现问题:

if( send(sock , message , strlen(message) , 0)

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

服务器端接收请求有问题:

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

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

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

recv(sock , server_reply , 2000 , 0);

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

write(client_sock , tmp , 1000);

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

..等等。

您应该修复所有代码，以便它不会对任何超过一个字节的消息进行假设。

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

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

抱歉，如果这看起来很困惑，但这就是 TCP 的生活。如果您不锁定所有内容以免出错，它可能会在其他人的安装上搞砸，即使它在您的测试中似乎工作正常。