Eclipse Paho Mqtt - Spring Java 配置

Question

我想在我的 SpringMVC 项目中使用 MqTT。 In this link，官方例子，创建所有带new关键字的对象。据我所知，这不是 Spring 风格。推荐的创建 bean 的方法不是吗？

我找到了一些示例（spring-integration-mqtt，基于eclipse-paho-mqtt）配置为基于xml，但我想使其基于Java配置。我配置了整个项目 Java-based。项目中没有 .xml 文件（甚至 web.xml 也没有）。

如果您建议我使用 Java-config 的示例或有关将 xml-config 转换为 java-config 的好文档，我将不胜感激。

提前致谢。

Answer 1

您可以跟踪 Pull Request 此事，但让我在这里分享一段代码以跟踪更多信息：

@Bean
public MessageProducer inbound() {
    MqttPahoMessageDrivenChannelAdapter adapter =
            new MqttPahoMessageDrivenChannelAdapter("tcp://localhost:1883", "testClient",
                                             "topic1", "topic2");
    adapter.setCompletionTimeout(5000);
    adapter.setConverter(new DefaultPahoMessageConverter());
    adapter.setQos(1);
    adapter.setOutputChannel(mqttInputChannel());
    return adapter;
}

@Bean
@ServiceActivator(inputChannel = "mqttOutboundChannel")
public MessageHandler amqpOutbound() {
    MqttPahoMessageHandler messageHandler =
                   new MqttPahoMessageHandler("testClient", mqttClientFactory());
    messageHandler.setAsync(true);
    messageHandler.setDefaultTopic("testTopic");
    return messageHandler;
}

Eclipse Paho Mqtt - Spring Java 配置

Eclipse Paho Mqtt - Spring Java configuration

spring

spring-integration

mqtt

spring-java-config

paho