如何使用带有SSL证书的Akka发送HTTP请求

libraryDependencies += "com.typesafe.akka" %% "akka-http" % "2.6.16"
libraryDependencies += "com.typesafe.akka" %% "akka-http-spray-json" % "2.6.16"
libraryDependencies += "com.typesafe.akka" %% "akka-http-xml" % "2.6.16"

import akka.http.scaladsl.{ConnectionContext, HttpsConnectionContext}
import javax.net.ssl.{KeyManagerFactory, SSLContext, TrustManagerFactory}
import java.security.{KeyStore, SecureRandom}

val password: Array[Char] = "password".toCharArray // SSL证书密码
val keyStore: KeyStore = KeyStore.getInstance("PKCS12")
val keystoreFile: InputStream = getClass.getClassLoader.getResourceAsStream("path/to/keystore.p12") // SSL证书文件路径
keyStore.load(keystoreFile, password)

val keyManagerFactory: KeyManagerFactory = KeyManagerFactory.getInstance("SunX509")
keyManagerFactory.init(keyStore, password)

val trustManagerFactory: TrustManagerFactory = TrustManagerFactory.getInstance("SunX509")
trustManagerFactory.init(keyStore)

val sslContext: SSLContext = SSLContext.getInstance("TLS")
sslContext.init(keyManagerFactory.getKeyManagers, trustManagerFactory.getTrustManagers, new SecureRandom())

val https: HttpsConnectionContext = ConnectionContext.https(sslContext)

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

implicit val system: ActorSystem = ActorSystem()
implicit val materializer: ActorMaterializer = ActorMaterializer()
implicit val executionContext: ExecutionContextExecutor = system.dispatcher

val request = HttpRequest(
  method = HttpMethods.GET,
  uri = "https://example.com",
  entity = HttpEntity.Empty,
  protocol = HttpProtocols.`HTTP/1.1`
)

val responseFuture = Http().singleRequest(request, connectionContext = https)

responseFuture.onComplete {
  case Success(response) =>
    // 处理响应
    response.entity.toStrict(5.seconds).map(_.data.utf8String).foreach(println)
    system.terminate()
  case Failure(ex) =>
    // 处理错误
    ex.printStackTrace()
    system.terminate()
}