Tag: zeromq

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”; […]

如何在JeroMQ中实现活动和备用队列作业处理系统？

使用ZeroMQ .Socket和.Socket实例，我能够推/拉消息 例如，我的代码下面的队列设置如下： ZMQ.Context context = ZMQ.context(1); // Socket to send messages on ZMQ.Socket sender = context.socket(ZMQ.PUSH); sender.bind(“tcp://*:5557”); // Send messages sender.send(“0”, 0); ZMQ.Socket receiver = context.socket(ZMQ.PULL); receiver.connect(“tcp://localhost:5557”); // receive messages String string = new String(receiver.recv(0)).trim(); 我的问题是 ： Q1：如何在队列中实现主用/备用模式？ 我的意思是将为一个主机和端口创建2个队列，如果一个队列（活动）发生故障，另一个（即备用）队列将立即启动以侦听/拉取消息。 任何实现它的示例或指导都会更有帮助。 Q2：是否有任何内置类可以执行此类任务？

了解zeromq java绑定

我正在调查zeromq作为java项目中的消息传递解决方案，但我发现有关java绑定的说明有点难以理解。 http://www.zeromq.org/bindings:java 我不熟悉java绑定，所以这些可能是愚蠢的问题，但有人可以帮助我理解： 为什么我需要安装任何东西？ 我在一台机器上构建的jar子可以在另一个系统上运行吗？ 我需要这个应用程序是可移植的。 如果是这样，为什么我要开始建立自己的jar子？ 我觉得zeromq上提供的说明需要熟悉构建我缺乏的C项目，所以也许我只是在密集，但这似乎很多工作。