我正在尝试让一个运行zmqv3.2.0本机c构建的设备与使用pub/subzmq套接字的jeromq（纯java impl）构建的java应用程序一起工作。然而，jeromq似乎在消息负载和c实现之前使用了不同的标志配置。iirc，jeromq打算与v3.2.2兼容，所以我不确定这是否是jeromq端口中的一个bug
我的java测试代码类似于psenvpub示例：public类psenvpub{

public static void main (String[] args) throws Exception {
    // Prepare our context and publisher
    Context context = ZMQ.context(1);
    Socket publisher = context.socket(ZMQ.PUB);

    publisher.bind("tcp://*:15052");
    byte seq = 1;
    while( !Thread.currentThread().isInterrupted() ){
        byte[] message = new byte[8];
        message[0] = 0;
        message[1] = 0;
        message[2] = 0;
        message[3] = 0;
        message[4] = seq++;
        message[5] = 0;
        message[6] = 0;
        message[7] = 0;
        publisher.send(message);
        try{
            Thread.sleep(1000);
        }
        catch(Exception e ){
            break;
        }
    }
}
}

我将perl脚本用于本机c端点：

use strict;
use warnings;

use Vocollect::ZMQ::Context;
use ZMQ::Constants qw(ZMQ_SUB);

my $ctx = Vocollect::ZMQ::Context->new();
my $sock = $ctx->socket(ZMQ_SUB);
$sock->connect('tcp://localhost:15052');
$sock->subscribe('');

while (1) {
    my $msg = $sock->recv(10000);
    print "Received msg\n" if defined($msg);
}

订阅者收到第一条消息时，由于libzmq源代码中的assert失败而崩溃：

Assertion failed: options.recv_identity (..\..\..\src\socket_base.cpp:990)

即：

void zmq::socket_base_t::extract_flags (msg_t *msg_)
{
    //  Test whether IDENTITY flag is valid for this socket type.
    if (unlikely (msg_->flags () & msg_t::identity))
        zmq_assert (options.recv_identity);

    //  Remove MORE flag.
    rcvmore = msg_->flags () & msg_t::more ? true : false;
}

wireshark对发送的数据包的跟踪显示，jeromq pub/sub和本机c pub/sub之间的握手顺序以及标志是不同的。我在使用jeromq和本机c libzmq的端点时没有发现任何问题。