zmq_poll 作用

zmq_poll是ZeroMQ库中的一个函数，用于在多个套接字上进行异步I/O操作的轮询。它可以用于同时监视多个套接字上的事件，并在事件发生时进行相应的处理。zmq_poll函数的作用是等待指定的套接字上发生事件，并返回发生事件的套接字的数量。

以下是一个使用zmq_poll函数的示例：

#include <zmq.h>
#include <stdio.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:5556");

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

    while (true) {
        zmq_poll(items, 2, -1);

        if (items[0].revents & ZMQ_POLLIN) {
            // 处理socket1上的事件
            printf("Received message from socket1\n");
        }

        if (items[1].revents & ZMQ_POLLIN) {
            // 处理socket2上的事件
            printf("Received message from socket2\n");
        }
    }

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

    return 0;
}

这个示例中，我们使用zmq_poll函数同时监视了两个套接字socket1和socket2。在无限循环中，zmq_poll函数会等待直到有事件发生在这两个套接字上。当socket1上有消息到达时，我们会打印"Received message from socket1"；当socket2上有消息到达时，我们会打印"Received message from socket2"。