在套接字之间发送消息

Send messages between sockets

本文关键字：消息 之间 套接字      更新时间：2023-10-16

我有一个用c++和Unix中的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只提供字节流，而不会将它们粘合在一起，以供应用程序使用。

相关文章：