在 akka Receive 中保留类型信息

2024-02-22

是否可以在消息处理程序部分函数中保留类型信息?

我有部分函数 eventHandler 通过某些特定参数匹配事件:

  def eventHandler: Receive = {
    case event: Event ⇒
        ...
        val matchingReactions = projectConfiguration.reactions.filter(reaction ⇒ reaction.eventSelector.matches(event))

其中 matches 方法通过反射根据一组规则验证事件:

case class EventSelector(ops: List[FieldEventSelectorOp]) {
  def matches[T <: Event](event: T)(implicit tag: ru.TypeTag[T], classtag: ClassTag[T]): Boolean = {
    ops.map {
      op ⇒ op.matches(event)
    }.reduceLeft(_ & _)
  }
}

case class FieldEventSelectorOp(field: String, operation: Symbol, value: Any) { 
  def matches[T <: Event](event: T)(implicit tag: ru.TypeTag[T], classtag: ClassTag[T]): Boolean = {
...
}

因此,当我检查 matches 方法中的 TypeTag 是什么时,它只返回事件,而不是事件的子类 - 如何让它传递完整的类型信息?

Update:

事件的案例类层次结构:

trait Event {
  def eventType: String
  def eventName: String = this.getClass.getSimpleName
}

trait VCSEvent extends Event {
  def eventType: String = "VCS"
}

case class BranchAdded(branch: String) extends VCSEvent
case class TagAdded(tag: String, commitId: String) extends VCSEvent

具体匹配器:

case class FieldEventSelectorOp(field: String, operation: Symbol, value: Any) extends EventSelectorOp {
  def matches[T <: Event](event: T)(implicit tag: ru.TypeTag[T], classtag: ClassTag[T]): Boolean = {
    val mirror = ru.runtimeMirror(event.getClass.getClassLoader)
    val memberSymbol = tag.tpe.member(ru.newTermName(field))

    if (memberSymbol.name.decoded.equals("<none>"))
      return false

    val fieldValue = if (memberSymbol.isMethod) {
      mirror.reflect(event).reflectMethod(memberSymbol.asMethod).apply()
    } else {
      mirror.reflect(event).reflectField(memberSymbol.asTerm).get
    }

    operation match {
      case 'eq ⇒ fieldValue.equals(value)
      case _   ⇒ false
    }
  }
}

TypeTags 描述仅在编译时存在的类型:在运行时类型被删除,您获得的所有内容都可以通过event.getClass。如果您想将通用类型信息传递给参与者,那么只有一种方法可以做到:在消息中。

trait Event[T] {
  def typeTag: ru.TypeTag[T]
  ...
}

case class MyEvent[T](...)(implicit val typeTag: ru.TypeTag[T])
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

在 akka Receive 中保留类型信息 的相关文章

随机推荐