0

我正在使用 TCP 服务器，并且正在使用 boost 库来实现 tcp 和套接字功能。我也在使用 boost 进行线程化。服务器可以工作，但是当我将客户端连接到服务器时，服务器会创建两个线程而不是一个。在接受连接后，我有一个控制台打印，并且每个连接都会看到此打印行两次。对于每个连接，将使用处理连接的函数创建一个新线程。我创建了一个 GlobalControll 类来设置服务器并处理连接。我的问题是为什么每个连接创建两个线程？因为它应该在使用接受功能后等待新的连接。

Bellow是我认为出现问题的构造函数。

GlobalControl::GlobalControl(){

cout << "Setting up a server with the default port (" << PORTNUMBER << ")" << endl;

// Protocol and port
 boost::asio::ip::tcp::endpoint endpoint(boost::asio::ip::tcp::v4(), PORTNUMBER);   

 // Create acceptor
 boost::asio::ip::tcp::acceptor acceptor(io_service, endpoint);   

 // Create socket
 boost::asio::ip::tcp::socket socket(io_service); 

 for(;;){

     // Create socket
     SmartSocket sock(new boost::asio::ip::tcp::socket(io_service));

     // Waiting for client
     acceptor.accept(*sock);
     cout << "Client connected" << endl;
     boost::thread t(InitHandler, sock); 
     Sleep(1);
 };  
};

每个线程运行的 Inithandler 函数是以下函数：

    // Global function that each thread wil run
    void InitHandler(SmartSocket sock){

    int result = -1;
    byte RecvData[DataGenerator::SHA256BYTESIZE];
    DataGenerator DatGen;

       try
       {
            bool pending = true;
            while(pending)
           {
            // Generate a new vector
            DatGen.GenerateInputData();

            // Send vector
            boost::asio::write(*sock, boost::asio::buffer(DatGen.digest, sizeof(DatGen.digest)));

            // Make sure that the RecvData variable is clear
            CleanData(RecvData, DataGenerator::SHA256BYTESIZE);

            // Recieve data back from client
            boost::asio::read(*sock, boost::asio::buffer(RecvData, DataGenerator::SHA256BYTESIZE));

            // Compare input vector with recieved data from client
            result = memcmp (DatGen.digest, RecvData, sizeof(DataGenerator::SHA256BYTESIZE));

            if(result != 0){
                cout << "Error found" << endl;
            };


        }
   }
           catch (std::exception& e){
         // std::cout << "Exception in thread: " << e.what() << std::endl;
       }
    };

如果有人可以帮助我或给我关于这个问题的提示，那就太好了！提前谢谢了。

4

1 回答 1

0

发现了问题。没有以正确的方式将客户端套接字连接到服务器套接字。服务器的代码（在这个线程中）不是问题。在客户端以一种奇怪的方式调用了连接函数两次。

解决了服务端socket后只调用connect就解决了这个问题，见下图：（解析服务端socket的代码省略）。

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

感谢所有的评论。

于 2013-07-10T09:12:08.580 回答