akka-remoting

    1热度

    1回答

    我正在将Play 2.3.x应用程序迁移到Play 2.5.x,并且在使用依赖注入时遇到了一些问题。 在2.3中,我有一个特性HasRemoteActor,控制器会根据配置混合引用一些远程参与者。由于这需要应用程序的配置对象,现在要求它变成一个类,因此可以注入配置。这里是我的尝试: /* Dummy controller that has environment and configur

    0热度

    1回答

    我正在学习Akka,并且正在尝试使用Akka远程处理。我正在使用intellij IDE,使用的语言是Java。我尝试运行AKKA远程示例(计算器)。我没有使用sbt工具。我如何构建应用程序并运行它。我试着运行该示例,但我不认为它正确读取配置文件,并且不创建远程参与者。我已经在项目中包含了akka jar文件。我在intellij中创建了一个简单的java项目来运行程序。 我是否正确的做法?什么是

    2热度

    1回答

    我有一个远程演员,Bar和本地演员Foo。我希望使用Foo在每次调用CLI时将消息传递给Bar。 Bar可以成功传递消息,但Foo在等待消息时挂起。为了解决这个问题,我在Foo的最后添加了一个sys.exit(0)。这会导致与Foo的系统有关联问题。 如何在连续CLI发行之间关闭本地演员而不手动杀死本地演员? 闭嘴,给我代码! 的Foo: build.sbt name := "Foo" ver

    0热度

    1回答

    我正在以编程方式创建远程演员演员。 以下是节目 - package remoting.programatic.demo import akka.actor.{ActorSystem, Props} import com.typesafe.config.ConfigFactory import remoting.config.demo.RemoteActor object RemoteA

    0热度

    1回答

    我有两个通过akka远程通信的角色系统。 当我看看JVM堆时,我看到(太)akka.dispatch.Envelope的许多实例包含来自akka.remote.RemoteActorRefProvider$RemoteDeadLetterActorRef的SelectChildName消息。 这些消息的保留堆非常大,并导致内存问题。 这些SelectChildName消息的目的是什么?有没有办法避

    0热度

    1回答

    我正在使用akka remote deployment。我使用日志记录来确保角色是否已成功部署到远程。这是我的日志信息 [adaptiveCEP-akka.actor.default-dispatcher-18] [akka.tcp://[email protected]:2555/remote/akka.tcp/[email protected]:2554/user/disjunction/si

    0热度

    1回答

    如何向所有正在观看特定演员的演员播放讯息? 对于上下文,假设我有一个AuctionActor(这可能是一个远程角色),正在被大量的AuctionParticipantActor类型监视。我想AuctionActor广播各种消息到AuctionParicipantActor类型。 一种可能性是AuctionActor保留所有参与者ActorRef实例的集合,然后在需要将消息发送给所有参与者时循环该集

    0热度

    2回答

    我正在使用分布式算法,并决定使用Akka在机器间进行缩放。机器需要非常频繁地交换消息,并且这些消息引用每台机器上存在的一些不可变对象。因此,从消息中共享的,复制的对象不应被序列化的意义上来说,“压缩”消息似乎是明智的。这不仅可以节省网络带宽,而且还可以避免在消息反序列化时在接收端创建重复对象。 现在,我的问题是如何正确地做到这一点。到目前为止,我能想到的两个选项: 处理这种情况“业务层”上,即,将