助力消息传递，轻松玩转MQTT与SpringBoot

后端

2022-12-11 02:19:13

MQTT与SpringBoot携手，畅通物联网消息传递

MQTT 简介

万物互联时代，消息传递成为关键环节，而MQTT（消息队列遥测传输）协议因其轻量级、低开销、易于实现的特性而备受青睐。MQTT 基于发布/订阅模式，专为物联网设备设计，使用主题组织和传递消息，非常适用于物联网设备间的通信。

SpringBoot 概览

SpringBoot 是基于 Spring 框架的快速开发框架，简化了 Spring 项目的搭建、配置和部署。SpringBoot 集成大量常用工具，提升开发者效率，是 Java 开发者的首选。

MQTT 与 SpringBoot 集成

将 MQTT 与 SpringBoot 集成可轻松构建发送和接收 MQTT 消息的应用。具体步骤如下：

1. 添加 MQTT 依赖

使用 Maven 或 Gradle 添加 MQTT 相关依赖：

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

2. 配置 MQTT 连接

在 application.properties 或 application.yml 文件中配置 MQTT 连接信息：

spring.mqtt.host=localhost
spring.mqtt.port=1883
spring.mqtt.username=admin
spring.mqtt.password=password

3. 创建 MQTT 连接工厂

使用 MqttPahoClientFactory 创建 MQTT 连接工厂并注册为 Spring Bean：

@Bean
public MqttPahoClientFactory mqttPahoClientFactory() {
    DefaultMqttPahoClientFactory factory = new DefaultMqttPahoClientFactory();
    factory.setConnectionOptions(mqttConnectionOptions());
    return factory;
}

4. 创建 MQTT 模板

使用 MqttTemplate 作为 MQTT 消息发送和接收模板并注册为 Spring Bean：

@Bean
public MqttTemplate mqttTemplate() {
    MqttTemplate template = new MqttTemplate(mqttPahoClientFactory());
    template.setConnectionTimeout(30000);
    template.setReceiveTimeout(30000);
    return template;
}

5. 接收 MQTT 消息

通过 @Subscribe 注解或 MessageListenerAdapter 监听 MQTT 消息：

@Subscribe 注解方式：

@Subscribe(topic = "topic/test")
public void receive(String message) {
    System.out.println("Received message: " + message);
}

MessageListenerAdapter 方式：

@Bean
public MessageListenerAdapter messageListenerAdapter() {
    MessageListenerAdapter adapter = new MessageListenerAdapter(new MessageListener() {
        @Override
        public void onMessage(Message message) {
            System.out.println("Received message: " + message.getPayload());
        }
    });
    adapter.setDefaultTopic("topic/test");
    return adapter;
}

6. 发送 MQTT 消息

使用 MqttTemplate 发送 MQTT 消息：

mqttTemplate.publish("topic/test", "Hello MQTT!");

实战案例

创建一个简单的 SpringBoot 项目，演示 MQTT 与 SpringBoot 的集成：

项目结构：

├── src
│   ├── main
│   │   ├── java
│   │   │   ├── MqttApplication.java
│   │   │   ├── MqttController.java
│   │   │   ├── MqttListener.java
│   │   │   └── MqttService.java
│   │   └── resources
│   │       ├── application.properties
│   │       ├── logback.xml
│   └── test
└── pom.xml

运行项目：