我有几个关于 splitter
的基本问题SI 中的元素。
我知道要形成自定义的拆分器逻辑,我们需要扩展AbstractMessageSplitter
并覆盖 splitMessage
方法。
然后在 output-channel
上显示此拆分消息集合。的 splitter
(假设没有在传入消息上配置回复 channel )。output-channel
的 splitter
然后可以变成input-channel
对于另一个 si 组件。让我们假设组件是一个简单的 service-activator
.
该手册说集合的“每个”消息将由呈现此集合的下游配置处理。所以在我们的例子中,service-activator
将处理“每个”消息。
1) 我的查询是“ who ”精确迭代集合并在 service-activator 的输入 channel 上呈现来自集合的“ each ”消息?
2) 让我们假设这里涉及所有直接 channel 。现在如果output-channel
的 service-activato
r 配置为 nullChannel
,一旦成功处理了第一条消息,它还会显示来自集合的“下一个”消息吗?
3) 假设我们没有 aggregator
涉及到这里。另外让我们假设所有涉及的方法都有非空返回。
将返回给将“ 集合 ”消息呈现给拆分器的 output-channel
的调用者线程的内容?它会取回服务激活器返回的返回类型集合吗?或者它会从集合中返回最后处理的消息?
我希望我的查询足够详细,以使它们得到澄清。
非常感谢回复。
此致
最佳答案
是的。你问得很好!
1) AbstractMessageProducingHandler
:
protected void sendOutputs(Object result, Message<?> requestMessage) {
if (result instanceof Iterable<?> && shouldSplitOutput((Iterable<?>) result)) {
for (Object o : (Iterable<?>) result) {
this.produceOutput(o, requestMessage);
}
}
else if (result != null) {
this.produceOutput(result, requestMessage);
}
}
正是从这里每个项目被发送到
output-channel
.2) 是的,如果一切都在
DirectChannel
上, 下一条消息直到上一条消息完成才会发送。实际上,它的工作方式与原始 Java 中的工作方式相同: for (Object o : collection) {
}
注:在此
sync
如果当前消息处理失败,则不会发送下一个。因为Exception
.与原始 Java 完全一样:-)。3)嗯。使用原始 Java,它可能看起来像:
split(Collection<?>, Future<?>);
--->>
for (Object o : collection) {
process(Object, Future<?>)
}
这个过程正是在
splitter
中完成的。甚至在每个 EIP 组件中都更好。实际上所有这些都只在 中有效推模式。即使它对回复做了一些事情,它实际上也只是推送到replyChannel
.因此,如果您不注意回复过程,则只有第一条消息会填充对该
Future<?>
的回复。 - 在我们的例子中发送回复到 replyChannel
.是的,所有其他人都可以这样做,但回复将被忽略。见 TemporaryReplyChannel
源代码。请注意,如果您的下游拆分器进程是
async
,例如ExecutorChannel
作为 output-channel
在 <splitter>
没有预测回复中哪个消息是有罪的。因此,为了让您最满意地发送 Thread,您应该围绕这些拆分的消息找出一些足够的算法。甚至还有 <aggregator>
.我认为您最后一个问题的答案取决于目标业务逻辑要求。
关于null - Spring 集成 - 究竟是谁 "iterates"来自拆分器的拆分消息?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/33248979/