Tag: jzmq

java.library.path中没有jzmq

我在一个交易引擎上工作，在运行时，我从engine.log获取日志，如下所示， 2018_01_02_03_28_20_684 INFO ZMQCommunicatorService REMOTE_EXECUTOR_MARKET_ADMIN-ALL_MARKETS-0-5 – no jzmq in java.library.path, sleeping 2 minutes then try again 2018_01_02_03_28_20_697 INFO ZMQCommunicatorService ENGINE_MARKET_ADMIN-ALL_MARKETS-0-4 – Could not initialize class org.zeromq.ZMQ, sleeping 2 minutes then try again 2018_01_02_03_30_20_696 INFO ZMQCommunicatorService REMOTE_EXECUTOR_MARKET_ADMIN-ALL_MARKETS-0-5 – Could not initialize class org.zeromq.ZMQ, sleeping 2 minutes then try again 2018_01_02_03_30_20_710 INFO ZMQCommunicatorService ENGINE_MARKET_ADMIN-ALL_MARKETS-0-4 – Could not […]

在ZeroMQ中使用Java中的SUB没有消息匹配

我正在尝试使用ZeroMQ的Java客户端。 订阅任何前缀时，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”; […]