Akka Streams：添加执行和 http 请求的流

Question

我有一个来自消息队列的 Akka 流源，例如 RabbitMq。对于我要执行http请求的每条消息，将http请求映射到一个对象，然后向下进行。

这是否可以通过使用来自 akka http (Http().outgoingConnection) 的流来实现，还是应该在映射操作中执行请求？

Answer 1

这正是 Http().outgoingConnection 的用途（如问题中所述）：

type MQMessage = ???

val messageToRequest : (MQMessage) => HttpRequest = ???

type ObjectType = ???

val responseToObjectType = (HttpResponse) => ObjectType = ???

val httpHost : String = ???

val messageFlow : Flow[MQMessage, ObjectType, _] = 
  Flow.map(messageToRequest)
      .via(Http().outgoingConnection(httpHost))
      .map(responseToObjectType)

Akka Streams：添加执行和 http 请求的流

Akka Streams: Add a flow which executes and http request

akka-stream

akka-http