利用Spring Boot实现MQTT在物联网中的应用

news/2024/12/13 17:47:54/

在物联网(IoT)领域,消息队列遵循发布/订阅模型的MQTT(Message Queuing Telemetry Transport)协议变得越来越受欢迎。本文将深入探讨如何在Spring Boot中使用MQTT,并讨论其与其他中间件的集成以及在物联网中的应用场景。

1. MQTT在Spring Boot中的用法

1.1 引入依赖

首先,在Spring Boot项目中,需要添加MQTT依赖。在pom.xml文件中加入如下依赖:

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

1.2 配置MQTT连接

mqtt:broker: tcp://1.1.1.1:1883clientId: testusername: xxxxxpassword: xxxxxxxtopic: topic/#qos: 1

1.3 配置消息通道

@Configuration
public class MqttConfig {@Value("${mqtt.broker}")private String broker;@Value("${mqtt.clientId}")private String clientId;@Value("${mqtt.topic}")private String topic;@Value("${mqtt.username}")private String username;@Value("${mqtt.password}")private String password;@Value("${mqtt.qos}")private int qos;@Beanpublic DefaultMqttPahoClientFactory mqttClientFactory() {DefaultMqttPahoClientFactory factory = new DefaultMqttPahoClientFactory();MqttConnectOptions options = new MqttConnectOptions();options.setServerURIs(new String[]{broker});options.setUserName(username);options.setPassword(password.toCharArray());factory.setConnectionOptions(options);return factory;}@Beanpublic MessageChannel mqttInputChannel() {return new DirectChannel();}@Beanpublic MessageProducer inbound() {MqttPahoMessageDrivenChannelAdapter adapter =new MqttPahoMessageDrivenChannelAdapter(clientId + "_inbound", mqttClientFactory(), topic);adapter.setCompletionTimeout(5000);adapter.setQos(qos);adapter.setOutputChannel(mqttInputChannel());return adapter;}}

1.4 编写MQTT消息处理器

创建一个MQTT消息处理器类,用于处理接收到的消息:

@Component
public class MqttMessageHandler {@ServiceActivator(inputChannel = "mqttInputChannel")public void handleMqttMessage(@Header("mqtt_receivedTopic") String topic, Message<String> message) {// 获取消息主题System.out.println("Received MQTT message from topic " + topic + ": " + message.getPayload());// 在这里可以根据不同的主题执行不同的业务逻辑if ("topic1".equals(topic)) {// 处理来自 topic1 的消息} else if ("topic2".equals(topic)) {// 处理来自 topic2 的消息}}
}

2. MQTT与其他中间件的结合使用

除了在Spring Boot中使用MQTT,我们还可以将其与其他中间件集成,例如使用Apache Kafka实现消息的持久化存储,或者与RabbitMQ结合以实现更复杂的消息路由。

3. MQTT在物联网中的应用场景

3.1 传感器数据传输

MQTT可用于传感器数据的实时传输,传感器通过发布数据,而订阅者可以及时获取到数据并进行相应处理。

3.2 远程设备控制

通过MQTT,可以实现对远程设备的实时监控和控制,将控制命令发布到设备,设备接收并执行相应的操作。

3.3 资源监测与管理

在物联网中,对各类资源的监测和管理是至关重要的,MQTT提供了一种高效的方式来实现资源状态的实时更新和管理。

结论

通过Spring Boot集成MQTT,我们能够轻松实现在物联网中的消息传递。同时,结合其他中间件,我们可以构建更为复杂和健壮的物联网应用。MQTT在传感器数据传输、远程设备控制以及资源监测与管理等方面都有着广泛的应用,为物联网的发展提供了强大的支持。


http://www.ppmy.cn/news/1365114.html

相关文章

【vue】vue 是怎么把 template 模版编译成 render 函数的,什么是AST抽象语法树

什么是AST 抽象语法树 是一个对象/或者json是一个数据结构 AST通常是由多个节点组成的树状结构&#xff0c;每个节点代表一个语法单位或表达式。节点之间的关系通过父子关系或兄弟关系来表示程序的结构。在不同的编程语言和工具中&#xff0c;AST可能有不同的表示方式和节点类…

【深度学习笔记】深度卷积神经网络——NiN

网络中的网络&#xff08;NiN&#xff09; LeNet、AlexNet和VGG都有一个共同的设计模式&#xff1a;通过一系列的卷积层与汇聚层来提取空间结构特征&#xff1b;然后通过全连接层对特征的表征进行处理。 AlexNet和VGG对LeNet的改进主要在于如何扩大和加深这两个模块。 或者&am…

FPGA 与 数字电路的关系 - 这篇文章 将 持续 更新 :)

先说几个逻辑&#xff1a;&#xff08;强调一下在这篇文章 输入路数 只有 1个或2个&#xff0c;输出只有1个&#xff0c;N个输入M个输出以后再说&#xff09; 看下面的几个图&#xff1a; 图一&#xff08; 忘了 这是 啥门&#xff0c;不是门吧 &#xff1a;&#xff09;也就…

Swagger接口文档管理工具

Swagger 1、Swagger1.1 swagger介绍1.2 项目集成swagger流程1.3 项目集成swagger 2、knife4j2.1 knife4j介绍2.2 项目集成knife4j 1、Swagger 1.1 swagger介绍 官网&#xff1a;https://swagger.io/ Swagger 是一个规范和完整的Web API框架&#xff0c;用于生成、描述、调用和…

Day03:Web架构OSS存储负载均衡CDN加速反向代理WAF防护

目录 WAF CDN OSS 反向代理 负载均衡 思维导图 章节知识点&#xff1a; 应用架构&#xff1a;Web/APP/云应用/三方服务/负载均衡等 安全产品&#xff1a;CDN/WAF/IDS/IPS/蜜罐/防火墙/杀毒等 渗透命令&#xff1a;文件上传下载/端口服务/Shell反弹等 抓包技术&#xff1a…

迭代器模式(Iterator Pattern)

定义 迭代器模式&#xff08;Iterator Pattern&#xff09;是一种行为型设计模式&#xff0c;它提供了一种方法来顺序访问聚合对象中的各个元素&#xff0c;而不需要暴露该对象的内部表示。迭代器模式使得客户端代码能够独立于聚合对象的具体实现进行遍历操作。 在迭代器模式…

SD-WAN技术:优化国内外服务器访问的关键

在全球化的商业环境中&#xff0c;企业经常需要在国内访问国外的服务器。然而&#xff0c;由于地理位置和网络架构的限制&#xff0c;这种跨国访问往往会遇到速度慢、延迟高等问题。SD-WAN&#xff08;软件定义广域网&#xff09;技术的兴起&#xff0c;为企业提供了一种新的解…

sql 分割字段,并分行

创建测试表格 CREATE TABLE test (id INT PRIMARY KEY, data VARCHAR(100)); INSERT INTO test VALUES (1, A,B,C); INSERT INTO test VALUES (2, D,E,F,G);查询并分割字段 SELECT id, value AS split_data FROM test CROSS APPLY STRING_SPLIT(data, ,) WHERE LEN(value) …