java - 如何处理 JZMQ 的错误？

Question

文档Socket#recv()内容如下：

返回： [...] 错误时为空。

我怎么知道错误是什么？我想EAGAIN具体处理。

Answer 1

我在这里的知识非常有限，但从外观上看，答案可能是：
“如果Socket#recv()返回 null 并且ZMQException抛出 no，则发生 EAGAIN 错误。”

我遵循了方法调用并到达了do_read第83 行Socket.cpp 有趣的地方：

rc = zmq_recv (socket, message, flags);
int err = zmq_errno();
if (rc < 0 && err == EAGAIN) {
    rc = zmq_msg_close (message);
    err = zmq_errno();
    if (rc != 0) {
        raise_exception (env, err);
        return NULL;
    }
    return NULL;
}
if (rc < 0) {
    raise_exception (env, err);
    rc = zmq_msg_close (message);
    err = zmq_errno();
    if (rc != 0) {
        raise_exception (env, err);
        return NULL;
    }
    return NULL;
}
return message;

我在这里读到的是，如果出现问题，您会ZMQException在 Java 中得到一个，除非该错误曾经出错EAGAIN并且zmq_msg_close不会出错（我不确定是什么出错zmq_msg_close，但我认为它很少出错）。
但是我没有测试这个的环境，我也不太明白它是如何raise_exception工作的（在util.cpp中的源代码）：如果在同一代码路径中引发/抛出两个异常会发生什么情况（例如，当err不是 EAGAIN和rc < 0) 并且您只能在 Java 中捕获一个运行时异常？

附带说明一下，在2015 年 5 月 15 日的此提交中添加了对 EAGAIN 错误代码的支持 。

Answer 2

源代码是：

    /**
         * Receive a message.
         *
         * @return the message received, as an array of bytes; null on error.
         */ 
        public final byte[] recv()
        {
            return recv(0);
        }

        /**
         * Receive a message.
         *
         * @param flags
         *            the flags to apply to the receive operation.
         * @return the message received, as an array of bytes; null on error.
         */
        public final byte[] recv(int flags)
        {
            zmq.Msg msg = base.recv(flags);

            if (msg != null) {
                return msg.data();
            }

            mayRaise();
            return null;
        }

        private void mayRaise()
        {
            int errno = base.errno();
            if (errno != 0 && errno != zmq.ZError.EAGAIN) {
                throw new ZMQException(errno);
            }
        } 

所以你可以改变 recv(int flags) 和 mayRaise() 函数