c++ zmq poller

ZeroMQ (ZMQ) 是一种跨平台的、高性能的、分布式消息队列库，主要用于创建分布式系统中的客户端-服务器架构。在C++中，`zmq_poller` 是 ZeroMQ 提供的一种用于异步事件驱动通信的重要工具，它允许你在单个线程中管理多个套接字，而无需轮询每个套接字。

`zmq_poller` 结构体的作用是维护一个事件集合，你可以将多个`zmq_socket_t`对象添加到`poller`中，然后调用`zmq_poll`函数来等待这些套接字中的任意一个变得可读或可写。`zmq_poll`函数接受两个参数：一个`zmq_poller_t`实例和一个时间限制（以毫秒为单位），它会在指定的时间内检查各个套接字的状态，并返回一个包含哪些套接字已准备好操作的数组。

下面是使用`zmq_poller`的基本步骤：

1. 初始化`zmq_poller`：

zmq_poller_t poller;

2. 添加套接字到`poller`：

int socket_id = zmq_socket(ctx, ZMQ_PULL); // 创建socket
zmq_pollitem_t item = {socket_id, 0, ZMQ_POLLIN, NULL}; // 初始化pollitem
zmq_poller_add(&poller, &item); // 添加到poller

3. 调用`zmq_poll`：

int timeout = 1000; // 等待1秒
size_t num_sockets = zmq_poll(&poller.items, &poller.nitems, timeout);

4. 根据`num_sockets`检查哪些套接字准备好操作：

for (int i = 0; i < num_sockets; i++) {
    if (poller.items[i].revents & ZMQ_POLLIN) {
        // 处理可读的套接字
    } else if (poller.items[i].revents & ZMQ_POLLOUT) {
        // 处理可写的套接字
    }
}