소켓 사이에 메시지 보내기

Question

유닉스에는 C++ 및 c 소켓으로 빌드 된 서버가 1 대 있습니다. 클라이언트는 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 바이트가 사용 가능하게됩니다.

소켓간에 메시지를 보내는 가장 좋은 방법은 무엇입니까? 또한 전체 메시지를 받았는지 어떻게 확인할 수 있습니까?

Answer 1

머리 속에 만 존재하는 "메시지"라는 개념이 있습니다. 당신의 코드에 그 어떤 것도 반영되어 있지 않습니다. 전송 된 "메시지"가 포함 된 응용 프로그램 프로토콜이있는 경우 메시지의 프로토콜 정의에 따라 메시지을 전송하고 메시지을 수신하도록 코드를 작성해야합니다. TCP는 바이트 스트림을 제공하며 응용 프로그램 용으로 이들을 하나의 바이트 이상으로 결합하지 않습니다.