Beanpublic MonoMqttClient mqttClient return MonofromCallable - MqttClient mqttClient = new MqttClientmqttPropertyConfiggetBroker MqttClientgenerateClientId; MqttConnectOptions mqttC
可以使用flatMap()方法将Mono
@Autowired
private Mono
public void doSomething() { mqttClientMono.flatMap(mqttClient -> { // 在这里使用MqttClient对象 return Mono.just(mqttClient); }).subscribe(); }
在上面的示例代码中,首先注入了一个Mono
原文地址: https://www.cveoy.top/t/topic/fh2W 著作权归作者所有。请勿转载和采集!