如何将mqtt代理集成到springboot项目中

Question

如何将mqtt代理集成到spring-boot项目中

我曾经尝试过spring-boot-starter-activemq，但它是一个客户端，而不是代理

---

主要目的是在云mqtt代理和Intranet mqtt代理之间桥接消息，包括消息桥接和主题管理

Answer 1

消息代理服务器是独立的，因此Spring引导不提供mqtt代理的实现，仅使用带有Spring引导的消息代理客户端，您就可以连接到您的mqtt代理，如Mosqitto/VerneMq/RabbitMq等。

基于您的消息代理，您可以直接选择特定于代理的客户端库或您可以使用spring集成mqtt模块

<dependency>
<groupId>org.springframework.integration</groupId>
<artifactId>spring-integration-stream</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.integration</groupId>
<artifactId>spring-integration-mqtt</artifactId>
</dependency>

您可以根据自己的需求使用spring集成模块配置入站或出站实现，这将为您提供灵活性，使您可以从一个mqtt代理切换到另一个。

内部示例：

@SpringBootApplication
public class MqttJavaApplication {
public static void main(String[] args) {
new SpringApplicationBuilder(MqttJavaApplication.class)
.web(false)
.run(args);
}
@Bean
public IntegrationFlow mqttInbound() {
return IntegrationFlows.from(
new MqttPahoMessageDrivenChannelAdapter("tcp://localhost:1883",
"testClient", "topic1", "topic2");)
.handle(m -> System.out.println(m.getPayload()))
.get();
}
}

突出示例：

@SpringBootApplication
public class MqttJavaApplication {
public static void main(String[] args) {
new SpringApplicationBuilder(MqttJavaApplication.class)
.web(false)
.run(args);
}
@Bean
public IntegrationFlow mqttOutboundFlow() {
return f -> f.handle(new MqttPahoMessageHandler("tcp://host1:1883", "someMqttClient"));
}
}

您可以通过spring-boot集成mqtt模块文档了解更多详细信息。