Spring集成使用Rest调用丰富/转换消息

Question

在Spring Integration中，我有如下消息:

{
  "name":"House",
  "attributeIds": [1,3,5]
}

我需要使用一些Rest服务来丰富/转换这个消息，这将为我提供属性值。

例如http://restservice.com/attributes?id=1，3,5会回答我

{"attributes": [
  {"id": 1, "value":"Waterproof"},
  {"id": 3, "value":"SoundProof"},
  {"id": 5, "value":"Concrete"}
]}

最后一个对象应如下所示：

{
  "name":"House",
  "attributes": [
    {"id": 1, "value":"Waterproof"},
    {"id": 3, "value":"SoundProof"},
    {"id": 5, "value":"Concrete"}
  ]
}

如何实现这一点？

应该是这样吗？https://www.youtube.com/watch?time_continue=273

入站适配器-

Answer 1

这确实是Content Enrich的典型任务。

因此，您需要将传入的JSON反序列化为一个普通的映射。使用＜code＞请求有效载荷表达式＝“payload.attributeIds”作为子流请求的有效载荷。

< code>request-channel上的订阅者可以只是简单的Spring Integration HTTP出站网关来调用REST服务并获得< code>attributes消息。该网关可以不带< code >输出通道通过< code>replyChannel头将其结果返回到< code >内容丰富器中。

当回复消息到达< code >内容丰富器时，一个简单的< code >

之后，您可以从该映射中删除属性 Ids 键，并在需要时将其序列化回 JSON。

更新

下面是一个使用Java DSL和Spring Boot的例子:https://github . com/artembilan/sandbox/tree/master/spring-integration-enricher