소켓 : 여러 클라이언트에 메시지 보내기

Question

N 개를 수신하고이 데이터 배치를 처리하여 모든 클라이언트에게 "완료"한 답장을 보낼 때까지 여러 클라이언트의 메시지를 수락하는 서버를 작성하려고합니다.

클라이언트에서 데이터를받은 직후에 클라이언트에 "완료"메시지를 보내면이 코드가 제대로 작동합니다. 어떻게하면 모든 클라이언트를 "저장"하고 나중에 배치를 처리 한 후에 메시지를 각각 보낼 수 있습니까?

while (true) { 
    listen(sock, 1000); 
    newsock = accept(sock, (struct sockaddr *) &cli_addr, &clilen); 
    n = read(newsock, buffer, read_len); 
    if (n < 0) { 
     cout << "ERROR reading from the socket" << endl; 
     continue; 
    } 
    memcpy(data + (msg_count * tuple_size), buffer, tuple_size); 
    n = write(newsock, "done\n", 5); //sending the message to the current client 
    msg_count++; 
    if (msg_count >= batch_size) { 
     msg_count = 0; 
     doSomethingWithTheData(data); 
     //I want to send the message to all the clients here 
    } 
    bzero(buffer, read_len); 
} 

Answer 1

다음과 같이 시도해보십시오. (3) 새로운 프로그램에서 사용 memset 함수 :

while (true) { 
    std::list<int> socks; 
    listen(sock, 1000); 
    newsock = accept(sock, (struct sockaddr *) &cli_addr, &clilen); 
    n = read(newsock, buffer, read_len); 
    if (n < 0) { 
     cout << "ERROR reading from the socket" << endl; 
     continue; 
    } 
    memcpy(data + (msg_count * tuple_size), buffer, tuple_size); 
    socks.push_back(newsock); 
    msg_count++; 
    if (msg_count >= batch_size) { 
     msg_count = 0; 
     doSomethingWithTheData(data); 

     //I want to send the message to all the clients here 
     msg_count -= socks.size(); 
     while (!socks.empty()) { 
      newsock = socks.front(); 
      n = write(newsock, "done\n", 5); //sending the message to the current client 
      close(newsock); 
      socks.pop_front(); 
     } 
    } 
    bzero(buffer, read_len); 
} 

FYI bzero() 함수는 사용되지 않으며 (POSIX.1-2001에 LEGACY으로 표시). POSIX.1-2008은 bzero()의 지정을 제거합니다

Answer 2

zeroMq를 시도 했습니까? 예 : http://zguide.zeromq.org/cpp:rrworker