Scala with play：Class 尝试通过 websocket 发送数据时抛出异常

Question

我正在尝试使用 Scala、Play 和 Akka 设置一个基本的基于 websocket 的通知系统。 websocket 工作正常，我能够发送东西，回显它，用新创建的 case classes 等进行响应。我已经定义了一个带有 case classes 的密封特征来表示各种输入和输出，自定义写入和读取以管理 input/output JSON 对象和 add/remove 一个 "type" 字段。

但是，当我尝试通过外部操作通过 websocket 发送数据时，我得到了这个奇怪的运行时间错误：java.lang.ClassCastException: v1.socket.SocketEvent$ cannot be cast to v1.socket.SocketEvent

这是一个动作的调用：

WebSocketActor.send(ConnectionRequest("test", "test", "test"), "test")

这是我的 WebSocketActor：

object WebSocketActor {
  def props(out: ActorRef) = Props(new WebSocketActor(out))
  var sessions: Map[String, Map[String, ActorRef]] = Map()

  /** Send data to a specified user. 
    * Response with false if the user does not have a session 
    */
  def send(socketEvent: SocketEvent, userId: String): Boolean = {
    if (sessions contains userId) {
      val userSessions = sessions(userId)
      userSessions.foreach(user => user._2 ! SocketEvent)
      return true
    }
    false
  }
}

class WebSocketActor(out: ActorRef) extends Actor {

  /** Authenticate the user and add device to session
    * (note that authentication is stripped out for brevity) 
    */

  def auth: Receive = {
    case init: Init => {
      var session: Map[String, ActorRef] = Map(init.deviceId -> out)
      if (sessions contains init.userId) {
        session = session ++ sessions(init.userId)
      }
      sessions = sessions + (init.userId -> session)

      context become await
    }
  }

  def await: Receive = {
    case conReq: ConnectionRequest => {
      out ! conReq
    }

  }
  override def receive: Receive = auth

}

这是 SocketEvent seale trait、伴随对象和案例 classes:

sealed trait SocketEvent

object SocketEvent {

  implicit val socketEventFmt: Format[SocketEvent] = new Format[SocketEvent] {

    override def writes(event: SocketEvent): JsValue = event match {
      case e: ConnectionRequest => Json.toJson(e)(Json.format[ConnectionRequest])
      case e: Init => Json.toJson(e)(Json.format[Init])
    }
    override def reads(json: JsValue): JsResult[SocketEvent] = (json \ "type").as[String] match {
      case "connectionRequest" =>
        Json.fromJson[ConnectionRequest](json.as[JsObject] - "type")(Json.format[ConnectionRequest])
      case "init" =>
        Json.fromJson[Init](json.as[JsObject] - "type")(Json.format[Init])
    }
  }
}

case class ConnectionRequest(userId: String, publicKey: String, signature: String) extends SocketEvent
object ConnectionRequest {
  implicit val format: OWrites[ConnectionRequest] = Json.format[ConnectionRequest]
    .withConstant("type", "connectionRequest")
}

case class Init(userId: String, deviceId: String) extends SocketEvent
object Init{
  implicit val initFmt: OWrites[Init] = Json.format[Init]
    .withConstant("type", "Init")
}

最后，一个 OWritesExtra class 用于向输出的 Json 添加字段：

object OWritesExtra {

  implicit class OWritesExt[A](owrites: OWrites[A]) {

    /** Add a (key, value) pair to the JSON object,
      * where the value is constant.
      */
    def withConstant[B: Writes](key: String, value: B): OWrites[A] =
      withValue(key, _ => value)

    /** Add a key, value pair to the JSON object that is written, where
      * the value depends on the original object.
      */
    def withValue[B: Writes](key: String, value: A => B): OWrites[A] =
      new OWrites[A] {
        def writes(a: A): JsObject = owrites.writes(a) ++ Json.obj(key -> value(a))
      }

  }

}

Answer 1

问题是我在 send 方法中发送了类型 SocketEvent 而不是实例 socketEvent。

Scala with play：Class 尝试通过 websocket 发送数据时抛出异常

Scala with play: Class Cast Exception when trying to send data through a websocket

scala

akka

playframework