是否可以使轮询器(或PollableMessageSource)以列表形式轮询消息？

Question

按照在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<?>>，而不是每次轮询一条消息？

我见过只在Source类型的对象中使用@Poller表示法，而没有在Processor或Sink中使用。例如，当使用@StreamListener或函数方法时，是否可以在这样的上下文中使用？

Answer 1

PollableMessageSource绑定和Source流应用程序完全基于Spring Integration的Poller和MessageSource抽象，它的合同是向配置的通道生成单个消息。消息传递的重点实际上是处理单个消息，而不影响其他消息。一条消息的失败并不意味着流中的其他消息失败。

另一方面，您的意思可能是将GCP发布/订阅消息作为Spring消息有效负载中的列表生成。这确实是可能的，但通过来自发布/订阅消费者和MessageSource impl的一些自定义代码。尽管我会三思而后行，希望从源代码中获得一些批次。如果您进一步的逻辑是关于处理列表，那么您可能可以利用聚合器来构建一些小窗口。但是再说一次:这将是一个单一的Spring消息。

开始考虑反应式函数实现可能会更好，在这种实现中，您确实可以期待一个Flux<Message<?>>作为输入，Spring Cloud Stream框架将负责如何将数据从发布/订阅发送到您期望的反应式流中。

欲了解更多信息，请访问：https://docs.spring.io/spring-cloud-stream/docs/3.1.0/reference/html/spring-cloud-stream.html#_reactive_functions_support