java - Java/Scala 的 ZeroMQ 回调

Question

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

Answer 1

为什么不创建一个简单的 Actor，它将回调作为构造函数 arg，然后就坐在:

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

如果对速度没有要求，也可以看看AKKA ZeroMQ模块，它遵循传统的非阻塞消息传递。但是我发现它比普通的 JZMQ 慢很多。