问Spring Cloud Stream和批量发送消息到队列
EN

Stack Overflow用户

提问于 2019-02-20 11:35:36

回答 1查看 262关注 0票数 0

我正在向我的消息队列发送消息，如下所示

 messages.forEach(message->
    sources.output().send(MessageBuilder.withPayload(message).build());

这些消息来自外部来源，可能有数千条。我见过拆分器，但它需要一个输入通道和输出通道，但我的消息是第一次进入队列，我只是生成不使用它们的消息，我不确定聚合器是如何工作的，或者对于这样一个简单的场景，它是否会太复杂。

因此，基本上我希望能够批量发送这些消息，而不是逐个发送。如何做到这一点呢？

发布于 2019-02-20 13:38:13

对于一些简单的事情，您可以收集并创建一个List数据(消息或仅仅是有效负载)，然后创建一条以List作为有效负载的消息并发送它。

要获得更具可配置性的方法，还可以使用Spring Integration Aggregator

票数 0

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/54778421

复制

相似问题

问Spring Cloud Stream和批量发送消息到队列EN