要在Akka(Java绑定(bind))中实现您自己的自定义actor，您可以扩展UntypedActor基类。这需要您定义自己的onReceive(...)方法:@OverridepublicvoidonReceive(Objectmessage){//TODO}手头的问题是确定一种消息处理策略，使参与者能够处理多种类型的消息。一种策略是使用反射/类型。这里的问题是:它迫使我们创建空的“外壳类”，这些类只是为消息提供语义意义(见下文)；和它占用了message参数并阻止我们传递任何动态或有意义的内容空壳类的例子:publicclassEmptyShellMessage{}然后在onR
intellij在子类指定更具体的返回类型时存在问题。Akka的Http.get(ActorSystem)方法就是这种情况。这个问题已报告给JB，但他们尚未回复。SCL-12302 最佳答案 我找到了解决问题的简单方法。只需从JetBrains安装Scala插件:文件->设置...->插件->安装JetBrains插件...->搜索Scala。重启IDE后故障消失。 关于java-AkkaHttp.get(ActorSystem)导致intellij中的方法调用不明确，我们在StackO
关于AKKA和Spring的集成方式有一个链接。或者更好地说:“如何在spring环境中使用Akkaactor”。http://doc.akka.io/docs/akka-modules/1.3.1/modules/spring.html实际上有modules文件夹http://doc.akka.io/docs/akka-modules/仅适用于1.3.1版本。Doesitmeanthatthereisnointegrationfordifferentthan`1.3.1`versionwithspring?Oritmeansthatweshouldnotuseit(springint
如何从Akkaactor中找出集群的节点？即本节点认为当前可访问的节点。谢谢，-丹尼尔 最佳答案 您实际上不需要订阅ClusterDomainEvent或MemberEvent。您可以只访问Cluster扩展的state成员，例如valcluster=akka.cluster.Cluster(context.system)valmembers=cluster.state.members.filter(_.status==MemberStatus.Up) 关于java-Akka:如何找到集
我想保持事件进入总线的顺序。例如，如果event1然后event2进入总线，那么订阅的actor将按该顺序获取它们。问题是在集群和单节点actor系统上是否可以保证这样的顺序。 最佳答案 如果您在actor系统(system.eventStream)上使用事件流，并且您可以保证单个线程正在发布，那么是的，顺序将被保留。事件总线的子channel分类风格(与system.eventStream相关的那种)非常简单。有一个基本类类型的Map到订阅参与者列表。发布事件时，它会从Map(如果有)中获取匹配的订阅者列表，然后将消息发送给每个订
我有以下驱动程序/主类封装了我的Akka程序://Groovypseudo-codeclassFizzBuzz{ActorSystemactorSystemstaticvoidmain(String[]args){FizzBuzzd=newFizzBuzz()d.run()}voidrun(){InitializeinitCmd=newInitialize()MasterActormaster=actorSystem.get(...)//Tellstheentireactorsystemtoinitializeitselfandstartdoingstuff.//ChickenCluc
Akkadocs声明默认调度程序是一个fork-join-executor，因为它“在大多数情况下提供出色的性能”。我想知道这是为什么？来自ForkJoinPoolAForkJoinPooldiffersfromotherkindsofExecutorServicemainlybyvirtueofemployingwork-stealing:allthreadsinthepoolattempttofindandexecutetaskssubmittedtothepooland/orcreatedbyotheractivetasks(eventuallyblockingwaitingfo
根据akki.io上的文档，我没有看到MicroKernel解决了哪些常见用例？有人有一些简单的现实世界用例吗？谢谢 最佳答案 Akka微内核模块为您提供了一个非常轻量级且免费的“应用程序服务器”bundle，因此可以轻松分发和运行您的Akka应用程序。在这里阅读更多相关信息:http://doc.akka.io/docs/akka/2.0.1/modules/microkernel.html 关于java-使用Akka微内核有哪些常见用例？，我们在StackOverflow上找到一个类
我有以下需求使用用户名和密码连接到网络服务器并获取身份验证token读取文件获取不同的参数使用第1步中的身份验证token和第2步中的参数向Web服务器发送http请求现在我有一个执行以下所有上述任务的Actorpackageakka.first.java;importakka.actor.UntypedActor;publicclassMySingleActorextendsUntypedActor{publicvoidonReceive(Objectmsg){if(msginstanceofsendRequest){//Connecttoawebserverwithausernam
需要一些关于如何在Java(不是Scala!)中使用Akka提供的EventBus的建议。网站上的文档似乎不完整:http://doc.akka.io/docs/akka/2.0.1/java/event-bus.html据我所知，应该创建Actor来对特定消息使用react，例如:finalActorSystemactorSystem=ActorSystem.create("ServerEvents");finalActorRefactor=actorSystem.actorOf(newProps(SeverEventHandler.class));actorSystem.event
