连接HiveMQ代理器实现MQTT协议传输

先下载MQTTX: MQTTX: Your All-in-one MQTT Client Toolbox

使用线上免费的MQTTX BROKER:The Free Global Public MQTT Broker | Try Now | EMQ

打开MQTTX,创建连接,点击NEW SUBSCRIPTION,创建一个主题,这里使用test/topic,在下面Json中填写配置好的主题,点击发送测试OK。订阅者,建立一个主题:

package com.jasonhong.application.media.mq.mqtt;import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.MqttCallback;  
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;  public class MqttSubscriber implements MqttCallback {  public static void main(String[] args) {  String brokerUrl = "tcp://broker.hivemq.com:1883"; // 使用公共MQTT代理或你的MQTT代理地址
//        String brokerUrl = "tcp://localhost:1883"; // Mosquitto代理地址和端口String clientId = "JavaSubscriber";  String topic = "test/topic";  int qos = 2;  try (MqttClient client = new MqttClient(brokerUrl, clientId, new MemoryPersistence())) {  client.setCallback(new MqttSubscriber());  MqttConnectOptions connOpts = new MqttConnectOptions();  connOpts.setCleanSession(true);  client.connect(connOpts);  client.subscribe(topic, qos);  } catch (MqttException e) {  e.printStackTrace();  }  }  @Override  public void connectionLost(Throwable cause) {  System.out.println("Connection lost");  cause.printStackTrace();  }  @Override  public void messageArrived(String topic, MqttMessage message) throws Exception {  System.out.println("Message arrived: " + new String(message.getPayload()));  }  @Override  public void deliveryComplete(IMqttDeliveryToken token) {  System.out.println("Delivery complete");  }  
}

发布者发送给一个消息

package com.jasonhong.application.media.mq.mqtt;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;  public class MqttPublisher {  public static void main(String[] args) {  String brokerUrl = "tcp://broker.hivemq.com:1883"; // 使用公共MQTT代理或你的MQTT代理地址
//        String brokerUrl = "tcp://localhost:1883"; // Mosquitto代理地址和端口String clientId = "JavaPublisher";  String topic = "test/topic";  int qos = 2;  String content = "Hello, MQTT!";  try (MqttClient client = new MqttClient(brokerUrl, clientId, new MemoryPersistence())) {  MqttConnectOptions connOpts = new MqttConnectOptions();  connOpts.setCleanSession(true);  client.connect(connOpts);  MqttMessage message = new MqttMessage(content.getBytes());  message.setQos(qos);  client.publish(topic, message);  System.out.println("Message published: " + content);  } catch (MqttException e) {  e.printStackTrace();  }  }  
}

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

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

相关文章

日本2024年铃木亮平主演的电影《城市猎人》

《城市猎人》是由佐藤祐市执导、三岛龙朗担任编剧、铃木亮平主演的动作片,于2024年4月25日上线Netflix。 该片改编自北条司的同名漫画,讲述了负责处理黑社会纠纷的清道夫在寻找失踪的Cosplayer时被卷入巨大阴谋的故事 [2]。 相关星图 查看更多 佐藤佑…

spring boot “error“: “Not Found“

标题spring boot “error”: “Not Found” {"timestamp": "2024-05-04T07:26:21.15000:00","status": 404,"error": "Not Found","path": "/user/register" }出现以上这个提示可能是如下原因 查看在…

中间件之搜索和数据分析组件Elasticsearch

一、概述 1.1介绍 The Elastic Stack, 包括 Elasticsearch、Kibana、Beats 和 Logstash(也称为 ELK Stack)。 能够安全可靠地获取任何来源、任何格式的数据,然后实时地对数据进行搜索、分析和可视 化。Elaticsearch,简称为 ES&a…

git的操作命令有哪些、PyCharm 中常用的 Git 操作命令、-b参数的使用、stash命令在git中的使用、rebase在git中的使用

1 git的操作命令有哪些 2 PyCharm 中常用的 Git 操作命令 3 -b参数的使用 4 stash命令在git中的使用 5 rebase在git中的使用 1 git的操作命令有哪些 1. **初始化一个新的仓库**&#xff1a;git init2. **克隆仓库**&#xff1a;git clone <repository_url>3. **添加文件…

【Android学习】自定义文本框和输入监听

实现功能 以上代码可实现功能&#xff1a; 1 自定义文本框样式 2. 文本框触发形式转变 3. 文本框输入长度监听&#xff0c;达到最大长度关闭软键盘 4. password框触发检测phone框内容 1. drawable自定义形状 我创建了editor_focus.xml 和 editor_unfocus.xml&#xff0c;两者仅…

Codeforces Round 943 (Div. 3 ABCDEFG1G2题) 视频讲解

A. Maximize? Problem Statement You are given an integer x x x. Your task is to find any integer y y y ( 1 ≤ y < x ) (1\le y<x) (1≤y<x) such that gcd ⁡ ( x , y ) y \gcd(x,y)y gcd(x,y)y is maximum possible. Note that if there is more tha…

计算机毕业设计Python+Spark考研预测系统 考研推荐系统 考研数据分析 考研大数据 大数据毕业设计 大数据毕设

安顺学院本科毕业论文(设计)题目申请表 院别&#xff1a;数学与计算机科学 专业&#xff1a;数据科学与大数据 时间&#xff1a;2022年 5月26日 题 目 情 况 题目名称 基于hive数据仓库的考研信息离线分析系统的设计与实现 学生姓名 杨娣荧 学号 201903144042 …

华为鸿蒙系统(Huawei HarmonyOS)

华为鸿蒙系统&#xff08;华为技术有限公司开发的分布式操作系统&#xff09; 华为鸿蒙系统&#xff08;HUAWEI HarmonyOS&#xff09;&#xff0c;是华为公司在2019年8月9日于东莞举行的华为开发者大会&#xff08;HDC.2019&#xff09;上正式发布的分布式操作系统。 华为鸿蒙…

CLIP模型-中文-通用领域-large部署

CLIP模型-中文-通用领域-large 官网 LLM微调文档 快速开始

基于免疫粒子群算法的考虑负荷需求相应的热电联供系统优化调度(MATLAB实现)

为了实现基于免疫粒子群算法的考虑负荷需求相应的热电联供系统优化调度&#xff0c;我们可以按照以下步骤进行&#xff1a; 1. 定义目标函数&#xff1a;根据热电联供系统的运行成本、环境效益等因素&#xff0c;构建目标函数。 2. 初始化免疫粒子群算法参数&#xff1a;包括种…

使用DependencyCheck工具检测JAR依赖包的安全漏洞

引言 Dependency-Check 是一个开源工具,用于检测软件项目中使用的第三方库和组件是否存在已知的安全漏洞。它可以帮助开发团队及时发现和解决项目中的潜在安全风险,从而提高软件的安全性。 该工具通过分析项目的依赖关系,识别其中使用的第三方库和组件,并与已知的漏洞数据…

代码随想录算法训练营第四十二天

我家娃可太好看了&#xff0c;有点担心月嫂走了没法照顾娃。 明天没有新的题&#xff0c;所以我今天开个头吧。又懒了。 01背包问题 二维 思路看了一遍&#xff0c;默写一下哈。甚至看了两遍&#xff0c;但是还没开始搞。。。振作起来&#xff01;&#xff01;&#xff01; 目…

IOS 开发 - block 使用详解

1.Blobk的定义 block的写法相对难记,不必司机应被,只需要在xcode里打出"inlineBlock"--回车, 系统会自动帮你把基础版写法给你匹配出来 //Block的基础声明//等号""之前是blobk的声明,等号“”后面是block的实现/*returnType:返回类型(void、int、String *…

如何使用 Nginx、MySQL、 PHP 在 Ubuntu 22.04 上安装 WordPress

Apache通常是部署WordPress的首选&#xff0c;因为它被广泛使用&#xff0c;配置简单&#xff0c;并且与WordPress的要求具有强大的兼容性。 然而&#xff0c;Nginx是一个可行的替代方案&#xff0c;并提供了自己的一系列优势。Nginx以其高性能而闻名&#xff0c;特别是在处理…

速盾:高防CDN-完美防御

如今&#xff0c;网络安全已成为企业和个人不可忽视的重要问题之一。随着网络技术的不断发展&#xff0c;网络攻击的手段也越来越复杂和隐蔽。因此&#xff0c;保护网络的安全性变得尤为重要。针对网络攻击的防护手段也在不断升级和完善。其中&#xff0c;高防CDN作为一种完美的…

Java面试题:什么是线程安全,如何使代码线程安全?

线程安全是指在多线程环境中&#xff0c;代码能够正确地工作而不会导致数据不一致或程序崩溃。当多个线程访问共享资源时&#xff0c;如果这些线程的执行顺序是不确定的&#xff0c;可能会导致数据的不一致性。为了确保线程安全&#xff0c;需要采取一定的措施来控制对共享资源…

zabbix监控Tongweb7企业版(by lqw+sy)

此贴参考zabbix通过jmx监控Tongweb7企业版&#xff08;by lqw&#xff09;&#xff0c;是在此帖子的基础和同事整理的文档基础上重新部署验证的优化版&#xff0c;使用的是centos7。 优点&#xff1a; 1.不需要通过jmx配置进行监控。&#xff08;jmx配置需要修改tongweb的配置…

大模型预训练与微调

一、基础知识 机器学习数学原理&#xff1a;梯度下降&#xff08;gradient descent&#xff09;在机器学习中应用十分的广泛&#xff0c;不论是在线性回归还是Logistic回归中&#xff0c;它的主要目的是通过迭代找到目标函数的最小值&#xff0c;或者收敛到最小值。深度学习 …

[leetcode]最多公共前缀

编写一个函数来查找字符串数组中的最长公共前缀。 如果不存在公共前缀&#xff0c;返回空字符串 ""。 示例 1&#xff1a; 输入&#xff1a;strs ["flower","flow","flight"] 输出&#xff1a;"fl"示例 2&#xff1a; 输…

IO复用技术(1)——select/poll/epoll原理介绍及使用案例

文章目录 1.Select1.1 工作流程1.2 fd_set函数1.3 select函数1.4 例程 2.poll2.1 poll函数2.2 例程 3.epoll3.1 工作流程3.2 相关函数3.3 epoll的两种工作模式3.4 示例代码 4.总结 原理&#xff1a;使用一个线程来检查多个文件描述符&#xff0c;委托内核进行检查&#xff0c;如…