在Scala中如何實現和使用WebSockets進行實時通信

在Scala中實現和使用WebSockets進行實時通信通常使用Akka HTTP庫。下面是一個簡單的示例代碼，演示如何在Scala中使用Akka HTTP實現一個基本的WebSocket服務器：

import akka.actor.ActorSystem
import akka.http.scaladsl.Http
import akka.stream.ActorMaterializer
import akka.http.scaladsl.server.Directives._
import akka.http.scaladsl.model.ws._

object WebSocketServer extends App {
  implicit val system = ActorSystem()
  implicit val materializer = ActorMaterializer()
  implicit val executionContext = system.dispatcher

  val route = path("websocket") {
    handleWebSocketMessages(websocketFlow)
  }

  val websocketFlow = Flow[Message]
    .collect {
      case TextMessage.Strict(msg) => TextMessage("Echo: " + msg)
    }

  val bindingFuture = Http().bindAndHandle(route, "localhost", 8080)

  println(s"Server online at http://localhost:8080/websocket")

  sys.addShutdownHook {
    bindingFuture
      .flatMap(_.unbind())
      .onComplete(_ => system.terminate())
  }
}

在上面的示例中，我們創建了一個簡單的WebSocket服務器，當有客戶端連接時，服務器會將客戶端發送的消息原樣返回給客戶端。通過訪問http://localhost:8080/websocket可以連接到該WebSocket服務器。

在實際應用中，您可以根據需要擴展和定制websocketFlow，以實現更復雜的WebSocket通信邏輯。通過使用Akka HTTP和Akka Streams，您可以輕松地構建出強大的實時通信系統。