在Akka Actor中撰写多个接收函数

我有一个Akka Actor，负责管理一些消息，如Find,Query，它将一条新消息转发给其他类型的演员。这些演员将以新类型的消息作出回应。在Akka Actor中撰写多个接收函数

class Actorbase extends Actor { 
    override def receive = { 
    /* The two message below are related to each other */ 
    case Find(coll, id) => // Do something 
    case QueryAck(key, value, u) => // Do something 
    /* The three message below are related to each other */ 
    case Upsert(collection, id, value) => // Do something 
    case Response.UpsertNAck(key, msg, u) => // Do something 
    case Response.UpsertAck(key, u) => // Do something 
    /* And so on... */ 
    } 
}

在上述例子中，是QueryAckFind类型的消息的前向的响应消息。 UpsertNAck和UpsertAck是对Upsert消息的可能响应。

为了使代码更具可读性和可维护性，我希望将两组case分为两个专用方法，即manageQueries和manageUpserts，获得类似于以下代码的内容。

class Actorbase extends Actor { 
    override def receive = { 
    manageQueries.andThen(manageUpserts) 
    } 
}

可能吗？我是否需要声明多个方法返回Receive对象，然后以某种方式组合它们？

非常感谢。

来源

2017-09-05 riccardo.cardin

的Receive仅仅是PartialFunction[Any, Unit]一个类型别名，所以你可以定义这样的任何地方，使用f1 orElse f2将它们结合起来：

val manageQueries: Receive = { case ... } 
val manageUpserts: Receive = { case ... } 

def receive = manageQueries.orElse(manageUpserts)

希望这有助于

来源

2017-09-05 10:22:24

感谢您的答复。你认为这是我在问题中描述的方法还是在[this]中暴露的方法更好（https://stackoverflow.com/questions/8681444/composing-trait-behavior-in-scala-in-an-akka- receive-method？rq = 1）SO答案？ –

这比我认为的另一个更好（作为项目的维护者） –

在Akka Actor中撰写多个接收函数

回答

相关问题