如何实现zmsg_recv_nowait？

Question

CZMQ库提供nowait选项zstr和zframe类（zstr_recv_nowait()和zframe_recv_nowait()），但没有什么像zmsg_recv_nowait()。有没有解决方法？而不是使用zmq_msg_recv和ZMQ_DONTWAIT标志。我的代码是：

zmq_pollitem_t items[] = { {sock, 0, ZMQ_POLLIN, 0} }; 
zmq_poll(items, 1, 10); 
/* now receive all pending messages */ 
while (1) { 
    zmsg_t *msg = zmsg_recv(sock); /* this will block after the last message received */ 
    /* consume message here */ 
} 
/* sending bunch of messages */ 

我正在做异步REQ/REP。发送多个请求然后在准备好时收到回复。此代码将阻止我的应用程序。另外，我做一个zmq_poll似乎很难看，接收一个消息等等，因为在zmq_poll返回时，其他答复已经到达。

Answer 1

将轮询代码放入循环中。使用轮询一个套接字很好。

一个例子可能会有帮助：

while (1) { 
    /* now receive all pending messages */ 
    zmq_pollitem_t items[] = { {sock, 0, ZMQ_POLLIN, 0} }; 

    /* this will block for 10msec, ZMQ_POLL_MSEC is for compatibility for v2.2 */ 
    int rc = zmq_poll(items, 1, 10 * ZMQ_POLL_MSEC); 
    if (rc == -1) 
     break; // some error occured, check errno... 

    if (items [0].revents & ZMQ_POLLIN) { 
     /* there's something to receive */ 
     zmsg_t *msg = zmsg_recv(sock); 
    } 

    /* sending bunch of messages */ 
}