ZeroMQ接口函数之 :zmq_msg_more - 指出是不是还有更多的消息部分可以接收

简介:

zmq_msg_more - 指出是不是还有更多的消息部分可以接收

Synopsis

int zmq_msg_more (zmq_msg_t *message);

Description

zmq_msg_more()函数指出在多个消息部分中是否还有更多的消息可以接收,或者当前的消息是不是属于还未接收完的多部分消息中的一个。

Return value

如果这是多个消息中最后一条消息,或者单消息中的唯一一条消息,zmq_msg_more()函数会返回0。如果有更多的消息等待接收,函数会返回 1

Example

  接收一个多部分消息

复制代码
 1 zmq_msg_t part;
 2 while (true) 
 3 {
 4     //  Create an empty ØMQ message to hold the message par
 5     int rc = zmq_msg_init (&part);
 6     assert (rc == 0); 
 7     //  Block until a message is available to be received from socket
 8     rc = zmq_recvmsg (socket, &part, 0); 
 9     assert (rc != -1);
10     if (zmq_msg_more (&part))
11     {   
12         fprintf (stderr, "more\n");
13     }   
14     else
15     {   
16         fprintf (stderr, "end\n");
17         break;
18     }   
19     zmq_msg_close (part); 
20 }
复制代码




本文转自郝峰波博客园博客,原文链接:http://www.cnblogs.com/fengbohello/p/4245304.html,如需转载请自行联系原作者

相关文章
|
11月前
|
消息中间件 C语言
zframe_send发送的内容,可以使用zmq_recv接收吗
如果你在同一套接字上混合使用CZMQ的zframe_send和ZMQ的zmq_recv,可能会遇到问题,因为这两个函数可能对ZMQ的内部状态有不同的预期。
72 0
|
5月前
|
消息中间件 Unix Linux
【ZMQ polling机制】ZMQ异步接收机制以及与epoll/select的对比分析
【ZMQ polling机制】ZMQ异步接收机制以及与epoll/select的对比分析
337 0
|
消息中间件 负载均衡 网络协议
ZMQ/ZeroMQ的三种消息模式
ZMQ/ZeroMQ的三种消息模式
ZMQ/ZeroMQ的三种消息模式