问题

我正在尝试实现一个简单的参与者，它将使用 akka-zeromq 从 zeromq 接收消息。

系统只打印

附加信息

发送消息是通过一个简单的 python 完成的

我注意到的另一件奇怪的事情是，在按下 enter 后，程序不会终止。如果我使用 python 脚本向它发送消息，它会。这是完整的输出：

使用

libzmq是版本3.2.2（在 Arch Linux 上）

这是application.conf

我使用的是 Mac，我使用自制软件安装 zeromq。我想在我的应用程序中使用 zeromq。我试图编译 zmq.hpp https://github.com/zeromq/cppzmq/blob/master/zmq.hpp

但它失败了。错误显示

“框架/zmq/zmq.hpp:377:35: 错误: 预期 ';' 在声明列表的末尾 socket_t (const socket_t&) ZMQ_DELETED_FUNCTION; ^ ; frameworks/zmq/zmq.hpp:379:42: error: expected ';' 在声明列表的末尾 void operator = (const socket_t&) ZMQ_DELETED_FUNCTION;"

为什么会这样？zmq.hpp 代码不包含任何错误。请帮忙。

最后我这样做了，它奏效了。

非常感谢。奥黛丽。

创建发布者和订阅者的顺序是否重要？如果我有作为发布者的应用程序 A 和几个客户端应用程序 X1 - Xn（作为应用程序 A 的订阅者），我可以先启动子应用程序，将它们注册为订阅者，然后再启动应用程序 A 吗？这会成功还是我需要启动应用程序 A？

我成功创建了发布者，但未能使用以下内容创建订阅者：

收到此错误：线程 [System-akka.zeromq.socket-dispatcher-7] 未捕获的错误正在关闭 JVM，因为 ActorSystem [System] java.lang.NoSuchMethodError 启用了“akka.jvm-exit-on-fatal-error” : org.zeromq.ZMQ$Poller.poll(J)J at akka.zeromq.ConcurrentSocketActor$$anonfun$10.apply(ConcurrentSocketActor.scala:180) at akka.zeromq.ConcurrentSocketActor$$anonfun$10.apply(ConcurrentSocketActor.scala: 179) 在akka.zeromq.ConcurrentSocketActor$$anonfun$receive$1.applyOrElse(ConcurrentSocketActor.scala:46) 在akka.actor.akka.zeromq.ConcurrentSocketActor.akka$zeromq$ConcurrentSocketActor$$doPoll(ConcurrentSocketActor.scala:197)。 ActorCell.receiveMessage(ActorCell.scala:425) at akka.actor.ActorCell.invoke(ActorCell.scala:386) at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:230) at akka.dispatch.Mailbox。在 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) 在 java.lang.Thread 的 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) 运行(Mailbox.scala:212) .run(Thread.java:722)

这是什么意思？

为什么它在 Heroku 上不存在？

我想使用 Akka 和分布式队列系统让演员在不同的测功机上进行通信。RabbitMQ 似乎不是使用 Akka 的最佳选择，因为需要很多技巧才能与 Actor 无缝协作，而无需考虑底层队列。

尽管如此，最好的选择似乎是持久邮箱，但使用 RabbitMQ：akka-amqp-mailbox。不过，我仍然必须先设置它。

您认为还有哪些其他选项可以在 Heroku 和 Akka 上提供无缝的底层队列系统？

谢谢！

我是 Akka 的新手，想构建一个允许多种分布式模式的小型框架，例如 MapReduce、Publish-Subscribe 等。我已经看到使用 ZeroMQ 作为 Akka 的网络提供者是可能的，我实际上更喜欢它。

但是，当我看到一些MapReduce 示例时，它们都依赖于 netty.io 网络框架。为了有一个单一的网络提供者 ZeroMQ ......有没有一种简单的方法可以在 MapReduce 示例配置中用 ZeroMQ 替换 netty io 网络，例如这个application.conf？

我正在尝试在 scala 中使用 zeromq 扩展，但编译失败并使用 sbt。

这是我得到的错误；

build.sbt 文件看起来像；

我尝试按照 zeromq 官方页面上的 osx 安装说明进行操作。 http://zeromq.org/bindings:scala-binding

我正在为服务器和客户端尝试 Zeromq Hello world 示例。下面是示例代码

和服务器代码

代码运行良好，我能够发送请求并获得回复。

但是我希望服务器不应该等待来自客户端的请求。服务器继续运行，如果来自客户端的请求来，它会给出回复。

我可以在程序中进行哪些更改来实现这一点。

在这里，我使用 SmallestMailboxRouter 创建了一个路由器

现在在 for 循环中我创建了 38 个演员

每个参与者将处理逻辑并返回分数和消息。我通过覆盖 onreceive 方法并将它们添加到列表中来接收消息

如果我多次运行该程序，我会得到不同的分数。但它应该总是返回与我给出相同输入相同的分数。

}

这里 standardActorResponse 包含 message 和 score 。如果我只使用 for 循环而不是 akka 框架来使用相同的逻辑，我将收到一致的结果。但是在akka中随机得到不同的结果。例如，我有一些规则，例如 loginexistence 和 navigationexistence 和 alertsexistence 规则。我已经为这些规则提供了一个 html 源，以检查 html 源是否在该源中具有登录、警报、导航链接。有时我正在登录不存在，有时导航不存在，有时警报不存在通过使用 akka 路由器和演员。但是如果我使用 for 循环，我总是得到相同的结果

谁能帮我找到问题。我正在使用 akka 2.1.4

我们正在创建一个 WPF 应用程序，在该应用程序中，我们从不同的测试站执行 python 脚本并在其相应的输出面板中显示输出，要并行运行脚本，我们使用 Task，但是当我们从测试站并行运行脚本时，我们正在将其他站点的输出也获取到首先启动的站点中，我们使用以下代码，

出于测试目的，我们根据我们保存在 python 脚本中的测试消息打破了这段代码中的 while 循环，然后我们能够正确地在相应的站中获得输出，但是这样我们只能以同步方式运行这是我们不希望的，因为我们需要并行运行测试站，并且 while 循环不应中断，因为它应该正在侦听响应。