Я пытаюсь настроить базовую систему уведомлений на основе веб-сокетов, используя Scala, Play и Akka.Веб-сокет работает нормально, я могу отправлять вещи, выводить их обратно, отвечать на вновь созданные классы дел и т. Д. Я определил запечатанную черту с классами дел для представления различных входов и выходов, с пользовательскими операциями записи и чтения по порядку.управлять объектами ввода / вывода JSON и добавлять / удалять поле типа.
Однако, когда я пытаюсь отправить данные через веб-сокет с помощью внешнего действия, я получаю странную ошибку времени выполнения: 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, сопутствующие объекты и классы дел:
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, который используетсяЧтобы добавить поля в 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))
}
}
}