Akka-http、JavaでクライアントIPを取得する

Question

akk-httpサービスを開始するための基本コードは次のとおりです。クライアントIPをルートハンドラに渡したいと思います。

... 
final Flow<HttpRequest, HttpResponse, NotUsed> myFlow= myRoute().flow(actorSystem, actorMaterializer); 

final CompletionStage<ServerBinding> binding = akkaHttp.bindAndHandle(myFlow, 
ConnectHttp.toHost(configurationInstance.getBindAddress(), configurationInstance.getBindPort()), actorMaterializer); 
... 

私はこの記事を見つけました：

Obtaining the client IP in Akka-http

それは低レベルのAPIを使用していますが。

今まで私はこれを手に入れましたが、低レベルのAPIに変更したくありません。高水準APIでこれを動作させる方法はありますか？ myRoute（）でコンパイルエラーが発生しましたが、このアプローチのハンドラをどのように作成できるかわかりません。

... 
      Http.get(system) 
        .bind(ConnectHttp.toHost(configurationInstance.getBindAddress(), 
         configurationInstance.getBindPort()), mat); 

      CompletionStage<ServerBinding> binding = 
        rverSource.runWith(Sink.foreach(connection -> { 
          connection.handleWithAsyncHandler( 
           myRoute(connection.remoteAddress()), mat); // ERROR 
       })).run(mat); 
... 
public Route finalRoute(InetSocketAddress client) { .... } 

- （UPDATE）これは、以下、ステファノBonettiからの助けを借りた後、働いていたものです。

ompletionStage<ServerBinding> binding = 
      serverSource.to(Sink.foreach(connection -> { 
        connection.handleWith(MyRoute(connection.remoteAddress()) 
        .flow(system, mat), mat); 
       } 
      )).run(mat); 

Answer 1

あなたはFlow[HttpRequest, HttpResponse, NotUsed]にあなたRouteを変換しhandleWith関数に渡すことができるはずです。

connection.handleWith(myRoute(connection.remoteAddress()).flow(actorSystem, mat), mat);