1

https を使用してスプレー クライアントを制限付きの REST API に接続しようとしています。問題は、リモート サーバーの証明書が信頼済みとして登録されていないことです。単純な Get() 接続が SSLHandshakeException で拒否され、これを機能させる方法に関する情報を見つけるのに苦労しています。これは、何かを変更する必要なく、ローカルマシンから何らかの形で機能します。

証明書をjvmトラストストアに入れる方法に関するチュートリアルを見つけましたが、dokku/dockerを使用しているため、知る限りjvmインスタンスはコンテナ固有です(または?)。将来、アプリケーションを別のマシンに再デプロイする可能性がありますが、毎回 jvm を設定するのではなく、アプリケーションで定義したいと考えています。

プログラムで SSL に直面するのはこれが初めてなので、SSL がどのように機能するかについて間違った仮定をしている可能性があります。手伝ってくれますか？

4

2 に答える 2

1

安全でない方法でそれをやりたいだけの場合、これが私の2セントです。HttpRequestの代わりに（HttpRequest、HostConnectorSetup）を送信するsendReceiveメソッドを作成するだけです

import java.security.SecureRandom
import java.security.cert.X509Certificate
import javax.net.ssl.{SSLContext, TrustManager, X509TrustManager}

import akka.actor.ActorRefFactory
import akka.io.IO
import akka.pattern.ask
import akka.util.Timeout
import spray.can.Http
import spray.can.Http.HostConnectorSetup
import spray.client.pipelining._
import spray.http.{HttpResponse, HttpResponsePart}
import spray.io.ClientSSLEngineProvider
import spray.util._

import scala.concurrent.ExecutionContext
import scala.concurrent.duration._


object Test {
  // prepare your sslContext and engine Provider
  implicit lazy val engineProvider = ClientSSLEngineProvider(engine => engine)

  implicit lazy val sslContext: SSLContext = {
    val context = SSLContext.getInstance("TLS")
    context.init(null, Array[TrustManager](new DummyTrustManager), new SecureRandom)
    context
  }

  private class DummyTrustManager extends X509TrustManager {

    def isClientTrusted(cert: Array[X509Certificate]): Boolean = true

    def isServerTrusted(cert: Array[X509Certificate]): Boolean = true

    override def getAcceptedIssuers: Array[X509Certificate] = Array.empty

    override def checkClientTrusted(x509Certificates: Array[X509Certificate], s: String): Unit = {}

    override def checkServerTrusted(x509Certificates: Array[X509Certificate], s: String): Unit = {}
  }

  // rewrite sendReceiveMethod fron spray.client.pipelining
  def mySendReceive(implicit refFactory: ActorRefFactory, executionContext: ExecutionContext,
                    futureTimeout: Timeout = 60.seconds): SendReceive = {
    val transport =  IO(Http)(actorSystem)
    // HttpManager actually also accepts Msg (HttpRequest, HostConnectorSetup)
    request =>
      val uri = request.uri
      val setup = HostConnectorSetup(uri.authority.host.toString, uri.effectivePort, uri.scheme == "https")
      transport ? (request, setup) map {
        case x: HttpResponse          => x
        case x: HttpResponsePart      => sys.error("sendReceive doesn't support chunked responses, try sendTo instead")
        case x: Http.ConnectionClosed => sys.error("Connection closed before reception of response: " + x)
        case x                        => sys.error("Unexpected response from HTTP transport: " + x)
      }
  }

  // use mySendReceive instead spray.client.pipelining.sendReceive
}
于 2016-07-10T13:06:36.817 に答える