一文搞懂MQTT，如何在SpringBoot中使用MQTT实现消息的订阅和发布

**MQTT入门与SpringBoot集成**

###什么是MQTT？

MQTT（Message Queuing Telemetry Transport）是一种轻量级、可扩展的机器间通信协议，主要用于物联网(IoT)应用。它设计用于在低带宽环境下传输数据，适合于设备之间的通信。

### MQTT特点* **轻量级**:MQTT协议非常简单，仅需要少量的资源和带宽。
* **可扩展**:MQTT支持高达256个主题（Topic）以及多个客户端订阅同一个主题。
* **低延迟**:MQTT使用发布-订阅模式，消息可以立即传递给订阅者。

### MQTT应用场景* **物联网(IoT)**:MQTT用于连接设备、传输数据和控制设备。
* **智能家居**:MQTT用于实现智能家居的自动化功能，如灯光控制、温度调节等。
* **工业互联网**:MQTT用于监控生产线设备、传递生产数据等。

### 在SpringBoot中使用MQTT####依赖配置首先，我们需要在pom.xml文件中添加MQTT相关的依赖：

xml<dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-mqtt</artifactId>
</dependency>

propertiesspring:
 mqtt:
 host: localhost port:1883 username: admin password: admin

javaimport org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
import org.springframework.integration.mqtt.core.DefaultMqttTemplate;

@SpringBootApplicationpublic class MqttApplication {

 public static void main(String[] args) {
 SpringApplication.run(MqttApplication.class, args);
 }

 @Bean public DefaultMqttTemplate mqttTemplate() {
 return new DefaultMqttTemplate("tcp://localhost:1883");
 }
}

javaimport org.springframework.integration.annotation.MqttListener;
import org.springframework.integration.mqtt.core.MqttMessage;

@SpringBootApplication@EnableMqttpublic class MqttApplication {

 public static void main(String[] args) {
 SpringApplication.run(MqttApplication.class, args);
 }

 @Bean public DefaultMqttTemplate mqttTemplate() {
 return new DefaultMqttTemplate("tcp://localhost:1883");
 }

 @MqttListener(topic = "hello")
 public void receiveMessage(MqttMessage message) {
 System.out.println("Received message: " + message.toString());
 }
}

javaimport org.springframework.integration.annotation.MqttSender;
import org.springframework.integration.mqtt.core.DefaultMqttTemplate;

@SpringBootApplication@EnableMqttpublic class MqttApplication {

 public static void main(String[] args) {
 SpringApplication.run(MqttApplication.class, args);
 }

 @Bean public DefaultMqttTemplate mqttTemplate() {
 return new DefaultMqttTemplate("tcp://localhost:1883");
 }

 @MqttSender(topic = "hello")
 public void sendMessage(String message) {
 System.out.println("Sending message: " + message);
 }
}