アクター間でAkka HttpEntityを送信する

Question

akka-httpでは、HttpEntityボディー（Sourceを除く）を除き、akka-httpのHttpRequestとHttpResponseはほとんど不変オブジェクトです。

リクエスト、レスポンス、またはソリッドエンティティを別のアクタ（特にリモートアクタ）に送信することは安全ですか、または予防策が必要ですか？

Answer 1

コメントに記載されているとおり：HttpEntityをリモートActorに送信することは、ソケットの制限のためにうまくいかない可能性があります。さらなる証拠は、the documentation（強調かれら）で見つけることができます：

重要：メッセージは、オブジェクトの任意の種類であってもよいが 不変でなければならないことができます。 Scalaは（まだ）不変性を強制することはできませんので、これは の規則でなければなりません。延ByteStringは不変であるので、

しかし、Sourceから来るByteString値は、ソース自体と同じ制限がありません。単にローカルのakka-http ActorSystemでSourceを排水して、ByteStringの値をリモートのActorに送ることができます。

たとえば、utf-8ベースのHttpEntityのすべての文字を大文字にするには、Actorを使用するとします。

class UpperActor extends Actor { 
    override def receive : Receive = { 
    case b : ByteString => sender() ! b.toString.toUpperCase 
    } 
} 

のように次に、あなたのアッカ-HTTPは見ることができる：ソースはそのデータから来ているソケットのライフサイクルにバインドされている

val actorRef = ??? //setup the ref to remote UpperActor 

/**Query the Actor*/ 
val dispatchByteString : (ByteString) => Future[String] = 
    (byteString : ByteString) => (actorRef ? byteString).mapTo[String] 

val parallelism = 10 // should match your Actor's mailbox size 

/**Construct the Response Source.*/ 
val requestToSrc : (HttpRequest) => Source[ChunkStreamPart,_] = 
    (_ : HttpRequest).entity 
        .dataBytes 
        .mapAsync(parallelism)(dispatchByteString) 
        .map(ChunkStreamPart.apply) 

val contentType = ContentTypes.`text/plain(UTF-8)` 

val route = extractRequest { request => 
    complete(HttpResponse(entity = Chunked(contentType, requestToSrc(request)))) 
}