我在为下一个全局用例创建/建模集成流时遇到了一个问题：
系统的输入是某种信息。该消息通过splitter和transformer端点，然后在serviceactivator上处理转换后的消息。这个用例对我来说很清楚。
由于下一部分，出现了混乱。serviceactivator完成处理后，我需要再次获取基本消息（来自第一部分开头的消息）并将其放入其他处理中，例如再次通过拆分器和转换器。我如何对用例建模？我可以将消息负载返回到该基本值吗？有什么能帮我的吗？
希望我能描述得很好。
我在为下一个全局用例创建/建模集成流时遇到了一个问题：
系统的输入是某种信息。该消息通过splitter和transformer端点，然后在serviceactivator上处理转换后的消息。这个用例对我来说很清楚。
由于下一部分，出现了混乱。serviceactivator完成处理后，我需要再次获取基本消息（来自第一部分开头的消息）并将其放入其他处理中，例如再次通过拆分器和转换器。我如何对用例建模？我可以将消息负载返回到该基本值吗？有什么能帮我的吗？
希望我能描述得很好。
1条答案
按热度按时间nnsrf1az1#
你的用例听起来更像一个
PublishSubscribeChannel: https://docs.spring.io/spring-integration/docs/current/reference/html/core.html#channel-实现publishsubscribechannel。因此，您将有多个订阅服务器（拆分器）用于该通道，并且将在这些独立的子流中处理相同的输入消息。如果配置Executor就这样PublishSubscribeChannel.另一种方法是，如果您可以并行地这样做，并且仍然需要serviceactivator的一些结果与下一个端点的原始消息一起可用，那么您可以使用
HeaderEnricher要将原始消息存储在标题中，请在流中需要时随时访问它：https://docs.spring.io/spring-integration/docs/current/reference/html/message-transformation.html#header-恩里彻