如何解决探索 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
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。