我在谷歌上搜索了一下,找到了对上述两种远程处理策略(即透明远程处理和位置透明)之间区别的一个很好的解释。据我所知,前者是JavaRMI的基础,后者是Akka的基础。我非常了解JavaRMI并且我理解透明远程处理的含义,但是Akka呢?非常感谢大家的回复。 最佳答案 两者其实是相反的。“透明远程处理”是关于使远程调用看起来像本地调用。“位置透明”是指让本地调用看起来像远程调用。虽然这听起来没什么大不了的,但确实如此。这完全取决于您可以做出的假设。通常本地调用具有更高的保真度,因为可能的错误和失败模式要少得多。通过在“位置透明度”中采用
关闭。这个问题需要更多focused.它目前不接受答案。想改进这个问题吗?更新问题,使其只关注一个问题editingthispost.关闭5年前。ImprovethisquestionAkkaactor和Jadeagent的概念有什么本质区别吗?据我所知,两者都通过创建独立的实体(具有系统逻辑block)来实现系统分发,这些实体可以通过在它们之间发送消息进行通信。是否有其他因素使它们不同(例如性能或预期用途)?
我正在研究akkaactors(JAVA),最近了解到有3种方法(可能更多)可以了解actor的存在。发送身份信息:ActorSelectionsel=actorSystem.actorSelection("akka://test/user/TestActor");AskableActorSelectionasker=newAskableActorSelection(sel);Futurefuture=asker.ask(newIdentify(1),newTimeout(5,TimeUnit.SECONDS));ActorIdentityidentity=(ActorIdentity
我正在使用来自Java的Akka。根据文档,context.become()需要Procedure作为参数。事实上,它期望PartialFunction这似乎是使用许多名称奇怪的方法自动生成的东西。在Java中使用become()的正确方法是什么?附言我正在使用Akka2.0.3更新:看起来有两种方法:context()和getContext()。第一个返回ActorContext,第二个返回UntypedActorContext。UntypedActorContext有become(Procedure). 最佳答案 您混淆了Akk
我正在尝试设置Akkaactor来处理游戏中的网络套接字。我已经定义了一个简单的actor来通过网络套接字发送消息:packageactors;importakka.actor.*;publicclassMyWebSocketActorextendsUntypedActor{publicstaticPropsprops(ActorRefout){returnProps.create(MyWebSocketActor.class,out);}privatefinalActorRefout;publicMyWebSocketActor(ActorRefout){this.out=out;}
我想在集群上部署一个用akka制作的远程actor软件。该系统由多个工作节点和一个主节点组成。问题是我无法提前知道集群节点的IP地址(但我知道它们都属于同一子网)。因此,我需要一种在启动后发现每个人的IP地址的好方法,以便在每个节点上创建正确的actor引用。我正在寻找在任何自由软件许可下分发的轻量级解决方案(我只需要它进行初始设置)。 最佳答案 前一段时间我创建了一个prototype旨在解决您的问题(请随意重用代码和/或做出贡献)。简单介绍一下它是如何工作的。它为每个参与者注册表(=节点)启动一个远程参与者。RegistryAc
有什么好方法可以让Actor在失败时再次尝试,但重试之间的时间间隔会越来越长?假设我希望Actor在15秒后再次尝试,然后是30秒,然后每分钟尝试有限的次数。这是我想出的:执行实际工作的参与者的方法有一个可选的RetryInfo参数,如果存在,则包含重试我们目前在失败时,actor将向自己发送一个新的ScheduleRetryMessage与retryCount+1,然后抛出RuntimeException另一个Actor监督workerActor,使用newOneForOneStrategy(-1,Duration.Inf()返回Resume作为其指令。actor没有状态,所以Res
我一直想使用Scala创建微服务。稍后我们可能还需要一些网页。关于微服务或RESTHTTP的反应性编程是什么?Lagom和Akka之间的关系(如果有)是什么关系?它们都用于制作微服务吗?播放是反应性的吗?微服务可以提供动态网页吗?还是我需要单独的应用程序?我已经与ReactJ进行了一些工作。图片中的任何地方都适合吗?请帮忙看答案这个问题太广泛了,无法在这里回答。但是Akka的创建者JonasBonér探索了他的免费电子书中的微服务与反应性系统之间的关系”反应性微服务体系结构”,为什么不读一开始。Akka是一个库/takit,它更低级,并且不会像框架一样指导您使用某些模式。PlayandLago
我正在努力建立未来的建筑商类,以简化链接期货。在此过程中,我试图了解使用等待的后果。因此,如果我的映射器会像这样的f1(future1)->f2->F3F1:构建对象fooF2:去DB向FOO添加价值栏F3:将包含FOO的消息发送到其他地方我遇到的问题是F2,通常我会创建一个未来以从DB中获得酒吧。在这种情况下,我已经将来了,所以只有一个Await.result()在子未来,这样我就可以立即将其添加到foo中并将其传递到F3。有问题吗?既然我是alreareyd,那么我会通过等待锁定一个额外的线程吗?还是我应该做不同的模式?请记住,我希望能够继续前进,因此将foo对象传递到映射器中
(改写问题和描述以便与S.O.兼容)奇怪的是,C++还没有被广泛采用、经过同行评审的actor模型库(按BOOST和STD的顺序)。我看到Theron,但它看起来像一个人和他的代码:无论它有多好,它都不是我希望生产代码依赖的东西。因此,如何在不使用未经证实的库的情况下使用C++进行Actor模型编程?我应该使用哪些BOOST类(class)?注意:我是在面对之前关于S.O.的一两个问题时问这个问题的。当人们搜索“actorC++”时就会出现,因为它们几乎没有吸引力。对于SEESHARP,有thisthread但对于C++,即使是获得中等关注度的问题也是如此thisguy,aquesti