按照在 GitHub https://github.com/spring-cloud/spring-cloud-gcp/tree/master/spring-cloud-gcp-samples/spring-cloud-gcp-pubsub-polling-binder-sample 中找到的关于从 PubSub 订阅轮询消息的示例，我想知道...
是否可以让PollableMessageSource 检索List<Message<?>> 而不是每次轮询的单个消息？
我看到@Poller 符号仅用于Source 类型化对象，从未用于Processor 或Sink。例如使用@StreamListener 或使用函数式方法时，是否可以在这种情况下使用？
【问题讨论】：
标签： spring-integration spring-cloud spring-cloud-stream
PollableMessageSource 绑定和Source 流应用程序完全基于 Spring Integration 的 Poller 和 MessageSource 抽象，其中它的合同是为配置的通道生成单个消息。消息传递的重点实际上是处理不影响其他人的单个消息。一条消息的失败并不意味着流程中的其他消息失败。
另一方面，您可能是指将 GCP Pub/Sub 消息作为 Spring 消息负载中的列表生成。这确实是可能的，但是通过来自 Pub/Sub 消费者和 MessageSource impl 的一些自定义代码。尽管我会三思而后行，期望从源头上批量处理。如果您的进一步逻辑是关于作为列表处理，您可能会使用聚合器来构建一些小窗口。但同样：这将是一条 Spring 消息。
开始考虑反应式函数实现可能会更好，您确实可以期望 Flux<Message<?>> 作为输入，Spring Cloud Stream 框架会照顾您如何将数据从 Pub/Sub 发送到您的反应式流中期待。
【讨论】：
Flux 仍然很热。因此，试图将其收集到一个列表中是行不通的。您可以考虑使用 `buffer()` 运算符，但这已经是另一回事了...