【发布时间】:2019-10-05 21:36:41
【问题描述】:
我遇到了一个问题,在应用程序运行一段时间后,发送到 akka 集群中远程参与者的消息具有非常高的延迟(10+ 秒)。日志表明提供者试图解析旧演员ActorPaths,这与我实际上将消息发送到的ActorRef 无关。您可以在问题底部找到日志摘录。
我的应用程序包含 3 个 ActorSystems,它们通过 akka-cluster 进行交互,远程传输通过 artery 配置,我将在下面提供我的 applications.conf(s)。
我以编程方式将远程actor创建为本地actor (like so),然后再次从子actor执行相同操作(因此最终得到不同ActorSystems的父子孙子) .
如果我在应用程序一开始就从孙子向其父级发送消息,我确实会以合理的延迟(
但是,如果我在三个系统上启动(并杀死)其他参与者,则此类消息的消息延迟变得不切实际。我认为这与ActorSystem 的LocalActorRefProviders 之一试图解决以前创建的(并且已经死的)演员的ActorPaths 有关。我将发布一段显示此类情况的应用程序日志摘录。
当我专门向(远程)ActorRef 发送消息时,我不明白为什么需要解决任何其他引用问题,并且非常感谢任何帮助或建议。
// application.conf(s)
akka {
actor {
provider = "cluster"
serializers {
kryo = "com.twitter.chill.akka.AkkaSerializer"
}
serialization-bindings {
"java.io.Serializable" = kryo
"akka.actor.Props" = kryo
}
enable-additional-serialization-bindings = on
}
remote {
log-sent-messages = on
log-received-messages = on
log-remote-lifecycle-events = off
artery {
enabled = on
transport = tcp
canonical.hostname = "127.0.0.1" // these obv differ depending on the system
canonical.port = 7900
}
}
cluster {
seed-nodes = [ // set in AbstractSystem
"akka://experiments-master@127.0.0.1:7900"
],
# WARN Don't use auto-down feature of Akka Cluster in production.
# auto-down-unreachable-after = 10s
}
loglevel = "DEBUG"
}
// ParentActor.java
public class ParentActor extends ClusterAwareActor {
public static final String DEFAULT_NAME = "ParentActor";
public static Props props() {
return Props.create(TestActor.class, () -> new TestActor());
}
TestActor() {}
private final Instant initTime = Instant.now();
@Override
public Receive createReceive() {
return receiveBuilder()
.match(ClusterEvent.CurrentClusterState.class, this::handle)
.match(ClusterEvent.MemberUp.class, this::handle)
.build().orElse(super.createReceive());
}
@Override
protected void handle(ClusterEvent.CurrentClusterState msg) {
super.handle(msg);
Collection<ActorRef> children = this.remoteActorsOf(ChildActor.props(), ChildActor.DEFAULT_NAME, SystemRole.SLAVE, true);
}
}
// excerpt from ClusterAwareActor
// [ ... ]
protected Collection<ActorRef> remoteActorsOf(Props props, String actorName, SystemRole role, boolean skipOwnSystem) {
Collection<ActorRef> results = Lists.newArrayList();
Collection<Member> members = this.systemRoleMemberMap.get(role);
for (Member member : members) {
if (cluster.selfMember().equals(member) && skipOwnSystem) continue;
Props remoteProps = props.withDeploy(new Deploy(new RemoteScope(member.address())));
if (actorName != null) {
results.add(this.getContext().actorOf(remoteProps, CustomStringUtils.randomActorName(actorName))); // this is just so I don't have name clashes
} else {
results.add(this.getContext().actorOf(remoteProps));
}
}
return results;
}
// ChildActor.java
public class ChildActor extends ClusterAwareActor {
public static final String DEFAULT_NAME = "ChildActor";
public static Props props() {
return Props.create(TestActorTwo.class, () -> new TestActorTwo());
}
TestActorTwo() {}
private final Instant initTime = Instant.now();
@Override
public Receive createReceive() {
return receiveBuilder()
.match(ClusterEvent.CurrentClusterState.class, this::handle)
.match(Messages.PongWithSendTime.class, this::handle)
.build().orElse(super.createReceive());
}
@Override
protected void handle(ClusterEvent.CurrentClusterState msg) {
super.handle(msg);
Collection<ActorRef> children = this.remoteActorsOf(GrandChildActor.props(), SystemRole.SLAVE, true);
Preconditions.checkState(children.size() == 1);
Lists.newArrayList(children).get(0).tell(new Messages.PingMessage(), self());
log().info("[{}] Sent PING at {} ms", DEFAULT_NAME, Duration.between(this.initTime, Instant.now()).toMillis());
}
private void handle(Messages.PongWithTime msg) {
log().info("[{}] Received PONG at {} ms, transmission took ~ {} ms",
DEFAULT_NAME,
Duration.between(this.initTime, Instant.now()).toMillis(),
Duration.between(msg.getSendTime(), Instant.now()).toMillis());
}
}
// GrandChildActor.java
public class GrandChildActor extends AbstractLoggingActor {
public static final String DEFAULT_NAME = "GrandChildActor";
public static Props props() {
return Props.create(PongSayer.class, () -> new PongSayer());
}
PongSayer() {}
@Override
public Receive createReceive() {
return receiveBuilder()
.match(Messages.PingMessage.class, this::handle)
.build().orElse(super.createReceive());
}
private void handle(Messages.PingMessage __) {
getContext().getParent().tell(new Messages.PongWithTime(Instant.now()), self());
}
}
只要之前没有创建和杀死其他参与者,所有这些都可以正常工作(即消息通过得相当快)。如果是这种情况,单个消息的传输(仅包装 Instant)可能需要 10 到 30 秒。
您可以在此处查看来自ActorSystem 的日志,其中包含ChildActor:
[INFO] [10/05/2019 22:37:12.431] [dispatcher] [akka://app@172.18.5.173:7700/remote/akka/app@172.18.5.173:7900/user/ParenteActor/ChildActor] Created GrandChildActor and sent PingMessage.
[...]
[DEBUG] [10/05/2019 22:37:13.668] [dispatcher] [akka.actor.LocalActorRefProvider(akka://app)] Resolve (deserialization) of path [remote/akka/app@172.18.5.173:7900/user/path/to/other/unrelated/actor] doesn't match an active actor. It has probably been stopped, using deadLetters.
[DEBUG] [10/05/2019 22:37:13.738] [dispatcher] [akka.actor.LocalActorRefProvider(akka://app)] Resolve (deserialization) of path [remote/akka/app@172.18.5.173:7900/user/path/to/other/unrelated/actor] doesn't match an active actor. It has probably been stopped, using deadLetters.
[DEBUG] [10/05/2019 22:37:13.809] [dispatcher] [akka.actor.LocalActorRefProvider(akka://app)] Resolve (deserialization) of path [remote/akka/app@172.18.5.173:7900/user/path/to/other/unrelated/actor] doesn't match an active actor. It has probably been stopped, using deadLetters.
[...] // there is a metric ton of these
[DEBUG] [10/05/2019 22:37:32.498] [dispatcher] [akka.actor.LocalActorRefProvider(akka://app)] Resolve (deserialization) of path [remote/akka/app@172.18.5.173:7900/user/path/to/other/unrelated/actor] doesn't match an active actor. It has probably been stopped, using deadLetters.
[DEBUG] [10/05/2019 22:37:32.568] [dispatcher] [akka.actor.LocalActorRefProvider(akka://app)] Resolve (deserialization) of path [remote/akka/app@172.18.5.173:7900/user/path/to/other/unrelated/actor] doesn't match an active actor. It has probably been stopped, using deadLetters.
[DEBUG] [10/05/2019 22:37:32.638] [dispatcher] [akka.actor.LocalActorRefProvider(akka://app)] Resolve (deserialization) of path [remote/akka/app@172.18.5.173:7900/user/path/to/other/unrelated/actor] doesn't match an active actor. It has probably been stopped, using deadLetters.
[DEBUG] [10/05/2019 22:37:32.708] [dispatcher] [akka.actor.LocalActorRefProvider(akka://app)] Resolve (deserialization) of path [remote/akka/app@172.18.5.173:7900/user/path/to/other/unrelated/actor] doesn't match an active actor. It has probably been stopped, using deadLetters.
// before finally
[INFO] [10/05/2019 22:37:32.711] [dispatcher] [akka://app@172.18.5.173:7700/remote/akka/app@172.18.5.173:7900/user/ParentActor/ChildActor] Received Lookup response. Transmission took 20234 ms.
【问题讨论】:
标签: java akka akka-cluster