套接字：發送郵件給幾個客戶端

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）：（3）在新的程序使用memset的。 POSIX.1-2008刪除了bzero的規格（）

Answer 2

你試過zeroMq了嗎？例如 http://zguide.zeromq.org/cpp:rrworker