如何在Spring Cloud Stream Aggregator处理器的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
}

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

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

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

使用如下所示的表达式：

 #this

作为聚合器的值。聚合属性创建一个负载，该负载是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

您可以用新java替换每个元素。util。ArrayList（#根）。获取（0）。负载等，但这相当难看（而且效率很低，因为您创建了一个新列表来获取每个元素）。我看看能不能想出更好的解决办法。

编辑2

也许这会接近你想要的。。。

#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中没有[]，在您的示例中就是这样）。