探索 Akka Typed Actors 函数式与面向对象的方式

问题描述

我曾研究过 Akka actor（非类型化），最近开始编写 Akka 类型化 actor，并发现了两种实现方式，一种是函数方式，另一种是面向对象方式（类似于旧的）。

我对以函数式和面向对象的方式理解状态封装很感兴趣。所以写了一个函数方式的方法和一个面向对象方式的类。

功能方式：


def webSocketConnections(l: List[ActorRef[Message]] = List.empty): Behavior[WebSocketMsg] = {
    Behaviors.receive[WebSocketMsg] {
      (context,message) => {
        message match {
          case Model.UserAdded(actorRef) => webSocketConnections(actorRef :: l)
          case Model.broadcastToAll(msg) =>
            context.spawnAnonymous(broadCastActorBehavIoUr) ! broadcast(l,msg)
            Behaviors.same
        }
      }
    }
  }

面向对象的方式

class WebSocketConnectionMaintainer(actorContext: ActorContext[WebSocketMsg]) extends
  AbstractBehavior[WebSocketMsg](actorContext) {
  private var actorRefL: List[ActorRef[Message]] = List.empty

  override def onMessage(msg: WebSocketMsg): Behavior[WebSocketMsg] = {
    msg match {
      case Model.UserAdded(actorRef) =>
        actorRefL =  actorRef :: actorRefL
        Behaviors.same
      case Model.broadcastToAll(msg) =>
        actorContext.spawnAnonymous(broadCastActorBehavIoUr) ! broadcast(actorRefL,msg)
        Behaviors.same
    }
  }
}

如果你观察这两种情况，在函数方式的情况下，状态被封装为一个参数，不确定它是否会在堆栈安全方面存在问题，因为它可能会在很多次之后由于堆栈溢出错误而崩溃打电话对吗？

但是如果你观察面向对象的方式，它只是直接改变列表，不会导致任何堆栈溢出问题。

我发现的另一个问题是，我只能使用 context.spawn 来生成一个功能性的方式actor，但是在面向对象的情况下，我需要一个特定类型的上下文。如果我想同时创建函数式和面向对象的 Actor 该怎么办？

解决方法

关于堆栈安全问题，简短的回答是明显的递归是蹦床的，所以它不会炸毁堆栈。见this StackOverflow question。

为了生成 OO 定义的类型化 actor，您可以使用 + curl.exe -s $'https://example.com\r' 注入上下文：

Behaviors.setup

actor akka akka-typed scala