scala – 如何用Akka演员使用可堆叠的特征模式？

发布时间：2020-12-16 09:21:37 所属栏目：安全来源：网络整理

导读：我正在尝试使用可堆叠的特征来实现一个Pub / Sub特征来混合到其他的akka??演员. 这是我想出来的： trait PubSubActor extends Actor { abstract override def receive = super.receive orElse { case Subscribe(topic) = /* ... */ case Publish(topic,msg)

我正在尝试使用可堆叠的特征来实现一个Pub / Sub特征来混合到其他的akka??演员.

这是我想出来的：

trait PubSubActor extends Actor {
  abstract override def receive = 
    super.receive orElse {
      case Subscribe(topic) => /* ... */
      case Publish(topic,msg) => /* ... */
    }
}

class MyActor extends Actor with PubSubActor {
  override def receive = {
    case SomeMessage(a,b,c) => /* ... */
  }
}

在这一点上,编译器会抛出一个错误：
错误：覆盖方法接收特征MyActor …方法接收需要“抽象覆盖”修饰符.

你可以向我解释为什么这不工作吗？我该如何解决这个问题呢？

谢谢！

UPDATE

以下作品：

trait PubSubActor extends Actor {
  abstract override def receive = 
    super.receive orElse {
      case Subscribe(topic) => /* ... */
      case Publish(topic,msg) => /* ... */
    }
}

class MyActor extends Actor {
  override def receive = {
    case SomeMessage(a,c) => /* ... */
  }
}

class MyActorImpl extends MyActor with PubSubActor

但为什么？为什么我可以得到我想要的行为,而不是其他的行为？有什么原因？我似乎无法弄清这两个样本之间的差异.

解决方法

有一个简单而简明的解决方案：

定义使用orElse链接多个接收函数的接收特征：

trait Receiving { 
  var receivers: Receive = Actor.emptyBehavior 
  def receiver(next: Actor.Receive) { receivers = receivers orElse next }
  def receive = receivers // Actor.receive definition
}

在演员中使用这个很容易：

trait PubSubActor extends Receiving {
  receiver {
    case Publish => /* I'm the first to handle messages */
  }
}

class MyActor extends PubSubActor with Receiving {
  receiver {
    case SomeMessage => /* PubSubActor didn't handle,I receive the message */ 
  }
}

第一个PubSubActor的接收将被调用.如果消息未被处理,它将被传递给MyActor的接收.

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!