springboot整合mqtt实现消息订阅和推送

前言

mica-mqtt-client-spring-boot-starter是一个基于Spring Boot的MQTT客户端启动器，它集成了mica-mqtt客户端，提供了在Spring Boot应用程序中使用MQTT协议进行消息通信的能力。以下是关于mica-mqtt-client-spring-boot-starter的简介：

特点：

  • 简单易用：通过Spring Boot的自动配置，可以轻松地集成到Spring应用程序中，并使用Spring的注解或Java配置进行MQTT客户端的配置。

  • 低延迟：支持MQTT协议，能够实现实时消息通信，具有较低的延迟。

  • 高性能：基于mica-mqtt客户端，具有高效的消息处理和网络通信能力，能够处理大量的并发连接和消息。

  • 集群支持：支持基于Redis的发布/订阅模式的集群，可以实现多个节点之间的消息同步和负载均衡。

  • 使用场景：适用于需要使用MQTT协议进行消息通信的物联网、实时应用、移动应用等领域。可以在云端或边缘端使用，实现设备与设备之间、设备与服务器之间的消息通信。

  • 集成方式：通过在Spring Boot项目中添加相关依赖，并配置MQTT客户端的相关参数，即可快速集成mica-mqtt-client-spring-boot-starter。具体的使用方法可以参考官方文档和示例代码。

  • 注意事项：在使用过程中需要注意确保网络连接的稳定性和安全性，并根据实际需求进行适当的配置和优化。同时，也需要关注数据安全和隐私保护等方面的问题。

总之，mica-mqtt-client-spring-boot-starter是一个方便、高效、可靠的MQTT客户端启动器，适用于需要使用MQTT协议进行消息通信的Spring Boot应用程序。

功能

  • 支持 MQTT v3.1、v3.1.1 以及 v5.0 协议。

  • 支持 websocket mqtt 子协议（支持 mqtt.js）。

  • 支持 http rest api，http api 文档详见[1]。

  • 支持 MQTT client 客户端。

  • 支持 MQTT server 服务端。

  • 支持 MQTT client、server 共享订阅支持（捐助VIP版采用 topic 树存储，跟 topic 数无关，百万 topic 性能依旧）。

  • 支持 MQTT 遗嘱消息。

  • 支持 MQTT 保留消息。

  • 支持自定义消息（mq）处理转发实现集群。

  • MQTT 客户端 阿里云 mqtt 连接 demo。

  • 支持 GraalVM 编译成本机可执行程序。

  • 支持 Spring boot 项目快速接入（mica-mqtt-spring-boot-starter）。

  • mica-mqtt-spring-boot-starter 支持对接 Prometheus + Grafana。

  • 基于 redis pub/sub 实现集群，详见 mica-mqtt-broker 模块[2]

教程

添加依赖

在springboot项目中添加maven依赖：

        <!-- https://mvnrepository.com/artifact/net.dreamlu/mica-mqtt-client-spring-boot-starter --><dependency><groupId>net.dreamlu</groupId><artifactId>mica-mqtt-client-spring-boot-starter</artifactId><version>2.2.8</version></dependency>

配置参数

在spring配置文件中配置mqtt相关参数，配置如下：

mqtt:server:    enabled: false              # 是否开启服务端，默认：falseclient:enabled: true               # 是否开启客户端，默认：falseip: 172.16.10.203   # 连接的服务端 ip ，默认：127.0.0.1port: 1883                  # 端口：默认：1883name: Mica2-Mqtt2-Client      # 名称，默认：Mica-Mqtt-ClientclientId: coalface_safety_3d            # 客户端Id（非常重要，一般为设备 sn，不可重复）user-name: admin           # 认证的用户名 你的用户名password: 3@!cHy@j       # 认证的密码timeout: 5                  # 连接超时时间，单位：秒，默认：5秒reconnect: true             # 是否重连，默认：truere-interval: 5000           # 重连时间，默认 5000 毫秒version: MQTT_3_1           # mqtt 协议版本，默认：3.1.1read-buffer-size: 8092      # 接收数据的 buffer size，默认：8092max-bytes-in-message: 8092  # 消息解析最大 bytes 长度，默认：8092buffer-allocator: heap      # 堆内存和堆外内存，默认：堆内存keep-alive-secs: 60         # keep-alive 心跳维持时间，单位：秒clean-session: false         # mqtt clean session，默认：truewill-message:                # 消息遗嘱qos: at_least_oncessl:enabled: false            # 是否开启 ssl 认证，2.1.0 开始支持双向认证keystore-path:            # 可选参数：ssl 双向认证 keystore 目录，支持 classpath:/ 路径。keystore-pass:            # 可选参数：ssl 双向认证 keystore 密码truststore-path:          # 可选参数：ssl 双向认证 truststore 目录，支持 classpath:/ 路径。truststore-pass:          # 可选参数：ssl 双向认证 truststore 密码
  • 注意：ssl 存在三种情况
服务端开启ssl客户端
ClientAuth 为 NONE（不需要客户端验证）仅仅需要开启 ssl 即可不用配置证书
ClientAuth 为 OPTIONAL（与客户端协商）需开启 ssl 并且配置 truststore 证书
ClientAuth 为 REQUIRE (必须的客户端验证)需开启 ssl 并且配置 truststore、 keystore证书

创建订阅

创建一个mqtt订阅消息监听类，例如SimulationSubscriber，代码如下：


import com.alibaba.fastjson.JSONObject;
import net.dreamlu.iot.mqtt.spring.client.MqttClientSubscribe;
import org.springframework.messaging.handler.annotation.Header;
import org.springframework.messaging.handler.annotation.Payload;
import org.springframework.stereotype.Component;
import org.tio.utils.buffer.ByteBufferUtil;/*** @author tarzan*/
@Component
@Slf4j
public class SimulationSubscriber {@MqttClientSubscribe("tuoyuan/publish/zj/#")public void zjOne(String topic, byte[] payload){String[] strs=topic.split("/");String ID=strs[strs.length-1];log.info("topic:{} payload:{} ID:{}", topic, new String(payload, StandardCharsets.UTF_8),ID);}@MqttClientSubscribe("/sys/${deviceName}/thing/sub/register")public void thingSubRegister(String topic, byte[] payload) {// 1.3.8 开始支持，@MqttClientSubscribe 注解支持 ${} 变量替换，会默认替换成 +// 注意：mica-mqtt 会先从 Spring boot 配置中替换参数 ${}，如果存在配置会优先被替换。logger.info("topic:{} payload:{}", topic, new String(payload, StandardCharsets.UTF_8));}@MqttClientSubscribe("/tianma/publish/cmj")public void cmj(@Header("topic") String topic,@Payload byte[] payload) {System.out.println("*****************gc**************************************"+topic);JSONObject jsonObject = JSONObject.parseObject(ByteBufferUtil.toString(payload));//业务的处理System.out.println("*****************test**************************************"+jsonObject);}@MqttClientSubscribe("/tianma/publish/zj")public void zj(@Header("topic") String topic,@Payload byte[] payload) {System.out.println("*****************gc**************************************"+topic);JSONObject jsonObject = JSONObject.parseObject(ByteBufferUtil.toString(payload));//业务的处理System.out.println("*****************test**************************************"+jsonObject);}@MqttClientSubscribe("/tianma/publish/gbj")public void gbj(@Header("topic") String topic,@Payload byte[] payload) {System.out.println("*****************gc**************************************"+topic);JSONObject jsonObject = JSONObject.parseObject(ByteBufferUtil.toString(payload));//业务的处理System.out.println("*****************test**************************************"+jsonObject);}@MqttClientSubscribe("/tianma/publish/ltl")public void ltl(@Header("topic") String topic,@Payload byte[] payload) {System.out.println("*****************gc**************************************"+topic);JSONObject jsonObject = JSONObject.parseObject(ByteBufferUtil.toString(payload));//业务的处理System.out.println("*****************test**************************************"+jsonObject);}@MqttClientSubscribe("/tianma/publish/ntl")public void ntl(@Header("topic") String topic,@Payload byte[] payload) {System.out.println("*****************gc**************************************"+topic);JSONObject jsonObject = JSONObject.parseObject(ByteBufferUtil.toString(payload));//业务的处理System.out.println("*****************test**************************************"+jsonObject);}@MqttClientSubscribe("/tianma/publish/ccl")public void ccl(@Header("topic") String topic,@Payload byte[] payload) {System.out.println("*****************gc**************************************"+topic);JSONObject jsonObject = JSONObject.parseObject(ByteBufferUtil.toString(payload));//业务的处理System.out.println("*****************test**************************************"+jsonObject);}}

  • @Header(“topic”) 和@Payload 注解可以省略

  • tuoyuan/publish/zj/# 中的# 是通配符

    • 在MQTT协议中，#是一个通配符，代表匹配该主题的所有子主题。例如，如果你订阅了主题sports/baseball/#，那么你将接收到所有以sports/baseball/开头的主题的消息。

    • 请注意，通配符#只能用于多层的主题名称中，并且只能用于最后一个级别。例如，sports/baseball/#是有效的，但#sports/baseball或sports/#/baseball都是无效的。

    • 除了#之外，MQTT协议还支持一个单层通配符+，它代表只匹配该级别的主题。例如，如果你订阅了主题sports/baseball/+，那么你将只接收到以sports/baseball/开头，且后面跟着至少一个字符的主题的消息。

    • 请注意，使用通配符时需要谨慎，因为它们可能会匹配到意外的主题。确保你的订阅主题明确，并且只匹配你感兴趣的主题。

  • /sys/${deviceName}/thing/sub/register

    • 1.3.8 开始支持，@MqttClientSubscribe 注解支持 ${} 变量替换，会默认替换成 +
    • 注意：mica-mqtt 会先从 Spring boot 配置中替换参数 ${}，如果存在配置会优先被替换。

创建发布

创建一个mqtt消息发布接口类，例如 MqttTestController，代码如下：


import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import net.dreamlu.iot.mqtt.spring.client.MqttClientTemplate;
import org.springblade.core.secure.annotation.NoToken;
import org.springblade.core.tool.api.R;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;import java.nio.charset.StandardCharsets;/*** @author tarzan*/
@RestController
@Api(tags = "mqtt测试")
@NoToken
@RequestMapping("/mqtt")
@AllArgsConstructor
@Slf4j
public class MqttTestController {private final MqttClientTemplate mqttClientTemplate;@ApiOperation(value = "消息发送")@PostMapping("/publish")private R<Boolean> publish(String topic, String msg) {return R.status(mqttClientTemplate.publish(topic, msg.getBytes(StandardCharsets.UTF_8)));}}

接口测试

接口调用
在这里插入图片描述
控制台输出
在这里插入图片描述

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

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

相关文章

dvwa靶场xss储存型

dvwa靶场xss储存型

xss储存型 xxs储存型lowmessage框插入恶意代码name栏插入恶意代码 medium绕过方法 high xxs储存型 攻击者事先将恶意代码上传或储存到漏洞服务器中&#xff0c;只要受害者浏览包含此恶意代码的页面就会执行恶意代码。产生层面:后端漏洞特征:持久性的、前端执行、储存在后端数据…
阅读更多...
03 Redis之命令（基本命令+Key命令+String型Value命令与应用场景）

03 Redis之命令（基本命令+Key命令+String型Value命令与应用场景）

Redis 根据命令所操作对象的不同&#xff0c;可以分为三大类&#xff1a;对 Redis 进行基础性操作的命令&#xff0c;对 Key 的操作命令&#xff0c;对 Value 的操作命令。 3.1 Redis 基本命令 一些可选项对大小写敏感, 所以应尽量将redis的所有命令大写输入 首先通过 redis-…
阅读更多...
【C项目】顺序表

【C项目】顺序表

简介&#xff1a;本系列博客为C项目系列内容&#xff0c;通过代码来具体实现某个经典简单项目 适宜人群&#xff1a;已大体了解C语法同学 作者留言&#xff1a;本博客相关内容如需转载请注明出处&#xff0c;本人学疏才浅&#xff0c;难免存在些许错误&#xff0c;望留言指正 作…
阅读更多...
初识webpack（一）概念、入口配置、输出配置、loader等

初识webpack（一）概念、入口配置、输出配置、loader等

目录 (一)概念 webpack的依赖图 (二)webpack的基本使用 (三)webpack的配置文件 1.入口(entry)配置 2.输出(output)配置 (三)loader 1.css文件处理 (1)安装css-loader和style-loader (2)在webpack.config.js中配置loader 2.less文件处理 3.postcss的使用 (1)安装…
阅读更多...
python爬虫之豆瓣首页图片爬取

python爬虫之豆瓣首页图片爬取

网址&#xff1a;https://movie.douban.com/ import requests from lxml import etree import re url https://movie.douban.com headers {User-Agent : Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/114.0.5735.289 Safari/5…
阅读更多...
代理IP在游戏中的作用有哪些？

代理IP在游戏中的作用有哪些？

游戏代理IP的作用是什么&#xff1f;IP代理软件相当于连接客户端和虚拟服务器的软件“中转站”&#xff0c;在我们向远程服务器提出需求后&#xff0c;代理服务器首先获得用户的请求&#xff0c;然后将服务请求转移到远程服务器&#xff0c;然后将远程服务器反馈的结果转移到客…
阅读更多...
redis 极简分布式锁实现

redis 极简分布式锁实现

写在前面 工作中遇到&#xff0c;整理 reids 做简单分布式锁的思考博文适合刚接触 redis 的小伙伴理解不足小伙伴帮忙指正 对每个人而言&#xff0c;真正的职责只有一个&#xff1a;找到自我。然后在心中坚守其一生&#xff0c;全心全意&#xff0c;永不停息。所有其它的路都是…
阅读更多...
Flutter 开发3：创建第一个Flutter应用

Flutter 开发3：创建第一个Flutter应用

Step 1: 安装Flutter 1.1 下载Flutter SDK 首先&#xff0c;你需要访问Flutter官方网站下载最新的Flutter SDK。选择适合你操作系统的安装包。 $ cd ~/development $ unzip ~/Downloads/flutter_macos_2.2.3-stable.zip1.2 更新环境变量 接下来&#xff0c;你需要将Flutter…
阅读更多...
Git 介绍 与 配置

Git 介绍 与 配置

Git 介绍 Git是一个分布式版本控制系统&#xff0c;用于跟踪文件的更改和协作开发。它可以管理项目的版本历史记录&#xff0c;并允许多个开发者在同一时间进行并行开发。 解决上图产生的问题就出现了git 分布式版本控制系统 看下图 Git 配置 Git的基本配置包括用户名和电子邮…
阅读更多...
人脸识别 FaceNet人脸识别（一种人脸识别与聚类的统一嵌入表示）

人脸识别 FaceNet人脸识别（一种人脸识别与聚类的统一嵌入表示）

人脸识别 FaceNet人脸识别&#xff08;一种人脸识别与聚类的统一嵌入表示&#xff09; FaceNet的简介Facenet的实现思路训练部分 FaceNet的简介 Facenet的实现思路 import torch.nn as nndef conv_bn(inp, oup, stride 1):return nn.Sequential(nn.Conv2d(inp, oup, 3, stride…
阅读更多...
Netty源码二：服务端创建NioEventLoopGroup

Netty源码二：服务端创建NioEventLoopGroup

示例 还是拿之前启动源码的示例&#xff0c;来分析NioEventLoopGroup源码 NioEventLoopGroup构造函数 这里能看到会调到父类的MultiThread EventLoopGroup的构造方法 MultiThreadEventLoopGroup 这里我们能看到&#xff0c;如果传入的线程数目为0&#xff0c;那么就会设置2倍…
阅读更多...
JDBC 结构优化2

JDBC 结构优化2

JDBC 结构优化2 文章目录 JDBC 结构优化2结构优化2 - ATM系统(存,取,转,查)1 Service2 事务3 ThreadLocal4 事务的封装 结构优化2 - ATM系统(存,取,转,查) 1 Service 什么是业务? 代表用户完成的一个业务功能&#xff0c;可以由一个或多个DAO的调用组成。软件所提供的一个功…
阅读更多...
[NCTF2019]Fake XML cookbook(特详解)

[NCTF2019]Fake XML cookbook(特详解)

先试了一下弱口令&#xff0c;哈哈习惯了 查看页面源码发现xml function doLogin(){var username $("#username").val();var password $("#password").val();if(username "" || password ""){alert("Please enter the usern…
阅读更多...
数据据库八之 视图、触发器、事务

数据据库八之 视图、触发器、事务

【零】准备数据 【1】创建表 &#xff08;1&#xff09;部门表 d_id是部门的编号d_name是部门的名字 # 确保表不存在 drop table if exists department; # 创建表 create table department( d_id int auto_increment primary key, d_name varchar(6) )auto_increment 501 …
阅读更多...
腾讯云部署vue+node项目

腾讯云部署vue+node项目

文章目录 一、安装宝塔二、vue项目部署三、node项目部署 前言: 关于项目部署,一开始也是找了很多资料,费了点时间,所以记录一下。希望能对各位有所帮助。 一、安装宝塔 1.首先在控制台,进入云服务器的终端界面 2.输入命令和密码获取权限,并且安装宝塔界面 yum install -y w…
阅读更多...
如何把png改成jpg格式？分享5个好用的方法！

如何把png改成jpg格式？分享5个好用的方法！

你是否经常遇到需要将PNG格式的图片转换成JPG格式的情况&#xff1f;无论是因为工作需要&#xff0c;还是为了适应不同的平台和设备&#xff0c;格式转换都是我们经常要面对的问题。那么&#xff0c;如何快速、简单地完成这个任务呢&#xff1f;今天&#xff0c;我们就来为你揭…
阅读更多...
计算机网络——IP协议

计算机网络——IP协议

前言 网络层的主要负责地址分配和路由选择,ip负责在网络中进行数据包的路由和传输。 IPv4报文组成&#xff08;了解&#xff09; IPv4首部&#xff1a;IPv4首部包含了用于路由和传输数据的控制信息&#xff0c;其长度为20个字节&#xff08;固定长度&#xff09;。 版本&#…
阅读更多...
图灵之旅--ArrayList顺序表LinkedList链表栈Stack队列Queue

图灵之旅--ArrayList顺序表LinkedList链表栈Stack队列Queue

目录 线性表顺序表ArrayList简介ArrayList使用ArrayList的构造ArrayList常见操作ArrayList的遍历ArrayList的扩容机制利用ArrayList洗牌ArrayList的优缺点 链表链表的实现双向链表的实现 LinkedListLinkedList引入LinkedList的使用LinkedList的构造LinkedList的常用方法介绍Lin…
阅读更多...
Power ModeII 插件的下载与使用-----idea

Power ModeII 插件的下载与使用-----idea

下载 Marketplace里面搜索下载即可 使用 下载后重启软件就可以用了 下面是一些关于Power ModeII &#xff0c;我的个性化设置截图 以及相关设置解释 插件或扩展的设置面板【用于给代码编辑器或集成开发环境&#xff08;IDE&#xff09;添加视觉效果】 主要设置 ENTER POWE…
阅读更多...
Maven安装，学习笔记，详细整理maven的一些配置

Maven安装，学习笔记，详细整理maven的一些配置

Maven 1. 初识Maven 2. Maven概述 Maven模型介绍 Maven仓库介绍 Maven安装与配置 3. IDEA集成Maven 4. 依赖管理 01. Maven课程介绍 1.1 课程安排 学习完前端Web开发技术后&#xff0c;我们即将开始学习后端Web开发技术。做为一名Java开发工程师&#xff0c;后端 Web开发技术…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023