不要将消息标记为使用Spring Cloud Stream在反应式功能中已确认

哈罗德·布朗（Harold L.Brown）：

我正在使用spring-cloud-stream带有Java 13的Horsham SR1版本。我正在使用Google Pub / Sub作为基础消息系统。

我有一个Function类似这样的反应式：

@Bean
public Function<Flux<Message>, Mono<Void>> messageConsumer() {
    return messageFlux ->
            messageFlux
                    .flatMap(message -> {
                        // do something
                        return something;
                    })
                    .doOnError(throwable -> log.error("could not process  message", throwable))
                    .then();
}

我怎样才能让Spring 不承认错误消息呢？在flatMap方法内部抛出异常是否足够？

奥列格·朱拉库斯基（Oleg Zhurakousky）：

您必须了解每种方法都有优点和缺点，而在反应性方面我们看不到流程。它完全在您的控制之下。实际上，主要区别之一是上述函数仅被调用一次，如果它是命令性函数，则它将在每条消息上被调用。

基本上，使用反应式用户可以有效地将操作单位声明为整个流（无论在您的应用程序上下文中可能意味着什么）。势在必行，操作单元是单个消息，因此我们可以执行按消息发送的小节，小节等。

本文收集自互联网，转载请注明来源。

如有侵权，请联系 [email protected] 删除。