gpt4 book ai didi

akka - 通过主管策略重新启动actor后如何取消发送消息

转载 作者:行者123 更新时间:2023-12-04 13:49:22 27 4
gpt4 key购买 nike

我有一个父 Actor (A)和两个 child Actor (B)。
我在A中制定了主管策略,因此,如果B中发生特定异常,B将重新启动。

如何再次将导致B中的异常的消息重新发送到B?

最佳答案

我在B中所做的是在preRestart中再次将消息发送给B,请参见下面的代码。

  @Override
public void preRestart(final Throwable reason, final scala.Option<Object> message) throws Exception
{
getSelf().tell(message.get(), getSender());
};

为确保我不会陷入无限循环,请按以下步骤在A中配置主管策略:
  private final SupervisorStrategy strategy = new OneForOneStrategy(3, Duration.Inf(),
new Function<Throwable, SupervisorStrategy.Directive>()
{
@Override
public Directive apply(final Throwable t) throws Exception
{
if (t instanceof SpecificException)
{
return SupervisorStrategy.restart();
}
return SupervisorStrategy.escalate();
}
});

这应该保证,有问题的消息仅被重发3次。如果这是好的做法,有人可以给我建议吗?还是可以给我提供更好的解决方案?

关于akka - 通过主管策略重新启动actor后如何取消发送消息,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/29986854/

27 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com