SpringBoot項目接入MQTT的詳細指南
更新時間：2025年03月05日 09:20:51 作者：ObjectNotFoundExc646
MQTT是一種輕量級的消息傳輸協議,特別適用于物聯網（IoT）場景,具有低帶寬、高延遲網絡環(huán)境下的優(yōu)勢,SpringBoot作為流行的 Java開發(fā)框架,能夠方便地與MQTT集成,實現高效的消息通信,本文將詳細介紹如何在SpringBoot項目中接入MQTT,需要的朋友可以參考下
一、引言
MQTT（Message Queuing Telemetry Transport）是一種輕量級的消息傳輸協議，特別適用于物聯網（IoT）場景，具有低帶寬、高延遲網絡環(huán)境下的優(yōu)勢。Spring Boot 作為流行的 Java 開發(fā)框架，能夠方便地與 MQTT 集成，實現高效的消息通信。本文將詳細介紹如何在 Spring Boot 項目中接入 MQTT。
二、環(huán)境準備
開發(fā)環(huán)境
- JDK 1.8 及以上版本
- Maven 3.x 或 Gradle
- Spring Boot 2.x 及以上版本
MQTT 服務器 可以選擇使用公共的 MQTT 服務器，如 HiveMQ 公共服務器（
tcp://broker.hivemq.com:1883），也可以自行搭建 Mosquitto 等 MQTT 服務器。
三、創(chuàng)建 Spring Boot 項目
可以使用 Spring Initializr（start.spring.io/）快速創(chuàng)建一個 Spring Boot 項目，添加以下依賴：
- Spring Web
- Spring for Apache Pulsar（因為 Pulsar 也支持 MQTT 協議，同時這里我們會使用其相關的 MQTT 依賴）
如果使用 Maven，pom.xml 中添加如下依賴：
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.integration</groupId>
<artifactId>spring-integration-mqtt</artifactId>
</dependency>
</dependencies>
解釋
url：MQTT 服務器的地址和端口。client-id：客戶端的唯一標識。default-topic：默認訂閱的主題。username和password：如果 MQTT 服務器需要認證，則填寫相應的用戶名和密碼。
五、創(chuàng)建 MQTT 配置類
創(chuàng)建一個配置類來配置 MQTT 連接和消息處理。
import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.integration.annotation.ServiceActivator;
import org.springframework.integration.channel.DirectChannel;
import org.springframework.integration.mqtt.core.DefaultMqttPahoClientFactory;
import org.springframework.integration.mqtt.core.MqttPahoClientFactory;
import org.springframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapter;
import org.springframework.integration.mqtt.outbound.MqttPahoMessageHandler;
import org.springframework.integration.mqtt.support.DefaultPahoMessageConverter;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.MessageHandler;
@Configuration
public class MqttConfig {
@Bean
public MqttPahoClientFactory mqttClientFactory() {
DefaultMqttPahoClientFactory factory = new DefaultMqttPahoClientFactory();
MqttConnectOptions options = new MqttConnectOptions();
options.setServerURIs(new String[]{"${spring.mqtt.url}"});
options.setUserName("${spring.mqtt.username}");
options.setPassword("${spring.mqtt.password}".toCharArray());
factory.setConnectionOptions(options);
return factory;
}
@Bean
public MessageChannel mqttInputChannel() {
return new DirectChannel();
}
@Bean
public MqttPahoMessageDrivenChannelAdapter inbound() {
MqttPahoMessageDrivenChannelAdapter adapter =
new MqttPahoMessageDrivenChannelAdapter("${spring.mqtt.client-id}", mqttClientFactory(),
"${spring.mqtt.default-topic}");
adapter.setCompletionTimeout(5000);
adapter.setConverter(new DefaultPahoMessageConverter());
adapter.setQos(1);
adapter.setOutputChannel(mqttInputChannel());
return adapter;
}
@Bean
@ServiceActivator(inputChannel = "mqttInputChannel")
public MessageHandler handler() {
return message -> {
System.out.println("Received message: " + message.getPayload());
};
}
@Bean
public MessageChannel mqttOutputChannel() {
return new DirectChannel();
}
@Bean
@ServiceActivator(inputChannel = "mqttOutputChannel")
public MessageHandler mqttOutbound() {
MqttPahoMessageHandler messageHandler =
new MqttPahoMessageHandler("${spring.mqtt.client-id}-publisher", mqttClientFactory());
messageHandler.setAsync(true);
messageHandler.setDefaultTopic("${spring.mqtt.default-topic}");
return messageHandler;
}
}
解釋
mqttClientFactory：創(chuàng)建 MQTT 客戶端工廠，配置連接選項。mqttInputChannel和mqttOutputChannel：定義消息通道，用于接收和發(fā)送消息。inbound：創(chuàng)建 MQTT 消息驅動的通道適配器，用于訂閱主題并接收消息。handler：處理接收到的 MQTT 消息。mqttOutbound：創(chuàng)建 MQTT 消息處理程序，用于發(fā)布消息。
六、發(fā)送和接收 MQTT 消息
發(fā)送消息
創(chuàng)建一個服務類來發(fā)送 MQTT 消息。
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.support.GenericMessage;
import org.springframework.stereotype.Service;
@Service
public class MqttMessageSender {
@Autowired
private MessageChannel mqttOutputChannel;
public void sendMessage(String message) {
mqttOutputChannel.send(new GenericMessage<>(message));
}
}
接收消息
在配置類中已經定義了消息處理邏輯，當接收到消息時，會在 handler 方法中進行處理。
七、測試 MQTT 連接
創(chuàng)建一個控制器來測試 MQTT 消息的發(fā)送。
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
@RestController
public class MqttController {
@Autowired
private MqttMessageSender mqttMessageSender;
@GetMapping("/send")
public String sendMessage(@RequestParam String message) {
mqttMessageSender.sendMessage(message);
return "Message sent: " + message;
}
}
啟動 Spring Boot 應用程序，訪問 http://localhost:8080/send?message=Hello, MQTT! 即可發(fā)送 MQTT 消息。
八、總結
通過以上步驟，我們成功地在 Spring Boot 項目中接入了 MQTT，實現了消息的發(fā)送和接收。MQTT 作為一種輕量級的消息傳輸協議，與 Spring Boot 的集成可以幫助我們快速構建高效、穩(wěn)定的物聯網消息通信系統(tǒng)。在實際應用中，可以根據需求進一步擴展和優(yōu)化，如增加消息持久化、多主題訂閱等功能。
以上就是SpringBoot項目接入MQTT的詳細指南的詳細內容，更多關于SpringBoot接入MQTT的資料請關注腳本之家其它相關文章！
相關文章
這篇文章主要介紹了Java泛型映射不同的值類型詳解及實例代碼的相關資料,需要的朋友可以參考下2017-02-02
很多時候我們需要根據不同的條件在容器中加載不同的Bean，或者根據不同的條件來選擇是否在容器中加載某個Bean，這就是Bean的加載控制，一般我們可以通過編程式或注解式兩種不同的方式來完成Bean的管理2023-01-01
這篇文章主要介紹了Java中的可變參數常見用法,結合實例形式總結分析了java可變參數的常見功能、使用方法及相關操作注意事項,需要的朋友可以參考下2019-10-10
本篇是針對構建 Maven 項目時可能出現的問題進行總結,并給出解決方法,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2026-03-03
《飛機大戰(zhàn)-II》是一款融合了街機、競技等多種元素的經典射擊手游。游戲是用java語言實現，采用了swing技術進行了界面化處理，感興趣的可以了解一下2022-02-02
這篇文章主要介紹了Java查找并高亮PDF文本過程解析,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2019-08-08
這篇文章主要介紹了springboot啟動時如何獲取端口和項目名，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-11-11
這篇文章主要為大家詳細介紹了Java實現銀行賬戶管理子系統(tǒng)，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2022-05-05
spring boot項目使用@JsonFormat失效問題的解決
這篇文章主要介紹了spring boot項目使用@JsonFormat失效問題的解決，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-11-11
七星彩是中國體育彩票的一種玩法，由中國國家體育總局體育彩票管理中心統(tǒng)一發(fā)行。本文為大家準備了一個七星彩號碼生成器Java工具類，感興趣的可以了解一下2022-08-08