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

Question

我曾从事 Akka actor（非类型化）的工作，最近开始编写 Akka 类型化的 actor，发现有两种实现方式，一种是函数式方式，另一种是面向对象方式（与旧方式类似）。

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

函数方式：


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，但在面向对象的情况下，我需要特定类型的上下文。如果我想同时创建函数式和面向对象的 actors，该怎么办？

Answer 1

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

为了生成 OO 定义的类型化 actor，您使用 Behaviors.setup 注入上下文：

def ooBehavior: Behavior[WebSocketMsg] = Behaviors.setup { ctx =>
  new WebSocketConnectionMaintainer(ctx)
}
context.spawn(ooBehavior)

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

Exploring Akka Typed Actors Functional Vs Object Oriented Way

scala

actor

akka

akka-typed