代码之家 › 专栏 › 技术社区 › gkatzioura

Akka Streams:添加一个执行和http请求的流

akka-http akka-stream

gkatzioura · 技术社区 · 6 年前

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

通过使用来自akka http(http()的流,这是可能的。outgoingConnection)还是应该在映射操作中执行请求?

1 回复 | 直到 6 年前

Ramón J Romero y Vigil 6 年前

这就是 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)

推荐文章

Falk Schuetzenmeister · Akka:如何在一个图形阶段提取值并在下一个图形阶段使用

6 年前

Teyu11 · Akka HTTP多文件上传到S3

6 年前

xDs · Alpakka MongoDB-在MongoSource中指定类型

6 年前

Roma Gafiyatullin · 阿克卡河。组合物化值。需要绘制未来地图。要使用哪个ExecutionContext/Dispatcher?

6 年前

apflieger · 如何在播放测试中从基于InputStream的结果中获取内容

7 年前

Jatin · 在project reactor或akka streams中,sink和subscriber在概念上有什么区别?

7 年前

stan · Scala RestartSink未来

7 年前

Alexander Arendar · 不完全了解来源。延迟方法或akka流文档中存在错误

7 年前

user3294786 · 使用Akka Http转换流畅的流数据并发送分块响应

7 年前

vgkowski · Akka流从外部世界获取无限流的当前值

7 年前