spring-integration-mqtt 定时发送消息

您可以使用 Spring Integration 提供的 `IntegrationFlowContext` 和 `IntegrationFlowRegistration` 来创建定时发送 MQTT 消息的 Spring 集成流程，并将其注册到应用程序中。以下是一个示例：

@Configuration
@EnableIntegration
public class MqttConfiguration {

    @Value("${mqtt.broker.url}")
    private String brokerUrl;

    @Value("${mqtt.client.id}")
    private String clientId;

    @Value("${mqtt.topic}")
    private String topic;

    @Autowired
    private IntegrationFlowContext flowContext;

    @Bean
    public MqttPahoClientFactory mqttClientFactory() {
        DefaultMqttPahoClientFactory factory = new DefaultMqttPahoClientFactory();
        MqttConnectOptions options = new MqttConnectOptions();
        options.setServerURIs(new String[]{brokerUrl});
        factory.setConnectionOptions(options);
        return factory;
    }

    @Bean
    public IntegrationFlow mqttOutFlow() {
        return IntegrationFlows.from(() -> "Hello, MQTT!", 
                e -> e.poller(Pollers.fixedRate(5000)))
                .handle(mqttOutbound())
                .get();
    }

    @Bean
    public MessageChannel mqttOutboundChannel() {
        return new DirectChannel();
    }

    @Bean
    public MessageHandler mqttOutbound() {
        MqttPahoMessageHandler messageHandler = new MqttPahoMessageHandler(clientId, mqttClientFactory());
        messageHandler.setAsync(true);
        messageHandler.setDefaultTopic(topic);
        return messageHandler;
    }

    @Bean
    public IntegrationFlowRegistration mqttOutFlowRegistration() {
        IntegrationFlowRegistration registration =
                this.flowContext.registration(mqttOutFlow())
                        .id("mqttOutFlow")
                        .register();
        return registration;
    }

}

在上面的代码中，我们创建了一个 `IntegrationFlow` 对象，并使用 `Pollers.fixedRate()` 方法将其配置为每隔 5 秒发送一条 MQTT 消息到指定的主题。我们还创建了一个 `MqttPahoMessageHandler` 对象，并将其配置为使用指定的客户端 ID、MQTT 客户端工厂和主题。最后，我们使用 `IntegrationFlowContext` 和 `IntegrationFlowRegistration` 将 `mqttOutFlow` 集成流程注册到应用程序中。通过运行应用程序，您可以在指定的频率下定时发送 MQTT 消息到指定的主题。