【EMQX】使用websocket订阅EMQX数据

2024-04-26 11:12

本文主要是介绍【EMQX】使用websocket订阅EMQX数据,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

需求:某平台希望通过 websocket 来订阅 EMQX平台上的某些 Topic数据进行处理

1、EMQX 服务配置

        前提是EMQX服务正常安装运行了,如果EMQX服务未安装的话,详见以下文章关于如何安装部署服务:

搭建自己的MQTT服务器、实现设备上云(Windows+EMQX)_自己搭建mqtt服务器-CSDN博客

MQTT 服务器搭建:EMQ X 安装指南和常见问题-CSDN博客

        服务安装运行后,登录到 EMQX 后台。登录地址为:http://{emqxBrokerHost}:{默认端口:18083}。如下所示:

1.1、查看websocket 服务配置信息

        登录系统后,找到菜单 “管理 --> 监听器”。选择类型为【ws】的记录,点击名称可以查看到如下信息:

        这里面需要注意的信息有以下几个,目的是为了连接到服务。其他配置参数根据需要进行对应调整。

  • 监听地址:EMQX所在服务的IP
  • 16593:EMQX服务分配的关于websocket未加密地址的监听端口
  • MQTT Path:WebSocket 连接的路径,例如 /mqtt,作用是指定 WebSocket 连接的路径,以便在服务器上找到正确的 WebSocket 端点

1.2、验证 websocket连接

        打开菜单 “问题分析  -->  Websocket 客户端”,如下截图所示:

        如果没有对EMQX服务开启授权认证,那么直接连接即可连接成功(端口没有更改的情况)。也就是说没有开启授权认证的话,就不需要配置用户名与密码可直接连接使用。关于如何开启认证或配置详见以下文章:

EMQX开启权限认证,添加用户名、密码认证--MQTT_emqx mnesia认证 不输入用户名密码也能登录-CSDN博客文章浏览阅读1.2w次,点赞5次,收藏21次。提示:前置条件,需要安装EMQX,同时可以访问控制面板文章目录前言一、认证方式二、使用步骤--仅介绍Mnesia(用户名/Client ID)认证1.开启插件2.方式一:预设认证用户(不推荐)3.方式二:使用 HTTP API 管理认证数据(推荐)添加认证数据#批量添加认证数据#查看已经添加的认证数据#更改已添加的认证数据#查看指定的认证数据#删除指定的 Clientid 认证数据总结前言EMQ X 默认配置中启用了匿名认证,任何客户端._emqx mnesia认证 不输入用户名密码也能登录https://blog.csdn.net/beibei3321/article/details/124293119        我这边是有配置授权认证的,所以需要查看关于认证用户的相关配置信息。

1.3、创建用户

        打开菜单 “系统设置  -->  用户”,详见如下所示。需要新增用户直接创建新增配置账户名密码即可使用。需要注意的是,只创建这个用户只能登录到 EMQX 平台,当使用客户端进行授权认证,是还无法使用的。

        比如我这边创建一个账户为【wsTest】:

        此时,我还没有对该用户进行客户端授权配置。我们可以拿这个用户进行websocket验证测试连接是否可以正常使用。

情况二:

情况三:配置客户端授权后

1.4、客户端授权配置

        打开菜单 “访问控制  -->  客户端认证 --->  内置数据库”记录的用户管理。

        很明显我们刚刚新增的用户并没有在列表中,此时我们把刚刚新增的用户配置进来。

        再去进行 websocket 客户端连接测试,如下测试:

        可以看到我们能够正常连接使用,此时我们可以对指定 Topic 进行消息的发布订阅测试。

2、websocket 客户端订阅发布

2.1、EMQX 发布订阅(ws)

        根据上文操作后,我们在EMQX平台上已经开启了一个 websocket 订阅客户端并且订阅了主题为 “tohave” 的数据。此时我们在 EMQX 平台的 websocket 客户端里在新建一个客户端连接进行数据发生,验证数据是否能够正常发送接收。

        在 5MZ 的客户端连接里,对Topic “tohave” 发送一条报文为 “大哥你好”的数据,如下图所示。此时在 5MZ 客户端连接里可以看到,我们数据是已经发送出去了,在 已发送 列表里可以看到具体信息。

        此时我们查看另一个客户端连接看数据是否已收到:

可以看到数据是可以正常发送订阅的

2.2、websocket网页

        这里我们在用HTML网页进行测试验证看下,网页编写如以下所示。将代码复制出来粘贴到HTML网页文件中,修改对应连接信息双击打开运行即可。

<!DOCTYPE html>
<html>
<body>
<script src="https://cdn.bootcdn.net/ajax/libs/mqtt/5.0.5/mqtt.min.js"></script>
<script src="https://cdn.bootcss.com/jquery/3.3.1/jquery.min.js"></script><h1 id="myDiv"></h1>
<script type="text/javascript">$(function () {// 连接选项const options = {clean: true, // true: 清除会话, false: 保留会话connectTimeout: 4000, // 超时时间// 认证信息clientId: 'wsEmqx' + Math.random(),//EMQX配置的相关账户密码username: '账号',password: '密码',};//订阅主题const subTopic = "subEmqx";//发布主题const pubTopic = "tohave";// 连接字符串, 通过协议指定使用的连接方式// ws 未加密 WebSocket 连接// wss 加密 WebSocket 连接// mqtt 未加密 TCP 连接// mqtts 加密 TCP 连接// wxs 微信小程序连接// alis 支付宝小程序连接const connectUrl = 'ws://{EMQX服务所在IP}:{EMQX服务分配 ws 类型的监听端口}/mqtt'const client = mqtt.connect(connectUrl, options)client.on('connect', function () {console.log('Connected')// 订阅主题client.subscribe(subTopic, function (err) {if (!err) {// 发布消息client.publish(pubTopic, 'EMQX,我想你了!!!')}})})client.on('reconnect', (error) => {console.log('正在重连:', error)})client.on('error', (error) => {console.log('连接失败:', error)})client.on('message', (topic, message) => {$("#myDiv").html(message.toString());console.log('收到消息:', topic, message.toString())})});</script></body>
</html>

        相应信息配置完成后,我们双击打开运行。运行后连接成功时,会向EMQX平台的【tohave】主题发送一条消息,如下所示:

        每刷新一次网页就会向EMQX服务端发生一条消息。

        可以看到数据是有发布过去的,此时我们在EMQX上推送下数据到网页端观察看看:

这篇关于【EMQX】使用websocket订阅EMQX数据的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/937434

相关文章

Java学习手册之Filter和Listener使用方法

《Java学习手册之Filter和Listener使用方法》:本文主要介绍Java学习手册之Filter和Listener使用方法的相关资料,Filter是一种拦截器,可以在请求到达Servl... 目录一、Filter(过滤器)1. Filter 的工作原理2. Filter 的配置与使用二、Listen

Pandas使用AdaBoost进行分类的实现

《Pandas使用AdaBoost进行分类的实现》Pandas和AdaBoost分类算法,可以高效地进行数据预处理和分类任务,本文主要介绍了Pandas使用AdaBoost进行分类的实现,具有一定的参... 目录什么是 AdaBoost?使用 AdaBoost 的步骤安装必要的库步骤一:数据准备步骤二:模型

Pandas统计每行数据中的空值的方法示例

《Pandas统计每行数据中的空值的方法示例》处理缺失数据(NaN值)是一个非常常见的问题,本文主要介绍了Pandas统计每行数据中的空值的方法示例,具有一定的参考价值,感兴趣的可以了解一下... 目录什么是空值?为什么要统计空值?准备工作创建示例数据统计每行空值数量进一步分析www.chinasem.cn处

使用Pandas进行均值填充的实现

《使用Pandas进行均值填充的实现》缺失数据(NaN值)是一个常见的问题,我们可以通过多种方法来处理缺失数据,其中一种常用的方法是均值填充,本文主要介绍了使用Pandas进行均值填充的实现,感兴趣的... 目录什么是均值填充?为什么选择均值填充?均值填充的步骤实际代码示例总结在数据分析和处理过程中,缺失数

如何使用 Python 读取 Excel 数据

《如何使用Python读取Excel数据》:本文主要介绍使用Python读取Excel数据的详细教程,通过pandas和openpyxl,你可以轻松读取Excel文件,并进行各种数据处理操... 目录使用 python 读取 Excel 数据的详细教程1. 安装必要的依赖2. 读取 Excel 文件3. 读

解决Maven项目idea找不到本地仓库jar包问题以及使用mvn install:install-file

《解决Maven项目idea找不到本地仓库jar包问题以及使用mvninstall:install-file》:本文主要介绍解决Maven项目idea找不到本地仓库jar包问题以及使用mvnin... 目录Maven项目idea找不到本地仓库jar包以及使用mvn install:install-file基

Spring 请求之传递 JSON 数据的操作方法

《Spring请求之传递JSON数据的操作方法》JSON就是一种数据格式,有自己的格式和语法,使用文本表示一个对象或数组的信息,因此JSON本质是字符串,主要负责在不同的语言中数据传递和交换,这... 目录jsON 概念JSON 语法JSON 的语法JSON 的两种结构JSON 字符串和 Java 对象互转

Python使用getopt处理命令行参数示例解析(最佳实践)

《Python使用getopt处理命令行参数示例解析(最佳实践)》getopt模块是Python标准库中一个简单但强大的命令行参数处理工具,它特别适合那些需要快速实现基本命令行参数解析的场景,或者需要... 目录为什么需要处理命令行参数?getopt模块基础实际应用示例与其他参数处理方式的比较常见问http

C 语言中enum枚举的定义和使用小结

《C语言中enum枚举的定义和使用小结》在C语言里,enum(枚举)是一种用户自定义的数据类型,它能够让你创建一组具名的整数常量,下面我会从定义、使用、特性等方面详细介绍enum,感兴趣的朋友一起看... 目录1、引言2、基本定义3、定义枚举变量4、自定义枚举常量的值5、枚举与switch语句结合使用6、枚

使用Python从PPT文档中提取图片和图片信息(如坐标、宽度和高度等)

《使用Python从PPT文档中提取图片和图片信息(如坐标、宽度和高度等)》PPT是一种高效的信息展示工具,广泛应用于教育、商务和设计等多个领域,PPT文档中常常包含丰富的图片内容,这些图片不仅提升了... 目录一、引言二、环境与工具三、python 提取PPT背景图片3.1 提取幻灯片背景图片3.2 提取