我的用例如下。机器上的应用程序连接到远程机器，在它们上执行脚本并返回结果。我正在使用AkkaFramework进行远程处理，并为客户端应用程序使用PlayFramework。在我的远程机器上运行的服务器代码如下:publicstaticvoidmain(String[]args){OnCallServerapp=newOnCallServer();app.executeServer();}privatevoidexecuteServer(){ActorSystemsystem=ActorSystem.create("OnCallServer");}(只是在远程机器上启动一个actor系
谁能告诉我一个使用JAVAAPI的akka-http的工作示例。提前致谢。 最佳答案 这是一个演示概念的小应用程序:https://github.com/J-Technologies/akka-http-java 关于java-Akka-httpJavaAPI示例代码/文档，我们在StackOverflow上找到一个类似的问题： https://stackoverflow.com/questions/28638176/
我正在Java服务层中调用，如下所示；Futurefuture=Patterns.ask(myActor,message,timeout);Responseres=(Response)Await.result(future,timeout.duration());我已经阅读了Akka文档并意识到不推荐这样的阻塞。我需要将响应对象返回给调用方法。是否可以通过我的Java服务与Akka异步执行此操作？我尝试使用future.onSuccess方法来执行此操作，但是onSuccess方法不允许返回值，因此我无法返回该值。 最佳答案 在线程
我有一个actorFooActor，它通过Props来实例化几个BarActor并发送BarMessage给它。代码有效，但我很难为它编写测试。添加的限制是我只能在此应用程序中使用Java代码，不能使用Scala代码。经过几次尝试，这似乎是我迄今为止最大的努力:@TestpublicvoidtestJavaTestKit(){newJavaTestKit(system){{JavaTestKitprobe=newJavaTestKit(system);//pretendingthattheprobeisthereceivingBar,byreturningitinthePropsPro
首先让我说我是Scala的新手；但是，我发现基于Actor的并发模型很有趣，并且我尝试将其用于一个相对简单的应用程序。我遇到的问题是，尽管我能够让应用程序运行，但结果(在实时、CPU时间和内存使用方面)的效率远低于基于Java的等效解决方案使用从ArrayBlockingQueue中提取消息的线程。我想明白为什么。我怀疑这可能是我缺乏Scala知识，并且我造成了所有的低效率，但在多次尝试重新设计应用程序但没有成功之后，我决定向社区寻求帮助。我的问题是:我有一个包含许多行的gzip文件，格式为:SomeIDcomma_separated_list_of_values例如:123412,4
我正在尝试将OneForOneStrategy粘贴到一个简单的Hello-Akka程序中，就像基于此文档一样:http://doc.akka.io/docs/akka/2.3.2/java/fault-tolerance.htmlprivatestaticSupervisorStrategystrategy=newOneForOneStrategy(10,Duration.create("1minute"),newFunction(){@OverridepublicSupervisorStrategy.Directiveapply(Throwablet){if(tinstanceofA
到目前为止，我唯一看到的是有人发布了一个测试TypedActor的示例。我认为没有办法通过Junit来测试UntypedActor？Akka文档一天比一天好，但我没有看到提到测试。它真的很明显，我只是错过了什么吗？ 最佳答案 要使用JUnit进行测试，您需要使用JUnit提供的工具，有关测试Actor(Java等同于UntypedActor)的文档位于:http://akka.io/docs/akka/snapshot/scala/testing.html 关于java-我们如何在Jav
要在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
我有一个专用于静态内容的服务器，所以我不想使用资源目录来存储javascript文件，但我不想停止使用标签。我怎样才能使该标记生成指向文件所在的静态服务器的链接，而不是RES_NOT_FOUND。我什至不需要JSF来检查文件是否存在...我试过:生成:但它生成:我能做什么？解决方案:丹尼尔向我指出了一个不错的解决方案!我已经下载了Omnifaces的源代码并修改了org.omnifaces.resourcehandler.CDNResourceHandle.createResource(StringresourceName,StringlibraryName)方法:publicReso
