发送带有多个数字的字符串客户端/服务器 TCP

Question

我正在使用 C 语言进行 TCP 客户端/服务器通信。客户端必须获取数据数量（不是 > 6），获取数据并将它们以单个字符串消息的形式发送到服务器，如下所示：4 11 21 9 11. 4是数据个数，11、21、9、11是数据。

然后，服务器必须读取消息，打印它并将接收到的数据数量发送给客户端（4）。

我为客户试过这个：

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




int main(int argc, char *argv[]) {

    int simpleSocket = 0;
    int simplePort = 0;
    int returnStatus= 0;
    char buffsend[256];
    char buffrecv[256];
    int n, i;
    struct sockaddr_in simpleServer;

    if (3 != argc) {

        fprintf(stderr, "Usage: %s <server> <port>\n", argv[0]);
        exit(1);

    }

    /* create a streaming socket      */
    simpleSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);

    if (simpleSocket == -1) {

        fprintf(stderr, "Could not create a socket!\n");
        exit(1);

    }
    else {
        fprintf(stderr, "Socket created!\n");
    }

    /* retrieve the port number for connecting */
    simplePort = atoi(argv[2]);

    /* setup the address structure */
    /* use the IP address sent as an argument for the server address  */
    //bzero(&simpleServer, sizeof(simpleServer)); 
    memset(&simpleServer, '\0', sizeof(simpleServer));
    simpleServer.sin_family = AF_INET;
    //inet_addr(argv[2], &simpleServer.sin_addr.s_addr);
    simpleServer.sin_addr.s_addr=inet_addr(argv[1]);
    simpleServer.sin_port = htons(simplePort);

    /*  connect to the address and port with our socket  */
    returnStatus = connect(simpleSocket, (struct sockaddr *)&simpleServer, sizeof(simpleServer));

    if (returnStatus == 0) {
        fprintf(stderr, "Connect successful!\n");
    }
    else {
        fprintf(stderr, "Could not connect to address!\n");
    close(simpleSocket);
    exit(1);
    }





    /* get the message from the server   */



      do {

        printf("get numb of data or terminate(write '0'): ");
        fgets(buffsend,256,stdin);
        n=atoi(buffsend);
        if(n>6) {
          printf("Error\n");

         }
        else {
                for(i=0;i<n;i++) {
                   printf("insert number: ");
                   fgets(buffsend,256,stdin);
                   write(simpleSocket, buffsend, strlen(buffsend)+1);


         }



     } while((n!=0) && (n>0));





    close(simpleSocket);
    return 0;

}

这用于服务器：

#include <stdio.h>      
#include <sys/types.h>
#include <sys/socket.h>   
#include <netdb.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h> 

int main(int argc, char *argv[]) {

    int simpleSocket = 0;
    int simplePort = 0;
    int returnStatus = 0;
    char buff[256];
    char message[256];
    int count;

    struct sockaddr_in simpleServer;

    if (2 != argc) {

        fprintf(stderr, "Usage: %s <port>\n", argv[0]);
        exit(1);

    }

    simpleSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);

    if (simpleSocket == -1) {

        fprintf(stderr, "Could not create a socket!\n");
        exit(1);

    }
    else {
        fprintf(stderr, "Socket created!\n");
    }

    /* retrieve the port number for listening */
    simplePort = atoi(argv[1]);

    /* setup the address structure */
    /* use INADDR_ANY to bind to all local addresses  */
    memset(&simpleServer, '\0', sizeof(simpleServer)); 
    simpleServer.sin_family = AF_INET;
    simpleServer.sin_addr.s_addr = htonl(INADDR_ANY);
    simpleServer.sin_port = htons(simplePort);

    /*  bind to the address and port with our socket  */
    returnStatus = bind(simpleSocket,(struct sockaddr *)&simpleServer,sizeof(simpleServer));

    if (returnStatus == 0) {
        fprintf(stderr, "Bind completed!\n");
    }
    else {
        fprintf(stderr, "Could not bind to address!\n");
    close(simpleSocket);
    exit(1);
    }

    /* lets listen on the socket for connections      */
    returnStatus = listen(simpleSocket, 5);

    if (returnStatus == -1) {
        fprintf(stderr, "Cannot listen on socket!\n");
    close(simpleSocket);
        exit(1);
    }

    while (1)

    {

        struct sockaddr_in clientName = { 0 };
    int simpleChildSocket = 0;
    int clientNameLength = sizeof(clientName);

    /* wait here */

        simpleChildSocket = accept(simpleSocket,(struct sockaddr *)&clientName, &clientNameLength);

    if (simpleChildSocket == -1) {

            fprintf(stderr, "Cannot accept connections!\n");
        close(simpleSocket);
        exit(1);

    }

        /* handle the new connection request  */
    /* write out our message to the client */


        while(read(simpleChildSocket, buff, 256))
            cont++;
            printf("%s", buff);
        printf("Data received: %d %s\n", cont, buff);



       close(simpleChildSocket);
    }

    close(simpleSocket);
    return 0;

}

Answer 1

问题是客户端在每个值之后发送一个字符串终止符 (\0)，所以当服务器打印整个消息时，它会在第一个值之后停止打印。

这个特殊问题可以通过在发送时不包括字符串终止符来解决：

      write(simpleSocket, buffsend, strlen(buffsend)); /* Removed the +1 */

接收消息时需要添加字符串结束符：

    int length;
    char buff[256];

    while((length = read(simpleChildSocket, buff, 256-1)) > 0) {
        buff[length] = `\0`;
        cont++;
        printf("Data received: %d %d %s\n", cont, length, buff);
    }

还请注意，您使用的是基于流的套接字。这意味着套接字本身没有消息协议的概念。请参阅this question 了解更多信息。

Answer 2

我无法编译您的客户端进行测试。我使用 netcat 进行测试（netcat 0 端口）

我不明白是什么问题，是因为你没有打印吗？ 这是因为 printf 使用 puts，而 puts 做了一些缓冲，所以每当客户端关闭时（以及 clientFd 已关闭）

如果是因为你有未定义的行为，这里有一些建议：

1 : 不要忘记你的 buff 中的 '\0'

2 : 避免静态分配 (buff[256])，使用 getline 函数代替。你得到了一条 malloced 行（相信我，玩堆栈会给你带来很多未定义的行为 (https://en.wikipedia.org/wiki/Stack_(abstract_data_type))

3 : 使用 valgrind

运行大量条件跳转

否则，通讯系统似乎还可以。

Answer 3

    while(read(simpleChildSocket, buff, 256))
        cont++;
        printf("%s", buff);

这行不通。您调用 read 就好像它理解您的消息格式并返回与消息对应的 C 样式字符串。但它不能这样做，因为它不知道你的消息是什么样的。

您需要存储read 的返回值，以便知道您读取了多少字节并将其放入缓冲区以确定它是否为消息。如果你想把它当作 C 风格的字符串，你必须让它遵循 C 风格的字符串的规则。

               write(simpleSocket, buffsend, strlen(buffsend)+1);

这也有点令人费解。通过将字符串的长度加一，您发送的是零字节。但是您对消息的描述并没有说明零字节。如果您的消息以零字节终止，那么您的“接收消息”代码必须查找零字节以找到终止符，以便它知道消息在哪里结束。你也没有代码可以做到这一点。

所以，回去一点。精确定义您的消息格式。它是否包含零字节？或者你如何找到消息的结尾？如果您阅读“2 1 3”，那是一条完整的信息吗？你怎么知道不是“2 1 37”，7 还没到？

确定消息格式并了解它应该如何工作后，编写代码来接收消息。