我正在尝试通过 C++ 中的 Socket 发送消息。我已经阅读了很多与此相关的堆栈溢出问题，但仍然无法弄清楚它是如何工作的。假设我正在将以下字符(M、a、r、t、i、n)发送到本地主机服务器，人们建议您可以使用 4 个字节作为长度(即 32 位，以便它可以处理一条消息到 4GB 长度)。

我在客户端做了同样的事情，但仍然不知道如何在服务器端弄清楚我是想只接收开始的 3 个字节(M，a，r)还是最后 3 个字节(t，i ,n) 我的数据。

我正在发布我的代码，请主要在服务器端帮助我，如果能写几行与代码相关的代码，将不胜感激。

           Client side code
std::vector<char> userbuffer(20);
std::cout<<"\nclient:"<<std::endl;
    char* p = userbuffer.data();
    *p = 'M';
            ++p; *p = 'a';
            ++p; *p = 'r';
            ++p; *p = 't';
            ++p; *p = 'i'; 
            ++p; *p = 'n';
            size_t length = strlen(userbuffer.data());
    uint32_t nlength = htonl(length);
            //line containg message length information
           int header_info = send(socketFD, (char*)&nlength, 4, 0); 
           // Data bytes send to the server
    int bytes_sent = send(socketFD, userbuffer.data(), length, 0);

    if(bytes_sent == SOCKET_ERROR){ //some errror handling}





 Server Side Code
 char receivebuffer[MAX_DATA] = { '\0' };
 int bytesReceivedFromClientMsg = 1;
 int length_bytes = 0;
 uint32_t length, nlength;
 //code to check length if we have received whole data length
 while(length_bytes < 4){
 int read = recv(clientSocket, ((char*)&nlength)+length_bytes, (4-length_bytes), 0);
 if (read == -1) { //error handling}
 length_bytes += read;}
// Most painfull section to understand.
// I implemented this code from some ideas on internet 
//but still cant find how its extracting length and what i am reading :(
       while(bytesReceivedFromClientMsg > 0){
    int msgheader = recv(clientSocket,(char*)&nlength,6, 0);
    length = ntohl(nlength);//leng value here is in severel thousand size
    char *receivebuffer = new char(length+1);
        bytesReceivedFromClientMsg = recv(clientSocket, receivebuffer, msgheader, 0);
    receivebuffer[length] = 0 ;
    std::cout<<"msg header is :"<<msgheader<<std::endl;
    std::cout<<"msg data is :"<<bytesReceivedFromClientMsg<<std::endl;

        if(bytesReceivedFromClientMsg == SOCKET_ERROR){//some error handling}

最佳答案

您需要设计网络协议(protocol)。像 SMTP 这样的协议(protocol)是类文本协议(protocol)。您必须读取字符，直到在类似文本的协议(protocol)中找到像换行符这样的终止字符。

使用基于消息的协议(protocol)，您有更好的机会获得高性能协议(protocol)。您定义一个标题(在您的代码中使用但未定义)。在 header 中，您可以放置​​有关长度的信息以及可能有关下一条消息的类型的信息。然后在邮件正文前面发送标题。在您的示例中，正文是“Martin”。

接收者有一个状态“header received”。当未收到完整的 header (或根本没有收到)时，它将使用 header 的大小作为 block 大小。它将 chunksize 字节接收到 header 变量中。接收完 header 后，接收方将 block 大小设置为 header 中设置的大小，并将如此多的字节接收到有效负载缓冲区。完成后，状态“已收到 header ”再次为假。

int receive(socket sock, char * buffer, int chunk_size)
{
    int offset = 0;

    while (chunk_size > 0)
    {
        // add select() here when you have a non-blocking socket.
        int n = recv(sock, buffer+offset, chunk_size);
        // TODO: error handling
        offset += n;
        chunk_size -= n;
    }

    // return amount of received bytes
    return offset;
}

void do_receive(void)
{
    struct {
        int size;
        // other message information
    } header;

    while (true)
    {
        receive(sock, &header, sizeof(header);
        receive(sock, buffer, header.size);
        process_message(buffer, header.size);
    }
}

上面的代码不会通过任何编译器。但它显示了这个想法..

关于c++ - 如何提取消息的长度信息并从 TCP 字节流中只提取那么多的消息？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/21510898/