问如何使用WebSocket在play Framework2.5.x中创建多个用户

EN

object MyWebSocketActor {
  case object Init
}

class MyWebSocketActor(out: ActorRef) extends Actor {

  //you can pass precreated room in constructor or receive it from message,
  //based on your logic
  val room: ActorRef = ???

  //when actor starts, it register self in room, we send Init 
  //message, because actors communications should be in `receive`
  override def preStart(): Unit = {
    self ! Init
  }

  //initial state, waiting joining in room 
  def waitingToJoin: Receive = {
    case Init => room ! Join(self)
    case Joined => context become joined
  }

  //joined state, process messages from out and room
  def joined: Receive = {
    case textFromOut: String => room ! Msg(textFromOut)
    case msg: Msg => out ! msg.toString
  }

  //initial state
  override def receive: Receive = waitingToJoin
}


object Room {
  //request to join
  case class Join(user: ActorRef)
  //join response
  case class Joined(room: ActorRef)
  case class Msg(text: String)
}

class Room extends Actor {

  //users in room
  val users: ListBuffer[ActorRef] = ListBuffer()

  override def receive: Receive = {
    case msg: Msg =>
      //send messages to all users
      users.foreach(u => u ! msg)
    //join request
    case Join(user) =>
      context watch user
      users += user
      user ! Joined(self)
    case Terminated(user) =>
      users -= user
  }

}