java - 在 Java 中使用 SUB 与 ZeroMQ 没有消息匹配

Question

我正在尝试将 Java 客户端与 ZeroMQ 一起使用。订阅任何前缀时，Java 客户端不会匹配任何消息，尽管类似的 Python 客户端会按预期匹配消息。

Python 服务器

context = zmq.Context()
socket = context.socket(zmq.PUB)
socket.bind("tcp://*:5556")

for i in range(100):
    r = "XXX " + i
    socket.send_string(r)

    time.sleep(random.randint(0,10))

Python 客户端工作正常

context = zmq.Context()
socket = context.socket(zmq.SUB)
socket.connect("tcp://localhost:5556")

zip_filter = "XXX"
socket.setsockopt_string(zmq.SUBSCRIBE, zip_filter)

for update_nbr in range(5):
    s = socket.recv_string()
    print(s)

Java 客户端未匹配任何消息

context = ZMQ.context(1);
subscriber = context.socket(ZMQ.SUB);
subscriber.connect("tcp://localhost:5556");

String filter = "XXX";
subscriber.subscribe(filter.getBytes(Charset.forName("UTF-8")));
while (true) {
  String msg = subscriber.recvStr(0, Charset.forName("UTF-8"));
  // ...
}

使用上述Python服务器，Python客户端按预期匹配所有以XXX开头的消息。

使用相同的 Python 服务器，Java 客户端不匹配任何消息。

您知道 Java 客户端中调用 subscribe() 有什么问题吗？

Answer 1

好吧，我重新创建了你的配置，遗憾的是，一切都工作正常 - 无论是在 python 还是 java 中。 (这是证据) )

Java代码:

public class Client {

    public static void main(String[] args) {
        final Context context = context(1);
        final Socket subscriber = context.socket(SUB);
        subscriber.connect("tcp://localhost:5556");

        String filter = "XXX";
        subscriber.subscribe(filter.getBytes(Charset.forName("UTF-8")));
        while (true) {
            String msg = subscriber.recvStr();
            System.out.println(msg);
        }
    }
}

Maven 依赖:

<dependency>
    <groupId>org.zeromq</groupId>
    <artifactId>jeromq</artifactId>
    <version>0.3.4</version>
</dependency>

zeromq版本:4.1.0

您使用什么版本的 jeromq？我什至没有方法 recvStr(int, Java.nio.charset.Charset)。