如何在Spring Cloud Stream聚合器处理器的aggregator.aggregation选项上使用SpEL表达式？
我有三个独立的消息有效负载：
"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表达式？我正在尝试的事情是可能的吗？
回答 1
Stack Overflow用户
发布于 2017-06-11 14:15:49
假设有效载荷是字符串...
试试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中没有[]，示例中就是这种情况)。
https://stackoverflow.com/questions/44483618
复制
腾讯云开发者
