Akka-ZMQ订阅服务器创建错误（轮询）

Question

我成功创建了publisher，但使用以下方法创建订阅服务器失败：

    public static void main(String [] args)
    {
        ActorSystem system = ActorSystem.create("System");
        ActorRef subscriber = system.actorOf(new Props(Sub.class),   "subscriber");    
        subscriber.tell(new MyActor("CharlieParker", 50, 25), subscriber);
    }
    public class Sub extends UntypedActor 
    {
        ActorRef subSocket = ZeroMQExtension.get(getContext().system()).newSubSocket(
        new Connect("tcp://127.0.0.1:1237"),
        new Listener(getSelf()), Subscribe.all());
    }

得到以下错误：从线程[system-akka.zeromq.socket-dispatcher-7]关闭JVM的未捕获错误，因为在Akka.zeromq.concurrentSocketActor$$AnonFun$10处为ActorSystem[System]java.lang.NosuchMethoderror:org.zeromq.zmq$poller.poll(J)J启用了'akka.jvm-exit-on-fatal-error'。在Akka.zeromq.concurrentSocketActor$$AnonFun$10处应用在Akka.zeromq.concurrentsocketactor.scala:197)Akka.zeromq.concurrentsocketactor.scala:46)Akka.actor.actorcell.receiveMessage(actorcell.scala:425)Akka.actor.actorcell.invoke(actorcell.scala:386)Akka.dispatch.mailbox.processMailbox(mailbox.scala:230)Akka.dispatch.mailbox.run java.util.concurrent.ThreadPoolExecutor$worker.run（ThreadPoolExecutor.jav）A:615)在java.lang.thread.run处(thread.java:722)

什么意思？

Answer 1

我在尝试与akka-zeromq合作时也遇到了同样类型的错误，并对此进行了一些调查。因此情况如下：错误消息声明它没有在类zmq.poller中找到方法long poll（long timeout)（有关错误消息解释，请参见此答案）。出现这种情况是因为以下原因

1. Akka是用zeromq-scala绑定构建的。
2. ZeromQ-Scala应该与jzmq兼容，但不幸的是目前还不兼容，因为在scala绑定中有方法long poll（long timeout)
而在jzmq中有 int poll（long timeout)

要在本地解决这个问题，您要么使用zmq.jar重建Akka，要么使用快速而肮脏的解决方案：更改jzmq zmq.poller类中方法poll（long timeout)的返回类型，并重建java绑定。有关更多详细信息和绑定兼容性讨论，请参阅此处

然而，存在一个全局Java/Scala绑定兼容性问题，但这超出了问题的范围。