在spark-java中使用https

Question

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

Answer 1

你可以直接进入星火密钥库的参数，如下所示：

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