akka-remote-actor

1热度

1回答

是否有可能进一步限定序列化绑定？运行时类型看起来太有限了。例如我有我现在无法序列ToDo[MyPayload]用不同的串行比ToDo[OtherPayload]（甚至在不同的演员！），因为其运行时类的名字是相同的（PersistentExecutorProtocol$ToDo）。我错过了什么吗？ - 引入AProtocolClass或使PersistentExecutorProtocol和

1热度

1回答

java akka默认序列化器警告

我不想禁用警告消息，因为我想知道如何完成建议来定义序列化器以提高性能？ [INFO] [06/24/2016 19:28:34.659] [main] [akka.remote.Remoting] Starting remoting [INFO] [06/24/2016 19:28:34.827] [main] [akka.remote.Remoting] Remoting started; l

2热度

1回答

如何使用Akka Remoting通过CLI将消息发送给远程演员？

我有一个远程演员，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

1热度

1回答

Akka.NET：无法发送列表消息给其他演员系统

我是Akka.NET的新手。我最近开始做我的大学项目并面临奇怪的问题。我在两个不同的桌面应用程序中有两个ActorSystems。在第一个ActorSystem中，我使用Akka.Remote在两个演员之间发送消息ZippedAddressListMessage。 public class ZippedAddressListMessage { public ZippedAd

0热度

1回答

AKKA：关于编程式远程部署的困惑

我正在使用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消息中移除共享状态的正确位置？

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

1热度

1回答

错误：从Actor到Actor的消息未送达。[1]遇到死信。分布式pub-sub跨群集工作不起作用

我试图在不同的群集系统上创建分布式pub-sub，但它无法正常工作。我想要做的就是创建一个简单的例子。 1）我创建了一个话题，说“内容”。 2）say jvm A中的一个节点创建该主题，订阅该主题以及发布该主题的发布者。 3）在一个不同的节点上，比如jvm B在不同的端口上，我创建一个订户。 4）当我从jvm A向主题发送消息时，我想让jvm B上的订阅者收到它，因为它订阅了同一主题。任何帮助

1热度

3回答

Akka - 创建远程演员

我试图在远程主机上创建Akka Actor。继官方文档之后，我创建了一个远程Actor系统解析application.config文件，然后创建一个新的actor。这是我的代码： public static void main(String[] args) { Config config = ConfigFactory.parseFile(new File("application