Vertx Scala:如何设置websocket连接和发送消息

libraryDependencies += "io.vertx" %% "vertx-scala" % "3.9.0"

import io.vertx.lang.scala.ScalaVerticle
import io.vertx.scala.core.Vertx

object Main extends App {
  val vertx = Vertx.vertx()
}

val server = vertx.createHttpServer()
val options = new HttpServerOptions().setPort(8080)
val websocketHandler = new WebSocketHandler()
server.websocketHandler(websocketHandler)
server.listen(options)

class WebSocketHandler extends ScalaVerticle {
  override def start(): Unit = {
    vertx.eventBus().consumer[String]("websocket.messages").handler { message: Message[String] =>
      val payload = message.body()
      // 处理接收到的消息
    }
  }
}

val message = "Hello, WebSocket!"
vertx.eventBus().publish("websocket.messages", message)