使用Lagom保护网络套接字

Question

使用lightbend Lagom框架，我正在尝试连接到Binance的websocket api。

然而，我在连接时不断收到以下错误：

400纯HTTP请求被发送到HTTPS端口

是否可以从Lagom连接到安全的websocket服务？那么WebSocketClient呢？我有以下代码：

trait BinanceStreamingService extends Service {
def depthStream(symbol: String): ServiceCall[NotUsed, Source[DepthEvent, NotUsed]]
override final def descriptor = {
import Service._
import me.koopal.crypto.api.BinanceModelsMarshallers._
named("depth-stream")
.withCalls(
restCall(GET, "/ws/:symbol@deth", depthStream _)
)
}
} 
private val binanceStreamApplication = new LagomClientApplication("binance-ws") with StaticServiceLocatorComponents with AhcWSComponents {
override def staticServiceUri = URI.create("wss://stream.binance.com:9443")
}
override def stream = ServiceCall { _ =>
binanceStreamClient.depthStream("bnbbtc")
.invoke()
.map { s =>
s.runForeach(e => println(e))
}.onComplete {
case Success(x) => println("success", x)
case Failure(ex) => println("failure", ex)
}
Future.successful("test")
}

ruuning代码示例可在此处找到：https://github.com/stijnkoopal/lagom-binance-websockets

Answer 1

Lagom的WebSocket客户端还不支持TLS。使用Akka HTTP重新实现客户端存在一个悬而未决的问题，这将启用TLS支持：https://github.com/lagom/lagom/issues/895

同时，最好的方法是使用Akka HTTP客户端WebSocket支持或另一个支持安全连接的WebSocket客户端库来实现您的客户端。