Java中SpringBoot组件集成接入【MQTT中间件】

- 1.MQTT介绍
- 2.搭建MQTT服务器
- - 1.Windows
  - 2.Ubuntu
  - 3.Docker
  - 4.其他方式
- 3.mqtt可视化客户端MQTTX及快速使用教程
- 4.SpringBoot接入MQTT
- - 1、maven依赖
  - 2、MQTT配置
  - 3、MQTT组件具体代码
  - - 1.定义通道名字
    - 2.消息发布器
    - 3.MQTT配置、生产者、消费者
    - 4.调用生产者像指定通道发布消息
    - 5.测试
    - - 1.先在客户端测试一下，可以看到mqtt服务是正常的
      - 2.调用生产者发布消息的接口，可以看到成功发布了
      - 3.从日志中也可以看到之前的消息都被程序接收到了，只需要在接收位置做业务逻辑即可
- 5.其他参考文章

1.MQTT介绍

MQTT（Message Queuing Telemetry Transport）是一种轻量级的发布/订阅消息传输协议，专门用于物联网（IoT）领域的通信。它旨在提供可靠且高效的消息传递机制，使设备和应用程序能够在低带宽、不稳定网络环境下进行实时通信。

MQTT协议采用了发布/订阅模式，其中包含两个主要角色：发布者（Publisher）和订阅者（Subscriber）。发布者负责将消息发布到特定的主题（Topic），而订阅者则通过订阅特定主题来接收相关消息。这种松耦合的通信方式使得系统能够轻松地扩展和管理。

MQTT协议具有以下特点：

轻量级：MQTT协议使用简单的二进制协议头，消息开销很小，适合在低带宽、低功耗设备上使用。
可靠性：MQTT支持确认和重传机制，确保消息在不稳定网络中的可靠传输。
异步通信：发布者和订阅者不需要互相了解对方的存在，使得系统更加松耦合。
灵活的消息过滤：订阅者可以使用通配符来过滤感兴趣的主题，灵活地选择接收哪些消息。
安全性：MQTT支持通过TLS/SSL协议进行加密传输，并且可以使用认证机制进行身份验证。

由于其轻量级和简单易用的特点，MQTT被广泛用于物联网场景中，如传感器数据采集、远程监控、智能家居等。

官方资料链接：

MQTT ORG
EMQX

2.搭建MQTT服务器

1.Windows

下载emqx-5.1.0-windows-amd64.zip，解压
命令行下进入解压路径，执行以下命令启动 emqx

./emqx/bin/emqx start

在这里插入图片描述

2.Ubuntu

1.通过以下命令配置 EMQX Apt 源：

curl -s https://assets.emqx.com/scripts/install-emqx-deb.sh | sudo bash

2.运行以下命令安装 EMQX：

sudo apt-get install emqx

3.运行以下命令启动 EMQX：

sudo systemctl start emqx

3.Docker

1.运行以下命令获取 Docker 镜像：

docker pull emqx/emqx:5.4.0

2.运行以下命令启动 Docker 容器。

docker run -d --name emqx -p 1883:1883 -p 8083:8083 -p 8084:8084 -p 8883:8883 -p 18083:18083 emqx/emqx:5.4.0

4.其他方式

在这里插入图片描述

参考：EMQX文档

3.mqtt可视化客户端MQTTX及快速使用教程

MQTTX下载地址：MQTT 5.0 客户端工具

快速使用教程参考文章：Windows版mqtt可视化客户端快速使用教程
在这里插入图片描述

4.SpringBoot接入MQTT

1、maven依赖

		<!--MQTT依赖库--><dependency><groupId>org.springframework.integration</groupId><artifactId>spring-integration-core</artifactId><version>5.4.2</version></dependency><dependency><groupId>org.springframework.integration</groupId><artifactId>spring-integration-mqtt</artifactId><version>5.5.5</version></dependency>

2、MQTT配置

在bootstrap.yml中增加MQTT配置信息，可根据自身情况修改相关字段

#是否启用MQTT服务
spring.mqtt.enable=true
#MQTT-服务端地址（本地服务器）
spring.mqtt.url=tcp://127.0.0.1:1883
#MQTT-服务端用户名
spring.mqtt.username=admin
#MQTT-服务端密码（本地服务器）
spring.mqtt.password=public
#MQTT-客户端clientid
spring.mqtt.clientid=test001
#MQTT-Warning默认主题
spring.mqtt.topicWarning=topic_warning

3、MQTT组件具体代码

在这里插入图片描述

1.定义通道名字

public class ChannelName {/*** 订阅的bean名称*/public static final String CHANNEL_NAME_IN = "mqttInboundChannel";/*** 发布的bean名称*/public static final String CHANNEL_NAME_OUT = "mqttOutboundChannel";
}

2.消息发布器

import com.funfan.autoCodeDemo.component.mqtt.model.ChannelName;
import org.springframework.integration.annotation.MessagingGateway;
import org.springframework.integration.mqtt.support.MqttHeaders;
import org.springframework.messaging.handler.annotation.Header;
import