我正在使用boost::asio,我的代码如下:
void CServer::Start(int port)
{
tcp::acceptor acceptor(m_IoService, tcp::endpoint(tcp::v4(), port));
for ( ;; )
{
shared_ptr<tcp::socket> pSocket(new tcp::socket(m_IoService));
acceptor.accept(*pSocket);
HandleRequest(pSocket);
}
}
这段代码是可以运行的,但我希望改用Acceptor::async_accept,这样我就能调用Acceptor::cancel来停止接收请求。
因此,我的新代码如下:
void CServer::StartAsync(int port)
{
m_pAcceptor = shared_ptr<tcp::acceptor>( new tcp::acceptor(m_IoService, tcp::endpoint(tcp::v4(), port)) );
StartAccept();
}
void CServer::StopAsync()
{
m_pAcceptor->cancel();
}
void CServer::StartAccept()
{
shared_ptr<tcp::socket> pSocket(new tcp::socket(m_IoService));
m_pAcceptor->async_accept(*pSocket, bind(&CServer::HandleAccept, this, pSocket));
}
void CServer::HandleAccept(shared_ptr<tcp::socket> pSocket)
{
HandleRequest(pSocket);
StartAccept();
}
但是这段代码似乎不起作用,我的函数CServer::HandleAccept从未被调用。你有什么想法吗?我看了一些示例代码,与我的代码主要的区别在于他们经常创建一个名为tcp_connection的类,其中socket作为成员,而我看不出为什么那是必需的。
- 亚历克斯