supervisor策略RESTART，其实不重启我的child actors？

Question

我有以下策略：

  override val supervisorStrategy = OneForOneStrategy(10, 10.seconds) {
    case e: JedisConnectionException => Restart
    case e: Exception => Restart
  }

根据我的阅读（我认为我误解了），每当子 actor 抛出未被捕获的异常时，它就会升级到父 actor。根据我上面的规则，如果我的子演员总是在接收时抛出异常，它不应该重新启动 10 次吗？

出于某种原因，从我的日志来看，它似乎只重新启动了一次，仅此而已。我把日志放在启动前和启动后。

编辑：

我意识到我犯了一个错误：

我使用的是 "context.system.actorof()" 这就是为什么 none 的儿童演员对该策略有反应。现在我正在使用 "context.actorof()" 并且我确实看到了 strat "caught" 的例外情况。

对于我的子演员，它需要与 redis 对话以获取信息，我故意关闭了我的 redis，这样子演员就会失败，现在如果我将我的 supervisor strat 设置为最多重启 10 次，我应该看到相同的堆栈跟踪 10 次？

我假设当子 actor 重新启动时，已发送的相同消息会再次发送给它，我的假设是否正确？

    2015-10-22 15:31:17,747 - [error] a.a.OneForOneStrategy - Error occurred trying to check for item existing in Redis:
java.lang.RuntimeException: Error occurred trying to check for item existing in Redis:
    at services.impl.RedisStatusServiceImpl.exists(RedisStatusServiceImpl.scala:62) ~[classes/:na]
    at w.c.Poller$$anonfun$process.apply(Poller.scala:64) ~[classes/:na]
    at w.c.Poller$$anonfun$process.apply(Poller.scala:58) ~[classes/:na]
    at scala.collection.immutable.List.foreach(List.scala:381) ~[scala-library-2.11.7.jar:na]
    at w.c.Poller.process(Poller.scala:58) ~[classes/:na]
Caused by: redis.clients.jedis.exceptions.JedisConnectionException: Could not get a resource from the pool
    at redis.clients.util.Pool.getResource(Pool.java:50) ~[jedis-2.7.3.jar:na]
    at redis.clients.jedis.JedisPool.getResource(JedisPool.java:99) ~[jedis-2.7.3.jar:na]
    at services.impl.RedisStatusServiceImpl.exists(RedisStatusServiceImpl.scala:58) ~[classes/:na]
    at w.c.Poller$$anonfun$process.apply(Poller.scala:64) ~[classes/:na]
    at w.c.Poller$$anonfun$process.apply(Poller.scala:58) ~[classes/:na]
Caused by: redis.clients.jedis.exceptions.JedisConnectionException: java.net.ConnectException: Connection refused
    at redis.clients.jedis.Connection.connect(Connection.java:164) ~[jedis-2.7.3.jar:na]
    at redis.clients.jedis.BinaryClient.connect(BinaryClient.java:82) ~[jedis-2.7.3.jar:na]
    at redis.clients.jedis.BinaryJedis.connect(BinaryJedis.java:1641) ~[jedis-2.7.3.jar:na]
    at redis.clients.jedis.JedisFactory.makeObject(JedisFactory.java:85) ~[jedis-2.7.3.jar:na]
    at org.apache.commons.pool2.impl.GenericObjectPool.create(GenericObjectPool.java:861) ~[commons-pool2-2.3.jar:2.3]
Caused by: java.net.ConnectException: Connection refused
    at java.net.PlainSocketImpl.socketConnect(Native Method) ~[na:1.8.0_05]
    at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:345) ~[na:1.8.0_05]
    at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206) ~[na:1.8.0_05]
    at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188) ~[na:1.8.0_05]
    at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392) ~[na:1.8.0_05]

Answer 1

是的，如果儿童演员在window（在您的示例中为 10 秒）内达到 maxNrOfRetries（在您的情况下为 10）重新启动，它将被停止。

您可以定义全局 supervisorStrategy，例如在某些基本特征或抽象 Actor class 中。在这种情况下，您所有的 actor classes 都是该 BaseActor 的子classes。

supervisor策略RESTART，其实不重启我的child actors？

Supervisor strategy RESTART, doesn't actually restart my child actors?

scala

akka

akka-supervision