SpringBoot连接MQTT客户端

引入依赖

<dependency><groupId>org.eclipse.paho</groupId><artifactId>org.eclipse.paho.client.mqttv3</artifactId><version>1.2.2</version>
</dependency>

启动类

@SpringBootApplication
public class AxiosDemoApplication implements CommandLineRunner {@Autowiredprivate MqttService mqttService;public static void main(String[] args) {SpringApplication.run(AxiosDemoApplication.class, args);}@Overridepublic void run(String... args) throws Exception {// 在新线程中启动 MQTT 客户端new Thread(() -> mqttService.startMqttClient()).start();}
}

MqttServer类

这是一个类，要修改你的主题，ip，用户名密码等

package com.leo.springboothd.service;import com.leo.springboothd.OnMessageCallback;
import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
import org.eclipse.paho.client.mqttv3.MqttException;
import org.eclipse.paho.client.mqttv3.MqttMessage;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;@Service
public class MqttService {@Autowiredprivate OnMessageCallback onMessageCallback;public void startMqttClient() {String subTopic = "topic";  // 订阅的主题String pubTopic = "topic";String content = "Hello World66+6";int qos = 2;String broker = "tcp://ip";  // 你自己的 IPString clientId = "java";MemoryPersistence persistence = new MemoryPersistence();try {MqttClient client = new MqttClient(broker, clientId, persistence);// MQTT 连接选项MqttConnectOptions connOpts = new MqttConnectOptions();connOpts.setUserName("java");connOpts.setPassword("1234".toCharArray());// 保留会话connOpts.setCleanSession(true);// 建立连接System.out.println("Connecting to broker: " + broker);client.connect(connOpts);// 连接成功后设置回调client.setCallback(onMessageCallback);System.out.println("Connected");System.out.println("Publishing message: " + content);// 订阅client.subscribe(subTopic);// 消息发布所需参数MqttMessage message = new MqttMessage(content.getBytes());message.setQos(qos);client.publish(pubTopic, message);System.out.println("Message published");// 主循环，保持程序运行while (true) {try {Thread.sleep(1000); // 每秒检查一次} catch (InterruptedException e) {e.printStackTrace();}}} catch (MqttException me) {System.out.println("reason " + me.getReasonCode());System.out.println("msg " + me.getMessage());System.out.println("loc " + me.getLocalizedMessage());System.out.println("cause " + me.getCause());System.out.println("excep " + me);me.printStackTrace();}}
}

OnMessageCallback类

package com.leo.springboothd;import com.leo.springboothd.pojo.Mes;
import com.leo.springboothd.service.MesService;
import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.MqttCallback;
import org.eclipse.paho.client.mqttv3.MqttMessage;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;import java.time.LocalDateTime;@Component
public class OnMessageCallback implements MqttCallback {private final MesService mesService;@Autowiredpublic OnMessageCallback(MesService mesService) {this.mesService = mesService;}@Overridepublic void connectionLost(Throwable cause) {// 连接丢失后，一般在这里面进行重连System.out.println("连接断开，可以做重连");}@Overridepublic void messageArrived(String topic, MqttMessage message) throws Exception {// subscribe后得到的消息会执行到这里面System.out.println("接收消息主题: " + topic);System.out.println("接收消息Qos: " + message.getQos());System.out.println("接收消息内容: " + new String(message.getPayload()));// 将消息封装到 Mes 对象中Mes mes = new Mes();mes.setId((long) message.getId());mes.setTopic(topic);mes.setPayload(new String(message.getPayload()));mes.setQos(message.getQos());mes.setTimestamp(LocalDateTime.now());// 保存消息到数据库mesService.save(mes);}@Overridepublic void deliveryComplete(IMqttDeliveryToken token) {System.out.println("deliveryComplete---------" + token.isComplete());}
}

MesService接口

package com.leo.springboothd.service;import com.leo.springboothd.pojo.Mes;public interface MesService {void save(Mes mes);
}

MesService接口实现类

MesServiceImpl1
package com.leo.springboothd.service.impl;import com.leo.springboothd.mapper.MesMapper;
import com.leo.springboothd.pojo.Mes;
import com.leo.springboothd.service.MesService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;@Service
public class MesServiceImpl1 implements MesService {@Autowiredprivate MesMapper mesMapper;@Overridepublic void save(Mes mes) {mesMapper.save(mes);System.out.println(mes);}
}

 MesMapper

package com.leo.springboothd.mapper;import com.leo.springboothd.pojo.Mes;
import org.apache.ibatis.annotations.Insert;
import org.apache.ibatis.annotations.Mapper;@Mapper
public interface MesMapper {@Insert("INSERT INTO Message (id, topic, payload, qos, timestamp) VALUES (#{id}, #{topic}, #{payload}, #{qos}, #{timestamp})")void save(Mes mes);
}

数据库

CREATE TABLE Message (num BIGINT AUTO_INCREMENT PRIMARY KEY,id BIGINT NOT NULL,qos INT NOT NULL,topic VARCHAR(255) NOT NULL,payload TEXT NOT NULL,timestamp DATETIME NOT NULL
)COMMENT='订阅信息表';

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

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

相关文章

HTML：网页的骨架 — 入门详解教程

HTML：网页的骨架 — 入门详解教程

HTML&#xff1a;网页的骨架 — 入门详解教程 HTML&#xff08;HyperText Markup Language&#xff0c;超文本标记语言&#xff09;是构建网页的基础语言&#xff0c;负责定义网页的结构和内容。无论是简单的个人博客&#xff0c;还是复杂的企业网站&#xff0c;HTML都是不可或…
阅读更多...
212、【图论】字符串接龙（Python）

212、【图论】字符串接龙（Python）

题目描述 题目链接&#xff1a;110. 字符串接龙 代码实现 import collectionsn int(input()) beginStr, endStr input().split() strList [input() for _ in range(n)]deque collections.deque() # 使用队列遍历结点 deque.append([beginStr, 1]) # 存储当前字符串和遍…
阅读更多...
操作系统导论——第19章 分页：快速地址转换（TLB）

操作系统导论——第19章 分页：快速地址转换（TLB）

使用分页作为核心机制来实现虚拟内存&#xff0c;可能会带来较高的性能开销。使用分页&#xff0c;就要将内存地址空间切分成大量固定大小的单元&#xff08;页&#xff09;&#xff0c;并且需要记录这些单元的地址映射信息。因为这些映射信息一般存储在物理内存中&#xff0c;…
阅读更多...
使用Apache POI（Java）创建docx文档和表格

使用Apache POI（Java）创建docx文档和表格

1、引入poi 依赖组件 <dependency><groupId>org.apache.poi</groupId><artifactId>poi-scratchpad</artifactId><version>4.0.0</version> </dependency> <dependency><groupId>org.apache.poi</groupId>&…
阅读更多...
python cv2 安装

python cv2 安装

在Python中安装opencv-python&#xff08;即OpenCV库&#xff09;&#xff0c;通常有两种方法&#xff1a;使用pip命令或通过conda&#xff08;如果你使用的是Anaconda或Miniconda&#xff09;。以下是详细的步骤&#xff1a; 方法1&#xff1a;使用pip 打开你的命令行界面&am…
阅读更多...
读者、写者问题优化

读者、写者问题优化

#include <stdio.h> #include <time.h> #include <stdlib.h> #include <unistd.h> #include <pthread.h> #include <semaphore.h> #define NUM_READERS 5 #define NUM_WRITERS 5 // 定义信号量和全局变量 sem_t sdata, srcount; int rea…
阅读更多...
如何通过前端表格控件实现自动化报表？1

如何通过前端表格控件实现自动化报表？1

背景 最近伙伴客户的项目经理遇见一个问题&#xff0c;他们在给甲方做自动化报表工具&#xff0c;项目已经基本做好了&#xff0c;但拿给最终甲方&#xff0c;业务人员不太买账&#xff0c;项目经理为此也是天天抓狂&#xff0c;没有想到合适的应对方案。 现阶段主要面临的问…
阅读更多...
RabbitMQ 优先级队列详解

RabbitMQ 优先级队列详解

本文是博主在记录使用 RabbitMQ 在执行业务时遇到的问题和解决办法&#xff0c;因此查阅了相关资料并做了以下记载&#xff0c;记录了优先级队列的机制和使用要点。 本文为长文&#xff0c;详细介绍了相关的知识&#xff0c;可作为学习资料看。 文章目录 一、优先级队列介绍1、…
阅读更多...
代理模式简述

代理模式简述

目录 一、主要角色 二、类型划分 三、静态代理 示例 缺点 四、动态代理 JDK动态代理 示例 缺点 CGLib动态代理 导入依赖 示例 五、Spring AOP 代理模式是一种结构型设计模式&#xff0c;通过代理对象控制对目标对象的访问&#xff0c;可在不改变目标对象情况下增强…
阅读更多...
每日一题——云服务计费问题

每日一题——云服务计费问题

云服务计费问题&#xff08;哈希表 排序&#xff09;| 附详细 C源码解析 一、题目描述二、输入描述三、输出描述四、样例输入输出输入示例&#xff1a;输出示例&#xff1a;说明&#xff1a; 五、解题思路分析六、C实现源码详解&#xff08;完整&#xff09;七、复杂度分析 一…
阅读更多...
【JVM】运行时数据区域

【JVM】运行时数据区域

文章目录 1. 程序计数器补充 2. 虚拟机栈2.1 栈帧1. 局部变量表2. 操作数栈3. 动态链接4. 方法返回地址补充 3. 本地方法栈4. 堆5. 方法区静态常量池&#xff08;Class常量池&#xff09;运行时常量池字符串常量池&#xff08;1&#xff09;位置变化&#xff08;2&#xff09;放…
阅读更多...
day28图像处理OpenCV

day28图像处理OpenCV

文章目录 一、图像预处理4 边缘填充4.1 边界复制&#xff08;BORDER_REPLICATE&#xff09;4.2 边界反射&#xff08;BORDER_REFLECT&#xff09;4.3 边界反射101&#xff08;BORDER_REFLECT_101&#xff09;4.4 边界常数&#xff08;BORDER_CONSTANT&#xff09;4.5 边界包裹&…
阅读更多...
C++ Json-Rpc框架-3项目实现(2)

C++ Json-Rpc框架-3项目实现(2)

一.消息分发Dispatcher实现 Dispatcher 就是“消息分发中枢”&#xff1a;根据消息类型 MType&#xff0c;把消息派发给对应的处理函数&#xff08;Handler&#xff09;执行。 初版&#xff1a; #pragma once #include "net.hpp" #include "message.hpp"n…
阅读更多...
C++算法优化实战：破解性能瓶颈，提升程序效率

C++算法优化实战：破解性能瓶颈，提升程序效率

C算法优化实战&#xff1a;破解性能瓶颈&#xff0c;提升程序效率 在现代软件开发中&#xff0c;算法优化是提升程序性能的关键手段之一。无论是在高频交易系统、实时游戏引擎&#xff0c;还是大数据处理平台&#xff0c;算法的高效性直接关系到整体系统的性能与响应速度。C作…
阅读更多...
【PostgreSQL教程】PostgreSQL 特别篇之 语言接口连接PHP

【PostgreSQL教程】PostgreSQL 特别篇之 语言接口连接PHP

博主介绍：✌全网粉丝22W+，CSDN博客专家、Java领域优质创作者，掘金/华为云/阿里云/InfoQ等平台优质作者、专注于Java技术领域✌ 技术范围：SpringBoot、SpringCloud、Vue、SSM、HTML、Nodejs、Python、MySQL、PostgreSQL、大数据、物联网、机器学习等设计与开发。 感兴趣的可…
阅读更多...
山东大学软件学院创新项目实训开发日志（12）之将对话记录保存到数据库中

山东大学软件学院创新项目实训开发日志（12）之将对话记录保存到数据库中

在之前的功能开发中&#xff0c;已经成功将deepseekAPI接口接入到springbootvue项目中&#xff0c;所以下一步的操作是将对话和消息记录保存到数据库中 在之前的开发日志中提到数据库建表&#xff0c;所以在此刻需要用到两个表&#xff0c;conversation表和message表&#xff…
阅读更多...
Spring-注解编程

Spring-注解编程

注解基础概念 1.什么是注解编程 指的是在类或者方法上加入特定的注解(XXX) 完成特定功能的开发 Component public classXXX{} 2.为什么要讲注解编程 1.注解开发方便 代码简洁 开发速度大大提高 2.Spring开发潮流 Spring2.x引入注解 Spring3.x完善注解 Springboot普及 推广注解…
阅读更多...
Dify智能体平台源码二次开发笔记（5） - 多租户的SAAS版实现（2）

Dify智能体平台源码二次开发笔记（5） - 多租户的SAAS版实现（2）

目录 前言 用户的查询 controller层 添加路由 service层 用户的添加 controller层 添加路由 service层-添加用户 service层-添加用户和租户关系 验证结果 结果 前言 完成租户添加功能后&#xff0c;下一步需要实现租户下的用户管理。基础功能包括&#xff1a;查询租…
阅读更多...
基于若依的ruoyi-vue-plus的nbmade-boot在线表单的设计（一）架构方面的设计

基于若依的ruoyi-vue-plus的nbmade-boot在线表单的设计（一）架构方面的设计

希望大家一起能参与我的新开源项目nbmade-boot: 宁波智能制造低代码实训平台 主要目标是类似设计jeecgboot那样的online表单功能，因为online本身没有开源这部分代码，而我设计这个是完全开源的，所以希望大家支持支持，开源不容易。 1、数据库方面设计考虑 是在原来gen_table和…
阅读更多...
WebFlux应用中获取x-www-form-urlencoded数据的六种方法

WebFlux应用中获取x-www-form-urlencoded数据的六种方法

&#x1f9d1; 博主简介&#xff1a;CSDN博客专家&#xff0c;历代文学网&#xff08;PC端可以访问&#xff1a;https://literature.sinhy.com/#/?__c1000&#xff0c;移动端可微信小程序搜索“历代文学”&#xff09;总架构师&#xff0c;15年工作经验&#xff0c;精通Java编…
阅读更多...
最新文章

Copyright @ 2022~2023