java - Java/Scala的ZeroMQ回调

我正在寻找Java / Scala的ZeroMQ的任何包装。我想向套接字添加回调，但是默认情况下zmq不提供此功能。仅阻止操作“recv”。另一种方法是创建循环和用户Poller，但也许存在其他解决方案？

最佳答案

为什么不创建一个简单的Actor，将其作为构造函数arg接收回调，然后坐在以下位置:

while( running ) {
  callback ( subscriber.recv( 0 ).asInstanceOf[Array[Byte]] )
}

如果速度不是必需的，您还可以查看AKKA ZeroMQ模块，它遵循传统的非阻塞消息传递。但是我发现香草JZMQ慢得多。