Serwer wielowątkowy TCP z bibliotekami POCO C++

Question

Próbuję stworzyć serwer TCP z bibliotekami POCO C++. Znalazłem kilka przykładów: here. Najpierw spróbowałem przykładu od Alexa, ale zdarzenie zamknięcia nie działało. EchoServer ma ten sam problem. Więc, spróbowałem przykładu Cesara Ortiza i dostałem niezwykły problem. Po pewnym czasie serwer zgłasza błąd:

%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%% 
["src/ErrorHandler.cpp", line 60] 
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%% 

Połączenia otrzymały również błąd limitu czasu połączenia, również nowe połączenia. Przykład z semeedem obsługi zdarzeń jest bardziej poprawny, ale nie wiem, jak mogę naprawić zdarzenie shutdown.

Answer 1

Jeśli wszystko czego potrzebujesz, to wielowątkowy serwer TCP, to zrobi to "z pudełka" Poco::Net::TCPServer - jest wewnętrznie wielowątkowy. Zacznij od zdefiniowania połączenia, ten po prostu echo cokolwiek wysłać do niego:

class EchoConnection: public TCPServerConnection { 
public: 
    EchoConnection(const StreamSocket& s): TCPServerConnection(s) { } 

    void run() { 
    StreamSocket& ss = socket(); 
    try { 
     char buffer[256]; 
     int n = ss.receiveBytes(buffer, sizeof(buffer)); 
     while (n > 0) { 
     ss.sendBytes(buffer, n); 
     n = ss.receiveBytes(buffer, sizeof(buffer)); 
     } 
    } 
    catch (Poco::Exception& exc) 
    { std::cerr << "EchoConnection: " << exc.displayText() << std::endl; } 
    } 
}; 

Następnie należy uruchomić serwer i wysłać go niektóre dane:

TCPServer srv(new TCPServerConnectionFactoryImpl<EchoConnection>()); 
srv.start(); 

SocketAddress sa("localhost", srv.socket().address().port()); 
StreamSocket ss(sa); 
std::string data("hello, world"); 
ss.sendBytes(data.data(), (int) data.size()); 
char buffer[256] = {0}; 
int n = ss.receiveBytes(buffer, sizeof(buffer)); 
std::cout << std::string(buffer, n) << std::endl; 

srv.stop();