在Spring Boot项目中集成和使用MQTT

在物联网（IoT）应用中，MQTT（消息队列遥测传输）协议因其轻量级和高效性被广泛使用。在Spring Boot项目中，我们可以通过集成org.springframework.integration:spring-integration-mqtt依赖来实现对MQTT的支持。本文将逐步介绍如何在Spring Boot应用中使用MQTT。

1. 添加依赖

首先，我们需要在项目的pom.xml文件中添加Spring Integration MQTT的依赖：

<dependencies><!-- Spring Boot Starter --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId></dependency><!-- Spring Integration MQTT --><dependency><groupId>org.springframework.integration</groupId><artifactId>spring-integration-mqtt</artifactId></dependency><!-- MQTT Client Library (Paho) --><dependency><groupId>org.eclipse.paho</groupId><artifactId>org.eclipse.paho.client.mqttv3</artifactId></dependency>
</dependencies>

2. 配置MQTT

在Spring Boot应用的配置文件application.properties中添加MQTT相关配置：

mqtt.broker.url=tcp://localhost:1883
mqtt.client.id=spring-boot-mqtt-client
mqtt.username=your-username
mqtt.password=your-password
mqtt.default.topic=your/topic

3. 创建MQTT配置类

创建一个新的配置类，用于配置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.core.MessageProducer;
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 {@Beanpublic MqttPahoClientFactory mqttClientFactory() {DefaultMqttPahoClientFactory factory = new DefaultMqttPahoClientFactory();MqttConnectOptions options = new MqttConnectOptions();options.setServerURIs(new String[] { "tcp://localhost:1883" });options.setUserName("your-username");options.setPassword("your-password".toCharArray());factory.setConnectionOptions(options);return factory;}@Beanpublic MessageChannel mqttInputChannel() {return new DirectChannel();}@Beanpublic MessageProducer inbound() {MqttPahoMessageDrivenChannelAdapter adapter =new MqttPahoMessageDrivenChannelAdapter("spring-boot-mqtt-client-inbound",mqttClientFactory(), "your/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 -> {String payload = (String) message.getPayload();System.out.println("Received message: " + payload);};}@Beanpublic MessageChannel mqttOutboundChannel() {return new DirectChannel();}@Bean@ServiceActivator(inputChannel = "mqttOutboundChannel")public MessageHandler mqttOutbound() {MqttPahoMessageHandler messageHandler =new MqttPahoMessageHandler("spring-boot-mqtt-client-outbound", mqttClientFactory());messageHandler.setAsync(true);messageHandler.setDefaultTopic("your/topic");return messageHandler;}
}

4. 发送和接收消息

在你的服务或控制器中，可以使用如下方法发送消息：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.integration.support.MessageBuilder;
import org.springframework.messaging.MessageChannel;
import org.springframework.stereotype.Service;@Service
public class MqttMessageSender {@Autowiredprivate MessageChannel mqttOutboundChannel;public void sendMessage(String topic, String payload) {mqttOutboundChannel.send(MessageBuilder.withPayload(payload).setHeader("mqtt_topic", topic).build());}
}

要接收消息，可以配置handler方法中的处理逻辑，或将消息发送到另一个Spring Integration通道进行进一步处理。

5. 使用示例

在一个控制器中调用发送消息方法：

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 {@Autowiredprivate MqttMessageSender mqttMessageSender;@GetMapping("/send")public String send(@RequestParam String topic, @RequestParam String message) {mqttMessageSender.sendMessage(topic, message);return "Message sent to topic " + topic;}
}

这样，你就可以通过HTTP请求发送MQTT消息了。例如，访问http://localhost:8080/send?topic=test/topic&message=Hello，将消息发送到MQTT主题test/topic。

这就是一个完整的Spring Boot应用中集成MQTT的简单示例，希望对你有所帮助！

MQTT报文头介绍

MQTT协议的请求报文头非常轻量级。MQTT协议定义了固定报文头和可变报文头两部分。以下是各类报文的基本格式：

固定报文头

所有MQTT报文都有一个固定报文头，占据2-5个字节。固定报文头包含报文类型和一些控制标志。

固定报文头格式

  • 第一个字节:

    • 位7-4：报文类型（Message Type）
    • 位3-0：标志（Flags），根据报文类型不同而不同

  • 第二个字节及后续字节:

    • 剩余长度（Remaining Length），表示剩余报文的字节数。采用可变长度编码，每个字节的最高位用于指示是否有后续字节。
各类报文示例

连接报文（CONNECT）

连接报文用于客户端请求与服务器建立连接。其报文头如下：

  • 固定报文头:

    • 第一个字节：0x10（CONNECT报文类型是1，标志位为0000）
    • 第二个字节：剩余长度（根据可变部分长度而定）

  • 可变报文头:

    • 协议名（“MQTT”）
    • 协议级别（4，表示MQTT 3.1.1）
    • 连接标志（Connect Flags）
    • 保持连接时间（Keep Alive）

  • 有效载荷:

    • 客户端标识符（Client Identifier）
    • 用户名（可选）
    • 密码（可选）
    • 遗嘱主题（可选）
    • 遗嘱消息（可选）

连接确认报文（CONNACK）

服务器响应客户端的连接请求。其报文头如下：

  • 固定报文头:

    • 第一个字节：0x20（CONNACK报文类型是2，标志位为0000）
    • 第二个字节：剩余长度（2字节）

  • 可变报文头:

    • 连接确认标志（0x00或0x01）
    • 返回码（0表示连接成功，其他值表示错误）

发布报文（PUBLISH）

客户端或服务器发送消息到指定主题。其报文头如下：

  • 固定报文头:

    • 第一个字节：0x30（PUBLISH报文类型是3，标志位根据QoS等级、重复标志和保留标志变化）
    • 第二个字节：剩余长度（根据主题名、消息ID和消息体长度而定）

  • 可变报文头:

    • 主题名（Topic Name）
    • 消息ID（QoS等级为1或2时需要）

  • 有效载荷:

    • 消息内容

示例

以下是一个PUBLISH报文的示例：

30 0B                # 固定报文头 (PUBLISH，QoS 0)
00 05                # 主题名长度
74 6F 70 69 63       # 主题名 "topic"
68 65 6C 6C 6F       # 消息内容 "hello"

在这个示例中：

  • 第一个字节 0x30 表示这是一个PUBLISH报文，QoS等级为0，重复标志和保留标志为0。
  • 第二个字节 0x0B 表示剩余长度为11个字节。
  • 接下来的两个两个字节 0x00 0x05 表示主题名的长度为5个字节。
  • 接下来的5个字节 0x74 0x6F 0x70 0x69 0x63 表示主题名 “topic”。
  • 最后5个字节 0x68 0x65 0x6C 0x6C 0x6F 表示消息内容 “hello”。

这种结构使得MQTT报文非常紧凑和高效，特别适合物联网设备的通信。希望这篇文章能帮助你更好地理解和使用MQTT协议。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/839370.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

Android 日志等级设置

Android 日志等级设置

一、LOG等级设置 1、Java设置 系统Log等级 public static final String LOG_CMD_TAG = "persist.log.tag";public static void setSystemLogLevel(String level) {Log.d(TAG, "setSystemLogLevel: " + level);SystemProperties.set(LOG_CMD_TAG, level)…
阅读更多...
计算机专业实习生应该去哪实习？

计算机专业实习生应该去哪实习？

计算机专业实习生可以选择在各种不同类型的公司和组织中实习。我这里有一套编程入门教程&#xff0c;不仅包含了详细的视频讲解&#xff0c;项目实战。如果你渴望学习编程&#xff0c;不妨点个关注&#xff0c;给个评论222&#xff0c;私信22&#xff0c;我在后台发给你。 这取…
阅读更多...
Harmony学习笔记一——项目创建及配置

Harmony学习笔记一——项目创建及配置

文章基于Harmony Next Preview2 进行学习&#xff0c;其他版本可能会稍有不同 准备工作 由于目前Harmony Next仅有Preview版本&#xff0c;想要进行Harmony Next开发需要向华为申请权限&#xff0c;具体操作参考: https://developer.huawei.com/consumer/cn/forum/topic/02081…
阅读更多...
MySQL查询---单、多表实例

MySQL查询---单、多表实例

目录 一、素材准备 建表 插入数据&#xff1a; 二、单表查询 三、多表查询 要求&#xff1a; 步骤&#xff1a; 1、建立新的数据库db_calss&#xff0c;以及按照要求建立student表 2.查看已经建立表的属性&#xff0c;并按照要求修改年龄字段属性 3.按照要求建立SC表 …
阅读更多...
AI播客下载：Create Like the Greats（主题是AI和市场营销）

AI播客下载：Create Like the Greats（主题是AI和市场营销）

《Create Like the Greats》是由Ross Simmonds主持的播客&#xff0c;旨在深入探讨创业、创造过程中的各种问题和挑战。该播客专注于揭示成功创作者的背后故事和策略。 该播客的第一集详细讲述了MasterClass如何建立起一个价值28亿美元的教育科技帝国。这一集不仅展示了Master…
阅读更多...
数据科学的守护者：数据治理与安全在大规模数据提取项目中的角色

数据科学的守护者：数据治理与安全在大规模数据提取项目中的角色

数据科学的守护者&#xff1a;数据治理与安全在大规模数据提取项目中的角色 随着数据科学的迅猛发展&#xff0c;大规模数据提取项目已成为企业、研究机构和政府等各个领域不可或缺的一部分。然而&#xff0c;伴随着数据的快速增长和复杂性的增加&#xff0c;数据治理与安全问…
阅读更多...
stm32学习-光敏传感器控制蜂鸣器

stm32学习-光敏传感器控制蜂鸣器

接线 GPIO配置 初始化GPIO 1.使用RCC开启GPIO时钟 void RCC_APB2PeriphClockCmd(uint32_t RCC_APB2Periph, FunctionalState NewState); 作用&#xff1a;外设时钟控制(根据外设连接的总线选择要开启的时钟&#xff09; RCC_AHBPeriph/RCC_APB2Periph/RCC_APB1Periph&#x…
阅读更多...
视觉里程计的融合方法及优缺点分析

视觉里程计的融合方法及优缺点分析

视觉里程计是视觉slam的一部分&#xff0c;即前端部分&#xff0c;用于前端跟踪并建立局部地图。多用于重定位或辅助定位&#xff0c;常用的有特征点法&#xff0c;光流法和直接法&#xff0c;其区别和优缺点如下。 特征点法&#xff0c;需要计算特征点和描述子&#xff0c;计算…
阅读更多...
Qt 文件模型（QFileSystemModel）详细介绍

Qt 文件模型（QFileSystemModel）详细介绍

一.定义 Qt提供了QFileSystemModel类&#xff0c;用于在Qt应用程序中展示文件系统的数据。QFileSystemModel类是QAbstractItemModel的子类&#xff0c;可以方便地将文件系统的文件和文件夹结构作为数据模型&#xff0c;供Qt的视图类&#xff08;比如QTreeView、QListView等&…
阅读更多...
5、HTTP header注入（详解）

5、HTTP header注入（详解）

1、知识补充 本篇主要演示user-Agent和Cookie注入 以下是一些可能的HTTP header注入点&#xff1a; User-Agent: 有些网站可能会记录并分析访问者的User-Agent字符串以了解用户的浏览器和设备信息。如果这些信息被用于动态生成SQL查询&#xff0c;并且没有进行适当的输入验证或…
阅读更多...
卡到BUG了：删除重发白得积分（以前删除会扣减积分）

卡到BUG了：删除重发白得积分（以前删除会扣减积分）

以前是&#xff1a;删除文章&#xff0c;积分减少&#xff0c;点赞积分减少&#xff0c;从回收站回复文章&#xff0c;积分恢复&#xff0c;点赞数恢复但点赞积分不恢复。也就是删除重发总积分减少点赞的积分&#xff0c;有损失。 今天是&#xff1a;删除文章&#xff0c;积分不…
阅读更多...
【Android】Gradle插件全局配置/Gradle插件下载源配置

【Android】Gradle插件全局配置/Gradle插件下载源配置

gradle插件概念 gradle发行包和gradle插件是两个东西&#xff0c;可以理解为maven版本与maven依赖项的关系。gradle插件由项目路径中的build.gradle文件进行管理&#xff0c;相当于pom.xmlsettings.xml&#xff0c;同时记录依赖项和依赖仓库。是一个依赖项&#xff0c;从指定仓…
阅读更多...
检索增强生成RAG的概念及参考架构

检索增强生成RAG的概念及参考架构

大家好&#xff0c;自ChatGPT火爆以来&#xff0c;大语言模型&#xff08;LLMs&#xff09;驱动的智能应用如雨后春笋般涌现&#xff0c;迅速改变了我们与世界互动的方式。在众多智能AI应用架构中&#xff0c;RAG&#xff08;检索增强生成&#xff09;架构以其独特的优势和强大…
阅读更多...
MySQL数据库单表查询中查询条件的写法

MySQL数据库单表查询中查询条件的写法

1.使用比较运算符作为查询条件 ; !; >; >; <; <; 如上图所示&#xff0c;可以使用命令select 字段&#xff0c;字段 from 表名 where Gender “M”; 即挑选出Gender “M” 的教师&#xff0c; 如上图所示&#xff0c;可以使用命令select 字段&#xff0c;…
阅读更多...
Python | Leetcode Python题解之第107题二叉树的层序遍历II

Python | Leetcode Python题解之第107题二叉树的层序遍历II

题目&#xff1a; 题解&#xff1a; class Solution:def levelOrderBottom(self, root: TreeNode) -> List[List[int]]:levelOrder list()if not root:return levelOrderq collections.deque([root])while q:level list()size len(q)for _ in range(size):node q.popl…
阅读更多...
QT7_视频知识点笔记_4_文件操作，Socket通信：TCP/UDP

QT7_视频知识点笔记_4_文件操作，Socket通信：TCP/UDP

1.事件分发器&#xff0c;事件过滤器&#xff08;重要程度&#xff1a;一般&#xff09; event函数 2.文件操作&#xff08;QFile&#xff09; 实现功能&#xff1a;点击按钮&#xff0c;弹出对话框&#xff0c;并且用文件类读取出内容输出显示在控件上。 #include <QFi…
阅读更多...
bclinux基于欧拉（BigCloud Enterprise Linux For Euler）下安装mysql5.7

bclinux基于欧拉（BigCloud Enterprise Linux For Euler）下安装mysql5.7

第一步&#xff1a;下载mysql5.7的rpm安装包 下载地址&#xff1a;https://dev.mysql.com/downloads/mysql/ 第二步&#xff1a;上传mysql安装包到Centos7的下 第三步&#xff1a;检查是否已经安装了mysql或者mariadb&#xff08;centos7默认安装&#xff09;&#xff0c;如已…
阅读更多...
如何在 Git 中处理和解决分支合并冲突？

如何在 Git 中处理和解决分支合并冲突？

在Git中&#xff0c;当两个或多个分支尝试合并&#xff0c;而它们对同一个文件的同一部分进行了不同的修改时&#xff0c;就可能会发生合并冲突。解决这些冲突是合并过程中一个重要的步骤。以下是如何在Git中处理和解决分支合并冲突的基本步骤&#xff1a; 拉取并合并分支&…
阅读更多...
Python 渗透测试：GhostScript 沙箱绕过.（CVE-2018-16509）

Python 渗透测试：GhostScript 沙箱绕过.（CVE-2018-16509）

什么是 GhostScript 沙箱绕过 GhostScript 沙箱是一种安全机制,用于在受控环境中运行 GhostScript 解释器,以防止恶意代码的执行。GhostScript 是一个广泛使用的 PDF 和 PostScript 解释器,通常用于在服务器上处理和渲染这些文件格式。Tavis Ormandy 通过公开邮件列表&#xf…
阅读更多...
14.js数组

14.js数组

是一种复杂数据类型&#xff0c;有序的数据集合 数组一般存放多个个例的不同数据&#xff0c;对象一般存放一个个例的不同信息 数组创建 &#xff08;1&#xff09;字面量创建 var 数组名[ ] &#xff08;2&#xff09;内部构造函数创建 var 数组名new Array() 创建指定长度的数…
阅读更多...
最新文章

Copyright @ 2022~2023