Spring Integration 消息大小太大，如何拆分

Question

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

/A

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<YourMessage>：

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 将获取此列表并从列表中一一转发YourMessages。