Akka-Stream 2.6.0+不推荐的参与者系统设置

Question

我过去常常在绑定中设置我的演员系统，如下所示：

  implicit val System: ActorSystem = ActorSystem()
  implicit val Mat: Materializer = ActorMaterializer(ActorMaterializerSettings.create(System).withSupervisionStrategy(Decider))

但是在新版本中，ActorMaterializer.apply/.create/.withSupervisionStrategy是不可取的：

  @deprecated(
    "Use the system wide materializer or Materializer.apply(actorContext) with stream attributes or configuration settings to change defaults",
    "2.6.0")

  @deprecated(
    "Use the system wide materializer or Materializer.create(actorContext) with stream attributes or configuration settings to change defaults",
    "2.6.0")

  @deprecated("Use attribute 'ActorAttributes.supervisionStrategy' to change setting value", "2.6.0")

我不知道我的两行系统应该改变什么.

Answer 1

均衡器容易，监管策略需要更多的改变。

1. 监督策略。您需要提供decider作为流的属性，例如： 来源..。.withAttributes(ActorAttributes.supervisionStrategy(decider)) .via(flow) .toMat(接收器)
2. 以这种方式创建实现者： 隐式val Mat: Materializer = Materializer(System)

Answer 2

是的，它是不推荐的，并且在文档中有明确的说明。

您实际上应该做的就是创建ActorSystem并使用隐式Materializer。正如在文档中所写的，Materializer提供了从盒子里出来。

在您的代码中，只需删除Materializer的显式创建