我是Akka的新手,查阅了Akka文档。我理解参与者通过消息相互作用,这些消息应该是不可变的对象。我还了解到,如果参与者进行远程交互,那么消息就会通过网络传递。
我的问题是当地行动者之间如何传递信息。如果我在一台机器上部署了一个Actor系统。这些共享同一JVM的参与者如何相互交互?是记忆互动吗?
谢谢你的回复。
是的,是通过记忆。具体来说,每个参与者都有一个队列,当您向该参与者发送消息时,您的消息将附加到队列中。
邮箱上的文档应该有助于清除此问题。
我有一个akka集群项目: https://github.com/roclas/akka-distributed-hash 它基本上是跨集群节点的分布式HashMap。 我希望能够读取(使用tcpdump或wireshark或类似工具)不同虚拟机中参与者之间交换的消息。 我怎么能这么做? 执行TCP转储时,我只看到“集群消息”,但看不到不同虚拟机中不同参与者交换的消息。 如果我在端口2551上启动
我对Akka演员和演员模型有点困惑。从参与者A发送到参与者B的消息是否保持顺序?如何在本地/网络环境中实现这一点?据我所知,网络引入了可变延迟,如果M1的延迟为1秒,M2为0.5秒,那么消息M1和消息M2如何保持顺序?
我很难弄清楚我如何知道我的演员何时从非演员代码中完成。 尝试使用akka演员进行并行执行,这似乎真的很好,但我需要知道何时所有人都完成了。 我添加了一个监督者演员,产生演员来做工作,从监督者/父演员,我可以观看孩子的终止消息。 我需要从akka actor系统之外的常规java代码中得到帮助,以确定我的监督actor是否完成。 这是否可能,请提供指针。 谢谢哈瑞
本文向大家介绍在多个页面之间需要传递参数,你是如何传递这些参数的?相关面试题,主要包含被问及在多个页面之间需要传递参数,你是如何传递这些参数的?时的应答技巧和注意事项,需要的朋友参考一下 form表单,url查询参数,request参数,session,cookie 参考文章
考虑下面的代码示例(版本1)。在这里,父角色(ActorA)向子角色(ActorB)发送消息,然后停止自我。由于父角色的自停止,在高负载下,子角色甚至在从邮箱提取邮件之前就会死亡,因此邮件变成了“死信”(参见下面的示例输出1)。 由于某些原因,我无法修改应用程序设计以删除父参与者的自停止。 版本1 样本输出1 现在考虑下面的代码修改(版本2)。通过将消息确认从子参与者引入到父参与者,然后在收到此确
问题内容: 我想在程序执行其他操作时监听服务器,但是从服务器收到消息后,我想对其进行解释。 我知道线程,但是不能完全确定它是如何工作的。如果我有一个线程正在监听服务器,如何将数据传递到主线程进行解释?主线程将数据发送到服务器的最佳方法是什么?同步修饰符的用途是什么? 问题答案: 如果我有一个线程正在监听服务器,如何将数据传递到主线程进行解释?主线程将数据发送到服务器的最佳方法是什么? 我会为此使用