ソケット：複数のクライアントにメッセージを送信

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

このようなものを試してください。

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としてマーク）は推奨されません：新しいプログラムではmemset（3）を使用します。 POSIX.1-2008はbzero（）の指定を削除します

Answer 2

zeroMqを試しましたか？ たとえばhttp://zguide.zeromq.org/cpp:rrworker