C++套接字只发送前4个字节的数据

Question

我目前正在为Linux编写一个套接字包装器。它基本上是处理TCP套接字的创建，连接，发送，读取和关闭的类的集合。

在我的套接字类中，除了发送和接收函数外，所有函数都能正常工作。他们不会返回错误;相反，它只发送前四个字节的数据。

我的发送功能：

int Socket::sends(char* buffer){ 

    int bytes; // for number of bytes sent 

    /* First, send the size of buffer */ 
    int datalen = strlen(buffer); // get sizeof buffer 
    int len  = htonl(datalen); // reformat 

    // send the size of the buffer 
    bytes = send(socketfd, (char*)&len, sizeof(len), 0); // send the size 
    if (bytes < 0){ 
     cerr << "Error sending size of buffer to socket" << endl; 
     return 1; 
    } 

    /* Now acutally send the data */ 

    bytes = send(socketfd, buffer, datalen, 0); 
    if (bytes < 0){ 
     cerr << "Error writing buffer to socket" << endl; 
     return 1; 
    } 

    cout << bytes << " written" << endl; 

    return 0; 

} 

其背后的想法是，这将首先发送缓冲区的大小，然后发送实际的缓冲区的缓冲区（char* buffer）。如果遇到一个错误（返回-1）函数通过返回1

现在终止，这里是读法：

int Socket::reads(char* buffer){ 

    int bytes, buflen; // for bytes written and size of buffer 

    /* Read the incoming size */ 
    bytes = recv(socketfd, (char*)&buflen, sizeof(buflen), 0); 
    if (bytes < 0){ 
     cerr << "Error reading size of data" << endl; 
     return 1; 
    } 
    buflen = ntohl(buflen); 

    /* Read the data */ 

    bytes = recv(socketfd, buffer, buflen, 0); 
    if (bytes < 0){ 
     cerr << "Error reading data" << endl; 
     return 1; 
    } 

    return 0; 
} 

在这里，想法是先读取数据的大小，然后将缓冲区设置为该大小并读入。错误时函数返回1（recv返回-1）。

使用方法会是这个样子：

socket.sends("Hello World"); // socket object sends the message 

char* buffer; 
socket.reads(buffer); // reads into the buffer 

然而，当过我使用这些功能，我只收到了前4个字节的数据，其次是陌生的，非ASCII字符。我不知道为什么会发生这种情况。 send和recv函数中没有遇到错误，函数说明只写入4个字节。有更好的方法来发送或接收数据吗？我忽略了一个非常简单的错误？

感谢您的帮助！

Answer 1

您正在将未初始化的指针（buffer）传递给您的reads方法，这可能说明它部分工作（未定义的行为）。

，你不应该通过buffer作为参数，因为它不会被修改（和你不知道的大小尚未反正）

另外，你必须用空字符结束，当你收到您的留言它。

我会做这样的：

char *Socket::reads(){ 
    char* buffer; 
    int bytes, buflen; // for bytes written and size of buffer 

    /* Read the incoming size */ 
    bytes = recv(socketfd, (char*)&buflen, sizeof(buflen), 0); 
    if (bytes < 0){ 
     cerr << "Error reading size of data" << endl; 
     return 1; 
    } 
    buflen = ntohl(buflen); 
    buffer = new char[buflen+1]; // +1 for the NUL-terminator 
    /* Read the data */ 

    bytes = recv(socketfd, buffer, buflen, 0); 
    if (bytes < 0){ 
     cerr << "Error reading data" << endl; 
     return 1; 
    } 
    buffer[buflen] = '\0'; // NUL-terminate the string 

    return buffer; 
} 

主：

socket.sends("Hello World"); // socket object sends the message 

char* buffer = socket.reads(); // reads into the buffer 

不要忘记delete []到底缓冲区。

也可以用std::string或std::vector<char>做是为了避免new和delete