Akka-http中获取客户端IP

我正在尝试编写一个 Akka HTTP 微服务（akka 版本 2.4.11，Scala 版本 2.11.8，在撰写本文时都是最新版本），它知道客户端服务的 IP（即远程地址），但我无法得到这个上班。

我可以创建并运行一个显示“Hello！”的服务使用这样的路线：

    val routeHello: Route = path("SayHello") {
      get {
        entity(as[String]) {
          body => complete {
            HttpResponse(entity = HttpEntity("Hello!"))
          }
        }
      }
    }

我构建了一条与上面类似的路由，对其进行了扩展，以便它能够了解客户端的 IP 地址。

我注意到我需要编辑 application.conf 文件并设置“remote-address-header = on”以启用添加Remote-Address标头保存客户端（远程）IP 地址。我已经这样做了，以防万一需要。

这是路线：

    val routeHelloIp: Route = path("SayHelloIp") {
      get {
        // extractClientIp appears to be working as a filter
        // instead of an extractor - why?
        extractClientIp {
          clientIp => {
            entity(as[String]) {
              body => complete {
                HttpResponse(entity = HttpEntity("Hello!"))
              }
            }
          }
        }
      }
    }

但是，当我运行此路线时，我收到一条消息“找不到请求的资源。”。

看起来我在上面的示例中弄错了 Akka-http DSL 语法糖。如果您能让我走上正确的道路，我将不胜感激！

EDIT:

我已经尝试了以下程序来回应拉蒙的有用答案。不幸的是它无法编译，我看不到需要做什么才能编译它。

import akka.actor.ActorSystem
import akka.http.scaladsl.Http
import akka.http.scaladsl.Http.IncomingConnection
import java.net.InetSocketAddress
import akka.stream.ActorMaterializer
import akka.stream.scaladsl.Sink
import akka.http.scaladsl.server.Directives._
import java.net.InetSocketAddress


object TestHttp {
  def main(args: Array[String]) {

    implicit val system = ActorSystem("my-system")
    implicit val materializer = ActorMaterializer()

    // allow connections from any IP
    val interface = "0.0.0.0"

    //from the question
    def createRoute(address: InetSocketAddress) = path("SayHelloIp") {
      get {
        extractRequestEntity { entity =>
          entity(as[String]) { body =>
         complete(entity = s"Hello ${address.getAddress().getHostAddress()}")
          }
        }
      }
    }

    Http().bind(interface).runWith(Sink foreach { conn =>
  val address = conn.remoteAddress
   conn.handleWithAsyncHandler(createRoute(address))
    })
  }
}

我有以下 build.sbt 以确保使用最新版本的 Scala 和 akka-http：

import sbt.Keys._

name := "Find my IP"

version := "1.0"

scalaVersion := "2.11.8"

resolvers ++= Seq(
  "Typesafe Repository" at "http://repo.typesafe.com/typesafe/releases/"
)

libraryDependencies ++= {
  Seq(
    "com.typesafe.akka" %% "akka-actor" % "2.4.11",
    "com.typesafe.akka" %% "akka-stream" % "2.4.11",
    "com.typesafe.akka" %% "akka-http-experimental" % "2.4.11",
    "com.typesafe.akka" %% "akka-http-core" % "2.4.11"
  )
}

我收到以下编译时错误：

[error] /Users/tilopa/temp/akka-test/src/main/scala/Test.scala:24: akka.http.scaladsl.model.RequestEntity does not take parameters
[error]           entity(as[String]) { body =>
[error]                 ^
[error] /Users/tilopa/temp/akka-test/src/main/scala/Test.scala:25: reassignment to val
[error]             complete(entity = s"Hello ${address.getAddress().getHostAddress()}")
[error]                             ^
[error] two errors found
[error] (compile:compileIncremental) Compilation failed

使用 extractClientIp

extractClientIp不适合您，因为发件人未指定必需的标头字段之一。来自文档 http://doc.akka.io/docs/akka/2.4/scala/http/routing-dsl/directives/misc-directives/extractClientIP.html#extractclientip:

提供 X-Forwarded-For、Remote-Address 或 X-Real-IP 的值 headers 作为 RemoteAddress 的实例。

您只需在发件人中打开正确的设置：

akka-http 服务器引擎将 Remote-Address 标头添加到每个 如果相应的设置自动请求 akka.http.server.remote-address-header 设置为 on。默认情况下是 设置为关闭。

通用解决方案

如果您希望它适用于任何 HttpRequest，而不仅仅是具有正确标头设置的 HttpRequest，那么您必须使用bind上的方法HttpExt http://doc.akka.io/api/akka/2.4/?_ga=1.42089507.723935664.1469018756#akka.http.scaladsl.HttpExt代替bindAndHandle:

import akka.actor.ActorSystem
import akka.http.scaladsl.Http
import akka.http.scaladsl.Http.IncomingConnection

import java.net.InetSocketAddress

implicit val actorSystem : ActorSystem = ???
implicit val actorMat = ActorMaterializer()


//alow connections from any IP
val interface = "0.0.0.0"

//from the question
def createRoute(address : InetSocketAddress) = path("SayHelloIp") {
  get {
    extractRequestEntity { entity =>
      entity(as[String]) { body =>
        complete(entity = s"Hello ${address.getAddress().getHostAddress()}")
      }
    }
  }
}

Http().bind(interface).runWith(Sink foreach { conn =>
  val address =  conn.remoteAddress

  conn.handleWithAsyncHandler(createRoute(address))
})

Edit

正如评论中所述：自从 akka10.0.13 use conn.handleWith.