zmq_poll()和ASIO它的io_service.run()之间的冲突...有没有办法让ASIO与0MQ的zmq_poll()一起工作？或者有其他推荐的方法来实现这样的设置吗？注意：我可以通过使用多个线程来解决这个问题 - 但它只是一个运行该程序的非常低SCGI流量的小单核/CPU盒子，因此多线程将浪费资源...ZMQ_FD: 检索与套接字相关联的文件描述符。ZMQ_FD选项将检索与指定套接字相关联的文件描述符。返回的文件描述符可用于将套接字集成到现有事件循环中; ØMQ库将通过使文件描述符准备好进行阅读来以边缘触发的方式通知套接字上的任何挂起事件。
我认为你可以对每个zmq_pollitem_t使用null_buffers并将事件循环推迟到一个io_service中，完全绕过zmq_poll()。然而，在上述文档中似乎存在一些注意事项，特别是：
从返回的文件描述符读取数据并不一定意味着消息可供读取或可以写入基础套接字；应用程序必须使用后续检索的ZMQ_EVENTS选项来检索实际的事件状态。
因此，当您的zmq套接字之一的处理程序被触发时，我认为您需要在处理事件之前多做一些工作。以下是未编译的伪代码：
const int fd = getZmqDescriptorSomehow();
boost::asio::posix::stream_descriptor socket( _io_service, fd );
socket->async_read_some(
boost::asio::null_buffers(),
[=](const boost::system::error_code& error)
{
if (!error) {
// handle data ready to be read
}
}
);
请注意，您不必在这里使用lambda表达式，boost::bind到成员函数就足够了。
ipc连接的ZMQ中获取了一个文件描述符。但是，async_read_some(null_buffers(), ...)给了我一个“坏文件描述符”的错误... - Chris这个问题发布两年后，有人发布了一个可以完美解决此问题的项目。该项目在这里：https://github.com/zeromq/azmq。讨论其设计的博客文章在这里：https://rodgert.github.io/2014/12/24/boost-asio-and-zeromq-pt1/。
以下是从自述文件中复制的示例代码：
#include <azmq/socket.hpp>
#include <boost/asio.hpp>
#include <array>
namespace asio = boost::asio;
int main(int argc, char** argv) {
asio::io_service ios;
azmq::sub_socket subscriber(ios);
subscriber.connect("tcp://192.168.55.112:5556");
subscriber.connect("tcp://192.168.55.201:7721");
subscriber.set_option(azmq::socket::subscribe("NASDAQ"));
azmq::pub_socket publisher(ios);
publisher.bind("ipc://nasdaq-feed");
std::array<char, 256> buf;
for (;;) {
auto size = subscriber.receive(asio::buffer(buf));
publisher.send(asio::buffer(buf));
}
return 0;
}
看起来不错。如果你尝试了，请在评论中告诉我它在2019年是否仍然有效（我可能会在几个月后尝试，然后更新这个答案）（该存储库已经过时，最后一次提交是一年前）
acceptor和socket的.native()方法中的ASIO文件描述符，并将它们插入zmq_pollitem_t数组中，使用ZeroMQ的事件循环zmq_pollitem_t数组是一个大麻烦，可以通过使用ASIO事件循环来避免。// Create a pool of threads to run all of the io_services.
std::vector<boost::shared_ptr<boost::thread> > threads;
for(std::size_t i = 0; i < thread_pool_size_; ++i) {
boost::shared_ptr<boost::thread> thread(new boost::thread(boost::bind(&boost::asio::io_service::run, &io_service_)));
threads.push_back(thread);
}
while (1) {
char buffer [10];
zmq_recv (responder_, buffer, 10, 0);
io_service_.post(boost::bind(&server::handle_zeromq_message, buffer, this));
}
zmq_poll() 的名称是具有误导性的，因为它不是“经典轮询”。它的名称源于 poll()，就像在 http://linux.die.net/man/2/poll 中所述的那样 - 这不是经典轮询。-- 到目前为止，我只能看到让 ZMQ 和 ASIO 立即返回的解决方案，这会导致经典轮询结果旋转（不好），或者使其中一个或两个阻塞，从而导致处理 ZMQ 和/或 ASIO 消息的巨大延迟。或者我没有正确理解您的评论 :( - Chris
zmq_poll()请求方面有什么延迟要求？你可以通过在io_service中运行zmq_poll()（通过在deadline_timer中处理它）来实现。如果您认为这是可接受的，我可以在答案中编写一个示例。 - Chad