- iOS/Objective-C 元类和类别
- objective-c - -1001 错误,当 NSURLSession 通过 httpproxy 和/etc/hosts
- java - 使用网络类获取 url 地址
- ios - 推送通知中不播放声音
我刚刚了解了 CAF,C++ Actor Framework .
让我感到惊讶的一件事是,通过网络使 Actor 可用的方法是"publish"。它到一个特定的 TCP 端口。
这基本上意味着您可以发布的参与者数量受限于您拥有的端口数量 (64k)。由于您既需要一个端口来发布 Actor ,又需要一个端口来访问远程 Actor ,我假设两个进程每个最多能够共享大约 32k 个 Actor ,而它们可能每个都在商品服务器上拥有一百万个 Actor .如果集群有 10 个节点,情况会更糟。
为了使发布具有可扩展性,每个进程只需要为一个系统中的每个参与者打开1 端口,并打开与每个参与者系统的1 连接他们想要访问。
有没有办法将一个 Actor 发布为 Actor 系统中所有 Actor 的代理(最好没有任何显着的性能损失)?
最佳答案
让我补充一些背景。 middleman::publish
/middleman::remote_actor
函数对做两件事:连接两个 CAF 实例并为您提供与远程参与者通信的句柄。您“发布”到给定端口的 actor 旨在充当入口点。这是一个方便的集合点,仅此而已。
两个 actor 之间的通信只需要一个句柄。当然,如果你想和更多的 Actor 交谈,你需要以某种方式学习新的把戏。 remote_actor
函数只是一种在两个参与者之间实现会合的便捷方式。但是,在您了解句柄后,您可以在分布式系统中自由传递它。 Actor 句柄是网络透明的。
此外,CAF 将始终在两个参与者系统之间保持单个 TCP 连接。如果您在主机 A 上发布 10 个参与者并通过 remote_actor
“连接”到主机 B 的所有 10 个参与者,您将看到 CAF 最初将打开 10 个连接(因为目标节点可以运行多个参与者系统) 但除一个连接外的所有连接都将关闭。
如果您不关心 publish
/remote_actor
提供的 actor 的集合点,那么您也可以使用 middleman::open
和middleman::connect
代替。这将只连接两个 CAF 实例而不交换角色句柄。相反,connect
将在成功时返回一个 node_id
。这就是某些功能所需的全部。例如remote spawning of actors .
Is there a way to publish one actor as a proxy for all actors in an actor system ( preferably without any significant performance loss )?
您可以在端口发布一个 actor,其唯一目的是为会合点建模。如果该 actor 向远程 actor 发送 1000 个以上的 actor 句柄,这将不会导致任何额外的网络连接。
推荐的方法是编写一个自定义 actor,通过提供某种排序字典来显式建模多个系统之间的会合点。
只是为了完整起见:CAF 也有一个注册机制。但是,键限于 atom
值,即 10 个字符或更少。由于注册表是通用的,它也只存储 strong_actor_ptr
并将类型安全留给您。但是,如果这就是您所需要的:您将句柄放入注册表(请参阅 actor_system::registry
),然后通过 middleman::remote_lookup
远程访问此注册表(您只需要node_id
来执行此操作)。
关于c++ - 如何 "publish"CAF中的大量 Actor ?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/46329780/
我有一个数据框: title | cast ------------------------------ movie1 | cast1,cast2,cast3 movie2
据我所知,Actor 模型是一种关于并发的理论。 Erlang 和 Scala 都实现了这个理论模型,但它们的实现都不完全符合 Actor 模型。 从计算机科学家的角度来看,Erlang、Scala
我是 akka 流的新手。我将 kafka 用作源(使用 ReactiveKafka 库)并通过流对数据进行一些处理并使用订阅者 (EsHandler) 作为接收器。 现在我需要处理错误并通过错误处理
考虑以下代码示例(版本 1)。此处父 actor (ActorA) 向子 actor (ActorB) 发送消息,然后停止自身。由于父 actor 的自停止,在高负载下,子 actor 甚至在从邮箱中
我有以下 Scala 代码: package dummy import javax.servlet.http.{HttpServlet, HttpServletRequest => H
如何描述“数据流编程”和“ Actor 模型”之间的区别?据我了解,它们并非无关,但又不相同。 DF 是否是一个更广泛的概念,其要点是与控制流模型的区别,而 Actor 模型是更详细的和理论上有根基的
GPars 中的 Actor 有自己的消息队列(邮箱)。假设一个参与者有 15 条待处理的消息,然后系统突然宕机(比如由于电源故障)。这 15 条消息会发生什么。当系统再次启动并运行时,消息队列会自动
我刚刚开始使用 AKKA,并且有一个关于非参与者代码如何与参与者代码对话的基本问题。 非参与者代码如何调用参与者并获得响应?我试过使用 Patterns.ask 从非 Actor 调用 Actor ,
这个问题在这里已经有了答案: 关闭 9 年前。 Possible Duplicate: Casting vs using the ‘as’ keyword in the CLR 我最近了解到一种不同
我在设置边界矩形位置时遇到麻烦,这就是我问这个的原因。当我设置 Actor 类型的对象的边界矩形位置时,看来我传递给 [setBounds(x,y,with,height)] 2 的坐标相对于 Act
我是 Actor 模型的新手。任何人都可以解释 Actor 模型中 Actor 的生命周期吗?我一直在文档中寻找答案,但找不到任何令人满意的内容。 我对 Actor 完成后做什么很感兴趣onRecei
例如,我有两个 Actor ——一个父 Actor 和一个子 Actor 。当 parent 收到一条消息时,它会产生与消息中指定的一样多的子actor。如何测试此功能?有没有办法模拟上下文或其他方法
我目前在 Futures 编程,我对 Actor 很好奇。我想听听有经验的声音: Actor 相对于 future 有什么优势? 我什么时候应该使用一种而不是另一种? 据我所知, Actor 持有状态
Actor 模型框架(例如 Orleans )和复杂事件处理 (CEP)(例如 Apache Storm )之间有什么区别? 其中每种方法都适用(或者一种方法比另一种方法更适用)的使用示例肯定会有所帮
你们中的任何人都可以帮助我理解传入的基本消息吗scala 使用 Actor 模型? 我正在尝试编写一个包含 3 个 Actor 的简单程序。 Actor “BossActor”创建了 2 个 Acto
Akka 1.1.3 文档指出“become 方法对于许多不同的事情都很有用,但它的一个特别好的例子是它用于实现有限状态机 (FSM) 的示例”。在运行时热交换 Akka actor 的实现还有哪些其
我正在尝试使用参与者实现消息处理管道。管道的步骤包括读取、过滤、扩充以及最后存储到数据库中等功能。类似于此:http://sujitpal.blogspot.nl/2013/12/akka-conte
可以使用 actor.send() 或 actor.offer() 向 Actor 发送消息一旦我的 Actor 从其 channel 收到消息,我想返回响应。我该怎么做呢?我没有看到任何明显的内置方
你们中的任何人都可以帮助我理解传入的基本消息吗scala 使用 Actor 模型? 我正在尝试编写一个包含 3 个 Actor 的简单程序。 Actor “BossActor”创建了 2 个 Acto
我目前正在尝试保存特殊 Actors所以如果加载旧 map ,我可以再次将它们放在 map 上。因此我想将它们放入 HashMap> monsterAtMap 中并从那里删除它们Stages .所以我
我是一名优秀的程序员,十分优秀!