如何實現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 */ 
}