如何正确使用zmq_msg_more？

Question

Code Connected Volume 1 - 第47页有一个关于如何接收多部分消息的示例:

while (1) {
    zmq_msg_t message;
    zmq_msg_init(&message);
    zmq_msg_recv(&message, socket, 0);
    // Process the message frame
    ...
    zmq_msg_close(&message);
    if (!zmq_msg_more(&message))
        break;
}

它是否正确？我们不应该使用zmq_msg_close()后zmq_msg_more()？

Answer 1

zmq_msg_more()和zmq_msg_recv()(ZeroMQ 3.2.2 Stable)的API参考都包含显示zmq_msg_close()在 zmq_msg_more 之后调用的示例.据我所知,API文档没有明确说明任何与此相矛盾的内容,因此Code Connected的示例似乎是错误的.zmq_msg_close()状态的文档说明实际的内存释放可能会被底层层推迟,这意味着zmq_msg_more()操作可能会成功,但在关闭消息后调用它仍然看起来不对.

zmq_msg_more()API文档(3.2.2)中的示例(为了便于阅读,略微编辑):

zmq_msg_t part;
while (true) 
{
    //  Create an empty ØMQ message to hold the message part
    int rc = zmq_msg_init (&part);
    assert (rc == 0);

    //  Block until a message is available to be received from socket
    rc = zmq_recvmsg (socket, &part, 0);
    assert (rc != -1);

    if (zmq_msg_more (&part))
        fprintf (stderr, "more\n");
    else 
    {
        fprintf (stderr, "end\n");
        break;
    }
    zmq_msg_close (part); 
}

但是,查看关于多部分消息的ZeroMq指南,该示例在关闭消息后实际检查了更多消息,但这是通过使用zmq_getsockopt()检查套接字来实现的,而不使用对消息的任何引用.我怀疑代码连接的例子只是使用了那个例子并且从更改zmq_getsockopt()为zmq_msg_more()(可能非常如此).

ZeroMq指南示例(多部分消息):

while (1) 
{
    zmq_msg_t message;
    zmq_msg_init (&message);
    zmq_msg_recv (&message, socket, 0);
    //  Process the message frame
    zmq_msg_close (&message);
    int more;
    size_t more_size = sizeof (more);
    zmq_getsockopt (socket, ZMQ_RCVMORE, &more, &more_size);
    if (!more)
        break;      //  Last message frame
}