问题标签 [akka-zeromq]

我在扩展使用 actor 模型和 zeromq 的应用程序时遇到问题。简单地说：我正在尝试创建数千个通过套接字进行通信的线程。类似于使用 Erlang 类型的消息传递所做的事情。我这样做不是出于多核/性能原因，而是因为以这种方式构建它给了我非常干净的代码。

从哲学的角度来看，这听起来好像是 zmq 开发人员想要实现的，例如 http://zeromq.org/whitepapers:multithreading-magic

但是，似乎存在一些实际限制。在 1024 inproc 套接字处，我开始收到“ZMQError：打开的文件过多”错误。TCP 给了我典型的“断言失败：fds.size () <= FD_SETSIZE”崩溃。

为什么 inproc 套接字有这个限制？为了让它工作，我不得不将项目组合在一起以共享一个套接字。有没有更好的办法？

zmq 只是这种工作的错误工具吗？即它仍然是一个网络库而不是一个演员消息传递库？

我想知道 Apache Zeppelin 使用哪个协议连接到 Apache Spark？

它也是 ZeroMQ 上的 iPython 协议吗？

非常感谢！

此致

罗密欧

我有一个需要将结构化数据发送到 Akka 演员的 C++ 应用程序。我找到的最佳选择（Google、stackoverflow...）是使用协议缓冲区和 ZeroMQ，因为看起来每个人都推荐它。然而，我一整天都在努力让它工作，我的 Scala 演员代码发生了各种崩溃（带有奇怪的 Windows 套接字错误）。当我深入研究它时，我注意到 zeromq 似乎不久前从 Akka 官方文档中消失了，我读到的最新文档说 ZeroMQ 3 仍然不支持下面的 zeromq-scala-bindings （虽然第 4 版已经发布）。

使用 Camel-netty 扩展并通过 JSON 传递信息会是更好的选择吗？

谢谢 ！

我有以下控制流程。在 for 循环中，我创建了一个字符串数组。我将数组的每一行（一个字符串）发送到发布者函数。然后发布者函数应该发送字符串。我有一个问题，如果发布者在无限循环中发布，我的订阅者只接收消息。为什么我不能连续调用发布者函数并让它发送数据？为什么它只能在无限循环中工作？

这是我的发布者功能：

这是我的订阅者功能：

为什么当我删除 while(1) 语句时，我什么也没有收到？

我正在使用 Scala 2.12.6、Akka 和 zeroMQ 构建应用程序 我正在尝试像这样为 zeroMQ 添加依赖项，但在下载 zeroMQ 的依赖项时遇到问题。我正在尝试像这样添加 ZeroMQ 依赖项：

下面的部分解释了我正在使用的 sbt 解析器： resolvers += Resolver.url("bintray-sbt-plugins", url(" https://dl.bintray.com/sbt/sbt-plugin-releases/ "))(Resolver .ivyStylePatterns), resolvers += Resolver.bintrayRepo("pqw", "maven"), version := "0.0.1", fork := true, parallelExecution in Test := false, autoCompilerPlugins := true, if (formatOnCompile) scalafmtOnCompile := true 否则 scalafmtOnCompile := false

我认为我做的一切都是正确的，但在尝试使用命令 sbt stage publishLocal 运行项目时仍然面临以下问题

如果您可以为此提供任何帮助，请告诉我。

我正在尝试订阅 zeromq 消息，然后将消息转换为 akka 流。谁能指出我这样做的正确方法？