1

基于 boost::asio 客户端/服务器关系，只有当服务器线程处于“等待连接”状态时，我才必须从服务器程序启动客户端程序。

我的问题是如何知道那个状态？

作为示例，使用asio 示例/序列化 链接，并将 server.cpp 的主要功能替换为该代码：

#include <conio.h>
#include <concrt.h> // wait function
#include <future>
#include <thread>

void server_thread( std::promise<bool>& run )
{ 
    boost::asio::io_service io_service;
    s11n_example::server server(io_service, 123);
    // too early to run.set_value( true );
    io_service.run();
    // too late to run.set_value( true );
}

int main(int argc, char* argv[])
{
    std::promise<bool> run;
    std::thread thrd( server_thread, boost::ref( run ) );
    thrd.detach(); 

    bool launched = run.get_future().get();
    // server is waiting for connection
    // launch the client
    if( launched )
    {
        int rc = system( "start client.exe localhost 123" );
        if( rc )
            std::cerr << "system failed returning " << rc << std::endl ;
    }
    else
        std::cerr << "server_thread failure" << std::endl ;

    std::cout << "hit a key to exit"  ;
    while( !_kbhit() )
        Concurrency::wait( 100 );

    return 0;
}

谢谢，

4

1 回答 1

4

简而言之，s11n_example::server在构造函数调用完成后传入连接将立即排队的状态。

通过定义状态和操作之间的区别可能更容易理解这一点。状态决定了操作系统可以对对象做什么；应用程序启动执行操作并可能依赖于状态的操作。例如，当一个套接字处于打开状态时，操作系统会将数据排队；读取操作检索排队的数据。这同样适用于受体。当一个acceptor处于listen状态时，OS会对连接进行排队；接受操作将完成连接，将其从队列中删除。

Anacceptor的[states]和transitions()如下：

     .----> [closed] ------.     [closed]:    socket not open
     |                     |     [opened]:    socket open but not listening for
     |                     V                  connections
  close() <------.      open()   [listening]: incoming connections will be
     ^           |         |                  queued until accepted(), causing
     |           |         V                  the connection to be established
[listening]      '---- [opened]
     ^                     |
     |                     |
     '------ listen() <----'

各种重载的构造函数将导致acceptor其生命周期以关闭、打开或侦听状态开始。在 的情况下s11n_example::server，接受器是用端点构造的，因此这种重载将导致接受器在构造后处于侦听状态。这相当于做：

using boost::asio::ip::tcp;
tcp::endpoint endpoint_(tcp::v4(), 123);
tcp::acceptor acceptor_(io_service); // closed state
acceptor.open(endpoint_.protocol()); // opened state
acceptor.bind(endpoint);
acceptor.listen();                   // listening state

因此，可以在server构造之后和之前设置承诺io_service.run()： 

void server_thread(std::promise<bool>& run)
{ 
    boost::asio::io_service io_service;
    s11n_example::server server(io_service, 123);
    // The server's acceptor is in a listening state, so connection attempts
    // will be queued even without the io_service event loop running.  The
    // server also has an outstanding asynchronous accept operation.
    run.set_value(true);
    // Run the service, this will start an asynchronous loop that accepts 
    // connections.
    io_service.run();
}

需要注意的一个微妙之处是 Boost.Asio 的接受器不提供：

  • 用于接受连接的基于反应器的操作。因此，无法检测连接何时准备好被接受（即连接排队等待接受）。
  • acceptor检测是否处于侦听状态的更高级别的方法。不过，这可以通过查询接受者的native_handle. 例如，使用getsockopt()来获取 的值SOL_SOCKET/SO_ACCEPTCONN。
于 2013-04-08T15:46:38.770 回答