Pracuję nad prostą grą multiplayer w scala, którą chciałbym udostępnić poprzez strony internetowe dla klientów JS.Akka HTTP Websocket, jak zidentyfikować połączenia wewnątrz aktora
Oto moja klasa WebsocketServer
class WebsocketServer(actorRef: ActorRef, protocol: Protocol, system: ActorSystem, materializer: ActorMaterializer) extends Directives {
val route = get {
pathEndOrSingleSlash {
handleWebSocketMessages(websocketFlow)
}
}
def websocketFlow: Flow[Message, Message, Any] =
Flow[Message]
.map {
case TextMessage.Strict(textMessage) => protocol.hydrate(textMessage)
}
.via(actorFlow)
.map(event => TextMessage.Strict(protocol.serialize(event)))
def actorFlow : Flow[Protocol.Message, Protocol.Event, Any] = {
val sink =
Flow[Protocol.Message]
.to(Sink.actorRef[Protocol.Message](actorRef, Protocol.CloseConnection()))
val source =
Source.actorRef[Protocol.Event](1, OverflowStrategy.fail)
.mapMaterializedValue(actor => actorRef ! Protocol.OpenConnection(actor))
Flow.fromSinkAndSource(sink, source)
}
}
To jest uproszczony kod mojego aktora, który powinien odbierać wiadomości z serwera websocket.
class GameActor() extends Actor {
private var connections: List[ActorRef] = List()
override def receive: Receive = {
case message: Protocol.OpenConnection => {
this.connections = message.connection :: this.connections
message.connection ! Protocol.ConnectionEstablished()
}
case message: Protocol.CloseConnection => {
// how can I remove actor from this.connections ?
}
case message: Protocol.DoSomething => {
// how can I identify from which connection this message came in?
}
}
}
tej pory tak dobry, obecnie jestem w stanie odpowiedzieć z prostym WelcomeMessage do klienta jednak ja nadal nie wiem, jak:
- aktor usuń z listy połączeń, gdy aktor otrzyma
CloseConnection
wiadomość? - określić, z której wiadomości o połączeniu doszła wiadomość do aktora?
Szukałem jakiegoś wbudowanego mechanizmu i nigdy nie myślałem o najprostszym rozwiązaniu, dzięki! –