在套接字之间发送消息答案

【问题标题】：Send messages between sockets在套接字之间发送消息
【发布时间】：2012-12-13 23:19:07
【问题描述】：

我有 1 台在 Unix 中使用 C++ 和 c 套接字构建的服务器。客户端正在使用 QT 和它附带的套接字 api。

服务器向客户端发送 345 字节的数据。

从服务器发送消息：

void Moderator::testSynch(){
  int type = (int) SYNCRHONIZE_M;
  //Update all connected clients with info about other clients
  for(int i = 0; i<nrOfClients_; i++){
    const TcpSocket &clientSocket = clients_[i].getSocket();
    int clientID = clients_[i].getID();

    int tempType = htonl(type);
    int tempClientID = htonl(clientID);
    int tempNrOfClients = htonl(funNrOfClients);

    clientSocket.writeData((const char*) &tempType, sizeof(tempType));
    clientSocket.writeData((const char*) &tempClientID, sizeof(tempClientID));
    clientSocket.writeData((const char*) &tempNrOfClients, sizeof(tempNrOfClients));

    for(int j = 0; j<nrOfClients; j++){ //Send info about connectecd clients

        int tempLength = (int) clients_[j].getName().length();
        int tempID = clients_[j].getID();
        string tempName = clients_[j].getName();

        tempID = htonl(tempID);
        tempLength = htonl(tempLength);
        clientSocket.writeData((const char*) &tempID, sizeof(tempID));
        clientSocket.writeData((const char*) &tempLength, sizeof(tempLength));
        clientSocket.writeData(tempName.c_str(), (int)tempName.length());

    }
  }
}

bool TcpSocket::writeData(const char* buffer, int length)const{
  size_t bytesLeft = length;
  ssize_t bytesWritten = 0;

  while((bytesWritten = write(socketFD_, buffer, bytesLeft)) > 0){
    bytesLeft -= bytesWritten;
    buffer += bytesWritten;
  }
  return bytesLeft == 0;
}

在客户端读取消息：

 void ChatClient::readMessage(Message &message){

 if(socket_->readData((char*) &type, sizeof(type))){
   if(type == SYNCRHONIZE_M){
        int nrOfUsers = 0;

        socket_->readData((char*) &ID_, sizeof(ID_)); //Set the client ID that server gave us
        socket_->readData((char*) &nrOfUsers, sizeof(nrOfUsers));

        ID_ = ntohl(ID_);
        nrOfUsers = ntohl(nrOfUsers);
        qDebug("%s=%d", "nrOfUsers", nrOfUsers);
        message.setMessageType(SYNCRHONIZE_M);
        messageOK = true;
        for(int i = 0; i<nrOfUsers; i++){ //Update client with all connected users to server
            int userID = 0;
            int nameLength = 0;

            socket_->readData((char*) &userID, sizeof(userID));
            socket_->readData((char*) &nameLength, sizeof(nameLength));

            userID = ntohl(userID);
            nameLength = ntohl(nameLength);

            if(nameLength > 0){
                qDebug("%s=%d", "nameLength", nameLength);
                buffer = new char[nameLength];
                socket_->readData(buffer, nameLength);

                message.addUser(ConnectedUser(buffer, nameLength, userID));
                delete [] buffer;
            }
        }
    }
}
}

bool TcpSocket::readData(char* buffer, int length){
    int bytesLeft = length;
    int bytesRead = 0;

    while((bytesRead = qSocket_->read(buffer, bytesLeft)) > 0){
       bytesLeft -= bytesRead;
       buffer += bytesRead;

    }
    return bytesLeft == 0;
}

我遇到的问题是有时无法同时获得来自服务器的整个消息。

例如，前 45 个字节在客户端可用。然后客户端尝试读取整个消息（345 字节），这会导致奇怪的行为。客户端读取完下一个 300 字节后立即可用。

在套接字之间发送消息的最佳方式是什么？另外，如何确定是否已收到整条消息？

【问题讨论】：

TCP 不提供任何类型的消息边界，它只是一个字节流。您需要循环调用read()，直到获得所有预期数据。如果您发布您的 readXXX 函数的实现，有人可能会提供更具体的建议。
对我来说很合适。什么是“奇怪的行为”？假设套接字处于阻塞模式，readString 应该等待整个消息被接收。如果是非阻塞模式，调用read()时需要检查EWOULDBLOCK错误。
问题是当我开始阅读时，预期的整个消息只有一部分可用。例如，当套接字流中的下一个字节是字符串字符时，这将导致客户端调用 readInt()。
将整个消息累积到一个缓冲区中，并通过一次发送操作发送。在接收端，继续调用receive，直到你有完整的消息，然后处理它。您正在尝试在没有实际实现协议的情况下使应用程序消息协议工作——这将永远工作。如果您有应用程序消息的概念，则必须编写代码以按照根据您的协议定义消息的规则来发送和接收这些消息。
“您正在尝试使应用程序消息协议工作而没有实际实现该协议”不确定我理解您的意思。你能详细说明一下吗？

标签： c++ qt sockets

【解决方案1】：

你有一些只存在于你脑海中的“信息”概念。您的代码中没有任何内容反映了这一点。如果您有一个涉及发送“消息”的应用程序协议，那么您需要编写代码来发送 message 和代码来接收基于协议的 message消息的定义。 TCP 只提供字节流，并不会为应用程序将它们粘合在一起形成大于一个字节的任何内容。

【讨论】：