18得票3回答
jeromq是否已经准备就绪用于生产环境?

我以前使用过jzmq库通过JVM应用程序使用ZeroMQ。 我计划在一个新项目中使用Zeromq,其中一些服务是在JVM上实现的。 我刚刚发现了jeromq,它是Zeromq的纯Java实现,我想主要使用它,因为它正在跟踪Zeromq 3.x并且它消除了处理jzmq的麻烦。但是,我无法从rep...

10得票1回答
java.lang.ArrayIndexOutOfBoundsException: 256,使用jeromq 0.3.6版本时出现了此错误。

我正在多线程环境中使用Jeromq,如下所示。以下是我的代码,SocketManager的构造函数首先连接到所有可用套接字,然后将它们放入connectToZMQSockets方法中的liveSocketsByDatacenter映射中。之后,在同一构造函数中启动一个后台线程,每30秒运行一次...

9得票1回答
如何在JeroMQ中实现一个主备队列的作业处理系统?

使用ZeroMQ的.Context和.Socket实例,我能够推送/拉取消息。例如下面是一个类似于队列的设置的代码: ZMQ.Context context = ZMQ.context(1); // Socket to send messages on ZMQ.Socket sen...

9得票3回答
JeroMQ 正确关闭

我想知道如何正确关闭JeroMQ,目前我知道三种方法,它们各有优缺点,但我不知道哪一种是最好的。 情况如下: 线程A: 拥有上下文,应提供启动/停止方法 线程B: 实际监听线程 我的当前方法: 线程A static ZContext CONTEXT = new ZContex...

8得票2回答
jeromq: 关闭上下文失败

编辑:我已经自己解决了,见下文(尽管我不确定自己是否遇到了一个bug) 使用下面的简单的hello-world请求-回复示例,在程序结束时关闭上下文会失败:要么它只是在ctx.close()处挂起,要么它会抛出以下异常: Exception in thread "reaper-1" jav...