在spark-java中使用https

Question

如何在spark-java框架中使用自定义SSLContext和自定义SSLServerSocketFactory？我在SparkServerImpl中搜索过但不知道如何注入sslfactory,有什么建议吗？

Answer 1

您可以直接将Spark的参数传递给Spark,如下所示:

Spark.secure(keyStorePath, keyStorePassword, trustStorePath, trustStorePassword);

这些都是字符串,例如,密钥库值可以是:

String keyStorePath = "/home/user/keys/private-key.jks";
String keyStorePassword = "password";

这样,Spark将具有在其中创建SslContextFactory的参数,如下所示:

https://github.com/perwendel/spark/blob/2.3/src/main/java/spark/webserver/jetty/SocketConnectorFactory.java#L68-L82