zmq_connect和zmq_poll

文章内容：
介绍函数zmq_connect和zmq_poll的使用

zmq_connect

zmq_connect函数是ZeroMQ库中的一个函数，用于在C语言中创建一个与指定地址的ZeroMQ套接字的连接。该函数的原型如下：

int zmq_connect(void *socket, const char *endpoint);

其中，socket为已创建的ZeroMQ套接字对象，可以是ZMQ_REQ、ZMQ_REP、ZMQ_PUB、ZMQ_SUB、ZMQ_PUSH、ZMQ_PULL、ZMQ_PAIR等类型；endpoint为一个字符串，表示要连接的服务端地址，格式参考ZeroMQ的地址规范。

该函数的功能是将套接字与指定的服务端地址建立连接。它会向所有可达的服务端地址发送连接请求，并等待服务端应答。如果连接请求成功，返回值为0；如果连接请求失败，返回值为-1，并通过全局变量errno设置相应的错误码。

使用示例：

#include <zmq.h>int main() {void *context = zmq_ctx_new();void *socket = zmq_socket(context, ZMQ_REQ);int rc = zmq_connect(socket, "tcp://localhost:5555");if (rc == 0) {printf("Connect success\n");} else {printf("Connect failed, error code: %d\n", errno);}zmq_close(socket);zmq_ctx_term(context);return 0;
}

以上代码创建了一个ZeroMQ上下文和一个REQ类型的套接字，并使用zmq_connect函数连接到本地的5555端口。如果连接成功，会输出"Connect success"，否则会输出"Connect failed"和相应的错误码。最后需要关闭套接字和上下文对象。

需要注意的是，zmq_connect函数并不会立即连接到指定的服务端地址，而是会在下一次ZeroMQ套接字的I/O操作（如发送或接收消息）时尝试连接。所以，在调用zmq_connect函数后，如果没有进行任何I/O操作，可能无法立即得知连接是否成功。在实际使用中，可以在连接失败时进行重试，或者通过zmq_poll等方法来检测连接是否成功。

zmq_poll

zmq_poll函数是ZeroMQ库中的一个函数，用于在C语言中多路复用ZeroMQ套接字的I/O操作。该函数的原型如下：

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

其中，items是一个指向zmq_pollitem_t结构体数组的指针，每个结构体包含一个ZeroMQ套接字以及该套接字上感兴趣的事件类型；nitems表示数组中元素的个数；timeout表示等待的超时时间，单位是毫秒。

结构体zmq_pollitem_t定义如下：

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

其中，socket是一个指向ZeroMQ套接字对象的指针；fd是一个指向操作系统文件句柄的指针，可用于与其他I/O多路复用库一起使用；events是感兴趣的事件类型，可以是ZMQ_POLLIN（可读事件）或ZMQ_POLLOUT（可写事件）；revents在函数返回时表示实际发生的事件类型。

函数的功能是等待指定的ZeroMQ套接字上的事件发生，并返回发生事件的个数（也可以返回0或-1表示错误）。函数调用时会一直阻塞，直到发生感兴趣的事件，或者超时时间到达。

使用示例：

#include <zmq.h>int main() {void *context = zmq_ctx_new();void *socket = zmq_socket(context, ZMQ_REQ);int rc = zmq_connect(socket, "tcp://localhost:5555");if (rc == 0) {zmq_pollitem_t items[] = {{socket, 0, ZMQ_POLLIN, 0}};int rc = zmq_poll(items, 1, 1000);if (rc > 0) {if (items[0].revents & ZMQ_POLLIN) {printf("Received data\n");}} else if (rc == 0) {printf("Timeout\n");} else {printf("Poll failed, error code: %d\n", errno);}} else {printf("Connect failed, error code: %d\n", errno);}zmq_close(socket);zmq_ctx_term(context);return 0;
}

以上代码创建了一个ZeroMQ上下文和一个REQ类型的套接字，并使用zmq_connect函数连接到本地的5555端口。然后，创建zmq_pollitem_t结构体数组，监听该套接字上的可读事件。通过zmq_poll函数等待事件发生，传入的超时时间为1000毫秒。如果有可读事件发生，会输出"Received data"；如果超时，会输出"Timeout"；如果发生错误，会输出"Poll failed"和相应的错误码。最后需要关闭套接字和上下文对象。

需要注意的是，zmq_poll函数会修改zmq_pollitem_t结构体数组中每个元素的revents字段，以表示实际发生的事件类型。在调用zmq_poll函数后，可以通过判断revents字段来确定发生了哪些事件。此外，zmq_poll函数还可以用于同时监听多个套接字的事件，通过设置多个zmq_pollitem_t结构体实现。