akka-remote-actor

1热度

1回答

问题/背景。我需要向远程演员发送一些消息。这些消息可能包含在接收方未知的类的对象。为了避免出现ClassNotFoundException，我需要拦截这种情况。一个解决方案可能包括在消息反序列化时拦截未知类。然后，消息可能会被不同的应用程序级消息替代，以便远程参与者可以与发件人通信它没有所需的类。我不知道这样的拦截是可能的，因为自德/ serializators必须实现akka.seriali

0热度

1回答

在Akka中的反序列化和类加载 - NoClassDefFoundError

我正在尝试设置一个Akka系统，其中反序列化错误触发了一个协议，其中缺少类别被交换。我使用一个自定义的de/serializer来达到这个目的，一旦它捕获到一个与缺少的类有关的异常，就会向应用程序actor发送一个特定的消息。简而言之，远程系统B将一个对象发送给系统A;如果在反序列化期间系统A得到ClassNotFoundError或NoClassDefFoundError，则系统A向系统B请求

2热度

1回答

Akka Remote：获取自动生成的端口

我有一个Java客户端，它获取自动生成的端口。在启动actor系统后，我想访问端口。 Config clientConfig = ConfigFactory.parseString("akka.remote.netty.tcp.port = 0") .withFallback(ConfigFactory.parseString("akka.remote.netty.tcp.hostna

3热度

1回答

Apache Spark错误的akka-remote netty版本

当spark正在运行用sbt测试时。我得到这个异常： 18:58:49.049 [sparkDriver-akka.actor.default-dispatcher-2] ERROR akka.actor.ActorSystemImpl - Uncaught fatal error from thread [sparkDriver-akka.remote.default-remote-dispat

1热度

2回答

AKKA远程演员错误

我试图运行由 1. Running the remote actor in a machine with IP 192.168.1.7 2. Running the local from my machine 远程演员在启动机器（IP地址为192.168.1.7）的AKKA远程例子;但是当我从我的机器启动Local actor时，它无法连接到远程actor。请找到本地和远程的演员系统配置：

0热度

1回答

从RemotingShutdownEvent中检索节点地址

我们目前正在从Akka 2.0.4更新到2.4.2（我知道，这是一个很大的飞跃，但没有人认为它是增量式的）。无论如何，在旧的代码库中，我们的主节点连接到一些有时会失败的远程从节点（“为什么”仍有待调查）。当从属设备死亡时，主设备收到一个事件，我们可以从中提取getRemoteAddress并相应地处理它（例如，通过管理员通过电子邮件指向失败的节点地址）。在版本2.4.2中，RemoteClie

0热度

1回答

检测远程akka连接错误

我的项目包含2个部分 - 一个是akka服务器，另一个是播放框架。两者都可以重新启动。从阿卡服务器接收日志我使用的WebSocket处理器 def ws = WebSocket.acceptWithActor[JsValue, JsValue] { request => out => CheckerActor.props(out) } 与演员，订阅了一些偏远的演员变化。 c

2热度

2回答

Akka演员：远程演员异常“期货超时后”

我是新的阿卡，我使用Akka 2.3.3版本创建演员。我将创建远程角色并尝试访问客户端。每当我要运行测试用例，下面的异常会抛出： [INFO] [04/27/2016 07:51:23.727] [Localsystem-akka.actor.default-dispatcher-3] [akka://Localsystem/deadLetters] Message [com.harmeetsin

0热度

1回答

如何在java中使用Akka远程访问进行双向通信

通过在网上搜索，我可以进行单向通话，但是当接收器在其控制台中键入任何内容时，它会给出如下错误，并且还希望要知道分布式akka系统如何在java上工作，我从[https://github.com/petabridge/akkadotnet-code-samples]得到了一些帮助，但它在.net中。请帮助我创建一个基于java的distrebute akka系统。 [ERROR] [12/10/2

1热度

2回答

有没有办法将使用我自己的类型输入的消息发送给Akka远程演员？

有没有办法将使用我自己的类输入的消息发送给远程参与者？比如我想能够在我的远程演员收到类似这样的消息： case myClass: MyClass => doSomething() 但我得到一个错误local class incompatible因为serialVersionUID是不同的。发送我找到的MyClass类型的消息的唯一方法是在Json中序列化它。但我必须序列化/反序列化它，并且