我正在更好地学习 boost::asio,最近我已经将它用于一些基本的服务器应用程序。所以我想我知道(一点)基础知识。
但是今天我有一个我似乎无法解决的问题:
我想建立一些传出 SSL 连接(超过 100 个)。出于这个原因,我使用了许多工作线程(因为我读到这样做可以更好地扩展)。这些工作线程除了io_service->run()
. 我使用 boost::asio SSL 客户端示例作为开始,并将这些工作线程添加到此源。在main()
我启动这些工作线程之后,我为 io_service 发布任务,如下所示:
int main( int argc, char * argv[] )
boost::shared_ptr< boost::asio::io_service > io_service(
new boost::asio::io_service
);
boost::shared_ptr< boost::asio::io_service::work > work(
new boost::asio::io_service::work( *io_service )
);
boost::shared_ptr< boost::asio::io_service::strand > strand(
new boost::asio::io_service::strand( *io_service )
);
boost::thread_group worker_threads;
for( int x = 0; x < 4; ++x )
{
worker_threads.create_thread( boost::bind( &WorkerThread, io_service ) );
}
io_service->post( boost::bind( &doConnect, io_service, "127.0.0.1", "7777" ) );
io_service->post( boost::bind( &doConnect, io_service, "192.168.2.3", "7777" ) );
work.reset();
worker_threads.join_all();
return 0;
}
doConnect()
只不过是 boost::asio SSL 客户端示例中的 main 中的原始代码:
void doConnect( boost::shared_ptr< boost::asio::io_service > io_service, string host, string port ) {
boost::asio::ip::tcp::resolver resolver(*io_service);
boost::asio::ip::tcp::resolver::query query(host, boost::lexical_cast< std::string >( port ));
boost::asio::ip::tcp::resolver::iterator iterator = resolver.resolve(query);
boost::asio::ssl::context ctx(boost::asio::ssl::context::sslv23);
ctx.load_verify_file("server.crt");
client c(io_service, ctx, iterator);
}
这段代码编译得很好,但在执行过程中发生的是我收到一个Operation canceled
错误。
我尝试了很多事情:
在此站点上阅读了一些内容后,我得到提示,示例代码中的构造函数可能存在
this
指针超出范围的问题,因此我尝试使用shared_from_this()
. 这导致了一个exception: tr11: weak pointer
.为了摆脱这个弱指针问题,我尝试将代码从构造函数移到它自己的方法
Start()
中,并在方法中创建对象后调用此doConnect()
方法。没有结果,弱指针问题仍然存在。之后,我将代码移回构造函数,就像在示例中一样,并删除了所有 SSL 特定代码,更改为普通套接字类型并再次运行它。现在我再次收到原始错误:
Operation canceled
,所以它似乎与 SSL 代码没有任何关系。一路上(但肯定没有 SSL 代码),我还收到一条错误消息,说没有网络。
任何人都可以在这个问题上闪耀他或她的光芒,因为我找不到关于错误消息本身或原因的太多信息(除了套接字已关闭或超出范围(然后也关闭)的建议)..
如果需要更多信息,请告诉我,我会发布更多文本或代码...