@Bean 注解创建 MqttClient 对象并使用 subscribe() 方法获取

使用 @Bean 注解可以方便地创建 MqttClient 对象，并使用 subscribe() 方法来获取 MqttClient 对象。例如：

@Bean
public Mono<MqttClient> mqttClient() {
    return Mono.fromCallable(() -> {
        MqttClient mqttClient = new MqttClient(mqttPropertyConfig.getBroker(), MqttClient.generateClientId());
        MqttConnectOptions mqttConnectOptions = new MqttConnectOptions();
        mqttConnectOptions.setAutomaticReconnect(true);
        mqttConnectOptions.setUserName(mqttPropertyConfig.getUsername());
        mqttConnectOptions.setPassword(mqttPropertyConfig.getPassword().toCharArray());
        mqttClient.connect(mqttConnectOptions);
        return mqttClient;
    }).subscribeOn(Schedulers.boundedElastic());
}

在需要使用 MqttClient 对象的地方，可以使用 subscribe() 方法来获取 MqttClient 对象。例如：

@Autowired
private Mono<MqttClient> mqttClient;

public void someMethod() {
    mqttClient.subscribe(mqttClient -> {
        // 使用 MqttClient 对象
    });
}

在 subscribe() 方法的 lambda 表达式中，可以使用获取到的 MqttClient 对象进行相关操作。需要注意的是，由于 Mono 采用异步处理方式，因此在使用 MqttClient 对象时需要注意线程安全问题。