BOOST-ASIO阻塞服務器不響應阻塞客戶端？

Question

我最近有問題的服務器解決了這個question，但事實證明，服務器似乎沒有回覆客戶端，也沒有收到任何數據發送。這就是我在客戶端所做的。

C:\blocking_tcp_echo_client\bin\Debug>blocking_tcp_echo_client 127.0.0.1 4001 
Enter message: hello 
Exception: read: End of file 

這是服務器端。我在啓動客戶端之前啓動了服務器。我也測試了客戶端的原始code，它工作得很好。

C:\boost_server_class\bin\Debug>boost_server_class 
TCPIP_server: 
Usage: blocking_tcp_echo_server 

blocking_tcp_echo_client.cpp

#include <cstdlib> 
#include <cstring> 
#include <iostream> 
#include <boost/asio.hpp> 

using boost::asio::ip::tcp; 

enum { max_length = 1024 }; 

int main(int argc, char* argv[]) 
{ 
    try 
    { 
    if (argc != 3) 
    { 
     std::cerr << "Usage: blocking_tcp_echo_client <host> <port>\n"; 
     return 1; 
    } 

    boost::asio::io_service io_service; 

    tcp::resolver resolver(io_service); 
    tcp::resolver::query query(tcp::v4(), argv[1], argv[2]); 
    tcp::resolver::iterator iterator = resolver.resolve(query); 

    tcp::socket s(io_service); 
    s.connect(*iterator); 

    using namespace std; // For strlen. 
    std::cout << "Enter message: "; 
    char request[max_length]; 
    std::cin.getline(request, max_length); 
    size_t request_length = strlen(request); 
    boost::asio::write(s, boost::asio::buffer(request, request_length)); 

    char reply[max_length]; 
    size_t reply_length = boost::asio::read(s, 
     boost::asio::buffer(reply, request_length)); 
    std::cout << "Reply is: "; 
    std::cout.write(reply, reply_length); 
    std::cout << "\n"; 
    } 
    catch (std::exception& e) 
    { 
    std::cerr << "Exception: " << e.what() << "\n"; 
    } 

    return 0; 
} 

boost_server_class.cpp

#include "TCPIP_server.h" 
#include <iostream> 

int main() 
{ 
    std::cout<<"TCPIP_server:"<<std::endl; 
    TCPIP_server server; 

    server.main_server(); 

    return 0; 
} 

TCPIP_server.h

#include <boost/thread/thread.hpp> 
#include <boost/bind.hpp> 
#include <boost/smart_ptr.hpp> 
#include <boost/asio.hpp> 
#include <cstdlib> 
#include <iostream> 

using boost::asio::ip::tcp; 

const int max_length = 1024; 

class TCPIP_server 
{ 
     private: 

      typedef boost::shared_ptr<tcp::socket> socket_ptr; 
      char data[max_length]; 

     public: 

     TCPIP_server(){} 
     ~TCPIP_server(){} 
     void session(socket_ptr sock) 
     { 
      std::cout<<"TCPIP_server session:"<<std::endl; 
      try 
      { 
       for (;;) 
       { 
        char data[max_length]; 

        boost::system::error_code error; 
        size_t length = sock->read_some(boost::asio::buffer(data), error); 
        if (error == boost::asio::error::eof) 
         break; // Connection closed cleanly by peer. 
        else if (error) 
         throw boost::system::system_error(error); // Some other error. 

        boost::asio::write(*sock, boost::asio::buffer(data, length)); 
       } 
      } 
      catch (std::exception& e) 
      { 
       std::cerr << "Exception in thread: " << e.what() << "\n"; 
      } 
     } 
     void server(boost::asio::io_service& io_service, short port) 
     { 
      tcp::acceptor a(io_service, tcp::endpoint(tcp::v4(), port)); 

      for (;;) 
      { 
       socket_ptr sock(new tcp::socket(io_service)); 
       a.accept(*sock); 
       boost::bind(&TCPIP_server::session, this, sock); 
      } 
     } 
     void main_server() 
     { 
      try 
      { 
       std::cerr << "Usage: blocking_tcp_echo_server \n"; 
       boost::asio::io_service io_service; 

       using namespace std; // For atoi. 
       server(io_service, atoi("4001")); 
      } 
      catch (std::exception& e) 
      { 
       std::cerr << "Exception: " << e.what() << "\n"; 
      } 
     } 
}; 

Answer 1

您的服務器壞了。

接受連接後，您將創建一個永不調用的未命名函子綁定到TCPIP_server::session()。接受的套接字將立即超出範圍，關閉套接字並且客戶端看到eof。

socket_ptr sock(new tcp::socket(io_service)); 
a.accept(*sock); 
boost::bind(&TCPIP_server::session, this, sock); // <-- this does nothing 

你可以通過刪除函子，而是接受連接後調用this->session(sock)解決這個問題。然而，我不會建議這種方法，因爲您的服務器是單線程的，所以在第一次連接後它將無法爲其他客戶端提供服務。相反，我建議遵循async echo sever example並使用單個線程，單個io_service和異步方法重寫您的服務器。