如何在Spring Cloud Stream聚合器处理器的aggregator.aggregation选项上使用SpEL表达式？

Question

我有三个独立的消息有效负载：

"id": "1234"

"type": "space-crite"

"attributes": {
  "ferocity": 10,
  "appetite": 10,
  "cuddliness": 0
}

我想使用Spring Cloud Stream aggregator-app-starter处理器将这三个消息有效负载合并为一个：

"id": "1234",
"type": "space-crite",
"attributes": {
  "ferocity": 10,
  "appetite": 10,
  "cuddliness": 0
}

通过使用聚合器处理器的aggregator.aggregation选项。文档指出，此属性的有效值是聚合策略的SpEL表达式，并且默认情况下它会生成有效负载的集合。aggregator processor的集成测试之一使用以下表达式：

#this.?[payload == 'foo'].![payload]

从"foo“和"bar”的单独有效负载生成"foo“的聚合消息。虽然这些测试非常有帮助，但文档中并没有提供很多关于如何在Spring Cloud Stream Starter Apps上下文中使用SpEL表达式的示例，这很遗憾，因为我知道我错过了一个非常强大的功能。

使用如下所示的表达式：

 #this

因为aggregator.aggregation属性的值创建了一个有效负载，它是GenericMessage对象的集合，每个对象都有自己的有效负载和标头属性。我希望创建一个大小为1的GenericMessage，它有一个包含3个传入消息的有效负载属性。

有没有人能给我举一些例子，告诉我如何在这个处理器选项中使用SpEL表达式？我正在尝试的事情是可能的吗？

Answer 1

假设有效载荷是字符串...

试试get(0).payload + get(1).payload + get(2).payload。

如果需要有效负载之间的换行符，请使用

T(String).format(get(0).payload + '%n' + get(1).payload + '%n' + get(2).payload)

编辑

不幸的是，聚合的#root对象是一个Collection<Message<?>>而不是一个List<Message<?>>，所以上面的方法不起作用。

您可以用new java.util.ArrayList(#root).get(0).payload等替换每个元素，但这相当难看(而且效率很低，因为您创建了一个新列表来获取每个元素)。我看看能不能想出一个更好的解决方案。

EDIT2

也许这会接近你想要的.

#root.![payload].toString()

测试：

MessageGroup g = new SimpleMessageGroup("foo");
g.add(new GenericMessage<>("foo"));
g.add(new GenericMessage<>("bar"));
Collection<Message<?>> messages = g.getMessages();
Expression e = new SpelExpressionParser().parseExpression(
        "#root.![payload].toString()");
System.out.println(e.getValue(messages));

产生

[foo, bar]

要删除大括号，请执行以下操作：

#root.![payload].toString().replaceAll('[\[\]]', '')

(只要您的JSON中没有[]，示例中就是这种情况)。