SpringIntegration消息大小太大，如何拆分

Question

我有一个带有 JMS 端点的 SprintIntegration 系统。消息的大小限制为 4mb。我的结果比这个大，我如何让 SI 将其分成几条消息？

/一个

Answer 1

在 Spring Integration 中，您可以使用 Splitter 用于将您的消息拆分为不超过 4MB。

<int:splitter id="splitter" 
              ref="splitterBean" 
              method="split" 
              input-channel="inputChannel" 
              output-channel="outputChannel" />

<beans:bean id="splitterBean" class="your.MessageSplitter"/>

或者使用 @Splitter 注释。

当消息进入拆分器时，您将在 your.MessageSplitter 中应用拆分逻辑，并返回一个 List：

public class MessageSplitter {

    public List<YourMessage> split( HugeMessage hugeMessage ) {

        List nicelySizedMessages = new ArrayList<YourMessage>();

        // splitting logic... that would parse "hugeMessage" and split it to
        // nicelySizedMessages.add( ... ) "YourMessage"s

        return nicelySizedMessages;
    }
}

Spring Integration 将获取此列表并返回从列表中一一转发 YourMessage。