Reactor.core中未显式调用subscribe的Mono为何能正常运行？

一、为啥Sinks.One构建的Mono不用显式调用subscribe也能跑 #

你说的没错，Mono作为冷流，确实得订阅才会触发执行，但这段代码里的订阅是Spring WebFlux框架自动帮你做的。

看控制器里的valveOpen方法，它返回的是Mono<?>类型，Spring WebFlux处理响应式请求时，会自动给这个返回的Mono创建订阅，触发整个流的运行：

• 客户端调用/valveOpen接口时，WebFlux会订阅该方法返回的Mono
• 这个订阅会一路传递到ValveOpenSender.send里的逻辑，既会触发MQTT消息发送，也会让Sinks.One.asMono()对应的流进入等待设备响应的状态

说白了，不是没订阅，是框架替你做了这个步骤，不用手动写subscribe。

二、你看到的Mono.from描述对不对 #

这段描述大部分正确，但有个细节得掰清楚：

• 前半段没问题：Mono.from确实是把任意Publisher转成Mono的工厂方法，只会取第一个元素，后续的完成、错误信号都会被忽略
• 后半句里“这种转换不需要显式订阅”容易误解：冷流的特性是“订阅才启动”，不是不需要订阅，而是它不会主动发数据，必须有订阅者（比如WebFlux的自动订阅）触发，才会开始工作；而“冷流、单播，订阅时才产生信号，只为单个消费者分配资源”这点是对的，单播意味着这个Mono只能被一个订阅者订阅，重复订阅会报错

所以准确的理解是：Mono.from生成的是冷单播流，它不会主动产生数据，必须有订阅者触发，才会从源Publisher里取第一个元素传给订阅者。

内容的提问来源于stack exchange，提问作者acoder