zmq_poll()

zmq_poll()函数是ZeroMQ库中的一个函数，用于等待多个ZeroMQ套接字上的事件。它的语法如下：

int zmq_poll(zmq_pollitem_t *items, int nitems, long timeout);

其中，items是一个指向zmq_pollitem_t结构体的指针，nitems是items数组中元素的数量，timeout是等待的毫秒数。zmq_pollitem_t结构体定义如下：

typedef struct zmq_pollitem_t {
    void *socket;
    int fd;
    short events;
    short revents;
} zmq_pollitem_t;

其中，socket是一个指向ZeroMQ套接字的指针，fd是套接字的文件描述符，events是等待的事件掩码，revents是返回的事件掩码。

下面是一个使用zmq_poll()函数等待多个ZeroMQ套接字上的事件的例子：

#include <zmq.h>
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>

int main()
{
    void *context = zmq_ctx_new();

    void *socket1 = zmq_socket(context, ZMQ_SUB);
    zmq_connect(socket1, "tcp://localhost:5555");
    zmq_setsockopt(socket1, ZMQ_SUBSCRIBE, "", 0);

    void *socket2 = zmq_socket(context, ZMQ_REQ);
    zmq_connect(socket2, "tcp://localhost:6666");

    zmq_pollitem_t items[] = {
        {socket1, 0, ZMQ_POLLIN, 0},
        {socket2, 0, ZMQ_POLLOUT, 0}
    };

    while (1) {
        zmq_poll(items, 2, -1);
        if (items[0].revents & ZMQ_POLLIN) {
            printf("Received message from socket1\n");
        }
        if (items[1].revents & ZMQ_POLLOUT) {
            printf("Can send message to socket2\n");
        }
    }

    zmq_close(socket1);
    zmq_close(socket2);
    zmq_ctx_destroy(context);

    return 0;
}

该例子中，我们创建了两个ZeroMQ套接字，一个是SUB套接字，一个是REQ套接字。我们使用zmq_poll()函数等待这两个套接字上的事件，当SUB套接字上有消息到达时，我们打印一条消息；当REQ套接字可以发送消息时，我们也打印一条消息。注意，我们在等待事件时使用了无限超时，即timeout参数为-1。