MQTT服务端EMQX开源版安装和客户端MQTTX介绍

一、EMQX是什么

EMQX 是一款开源的大规模分布式 MQTT 消息服务器,功能丰富,专为物联网和实时通信应用而设计。EMQX 5.0 单集群支持 MQTT 并发连接数高达 1 亿条,单服务器的传输与处理吞吐量可达每秒百万级 MQTT 消息,同时保证毫秒级的低时延。

EMQX 支持多种协议,包括 MQTT (3.1、3.1.1 和 5.0)、HTTP、QUIC 和 WebSocket 等,保证各种网络环境和硬件设备的可访问性。EMQX 还提供了全面的 SSL/TLS 功能支持,比如双向认证以及多种身份验证机制,为物联网设备和应用程序提供可靠和高效的通信基础设施。
在这里插入图片描述
内置基于 SQL 的规则引擎,EMQX 可以实时提取、过滤、丰富和转换物联网数据。此外,EMQX 采用了无主分布式架构,以确保高可用性和水平扩展性,并提供操作友好的用户体验和出色的可观测性。

EMQX 拥有来自 50 多个国家的 20,000 多家企业用户,连接全球超过 1 亿台物联网设备,服务企业数字化、实时化、智能化转型。

下载入口:
https://www.emqx.com/zh/try?tab=self-managed
在这里插入图片描述

使用指南:
https://docs.emqx.com/zh/emqx/latest/

二、EMQX开源版-CentOS/RHEL版本

链接地址
https://www.emqx.com/zh/downloads-and-install/broker?os=RHEL

配置 EMQX Yum 源

curl -s https://assets.emqx.com/scripts/install-emqx-rpm.sh | sudo bash

安装依赖

yum install epel-release -y
yum install -y openssl11 openssl11-devel

安装 EMQX

sudo yum install emqx -y

启动 EMQX

sudo systemctl start emqx

查看状态

sudo systemctl status emqx

看到 Active: active(running)则为启动成功
在这里插入图片描述

三、EMQX开源版-Docker版本

链接地址:
https://www.emqx.com/zh/downloads-and-install/broker?os=Docker

获取 Docker 镜像

docker pull emqx/emqx:5.7.1

(由于Docker限制,需要梯子才能拉取到镜像)

启动 Docker 容器

docker run --restart=always -d --name emqx -p 1883:1883 -p 8083:8083 -p 8084:8084 -p 8883:8883 -p 18083:18083 emqx/emqx:5.7.1

四、EMQX开源版-macOS版本

链接地址:
https://www.emqx.com/zh/downloads-and-install/broker?os=macOS

先选择版本,如 v5.7.1

再选择安装包系统类型,目前只支持 macOS 13macOS 14
在这里插入图片描述

下载安装包

wget https://www.emqx.com/zh/downloads/broker/5.7.1/emqx-5.7.1-macos14-arm64.zip

解压并安装

mkdir -p emqx && unzip emqx-5.7.1-macos14-arm64.zip -d emqx

启动

./emqx/bin/emqx start

五、其他版本

其他版本下载地址
https://www.emqx.com/zh/downloads/broker

六、EMQX控制台

控制台的端口是18083,如果有防火墙记得把端口开放。
通过浏览器访问 http://ip:18083/
在这里插入图片描述
默认用户名 admin,密码 public,第一次登录提示修改密码,成功后就进入系统了。
能查看当前集群的情况
在这里插入图片描述
左边的菜单如下
在这里插入图片描述

七、客户端MQTTX

MQTTX 是一个强大的跨平台 MQTT 客户端,支持MQTT 5.0和3.x。有桌面版,CLI版和在线版。支持Windows、Mac、Linux、Docker。

下载地址: https://mqttx.app/zh/downloads
安装后打开客户端
在这里插入图片描述
先创建连接。EMQX提供了一个免费开源的服务器可供测试,地址:mqtt://broker.emqx.io:1883,也可以使用刚刚安装的MQTT服务进行测试。
在这里插入图片描述
填入服务器信息,可选择MQTT版本,MQTT 5.0支持遗嘱消息,填写完成后点击右上角的连接。
之后添加订阅 在这里插入图片描述
填写topic,可使用通配符,如:testtopic/# 表示多层匹配,可匹配如 testtopic/1/testtesttopic/1
在这里插入图片描述
选择Qos,确定。
在这里插入图片描述
可查看他人发送的消息。如果想自己发送消息,则在消息框上方填写对应的topic,输入相应的消息发送即可。通过订阅此topic,也能接收到自己发送的消息。如图:
在这里插入图片描述

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

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

相关文章

vscode 中python 支持自动跳转

随笔记录 目录 1. 背景介绍 2. 解决方案 1. 背景介绍 vscode 远程ssh 打开python 脚本无法自动跳转 2. 解决方案 安装python 插件即可。 至此,已完成vscode 上py 文件支持自动跳转功能

1.6.丢弃法

丢弃法 动机:一个好的模型需要对输入数据的扰动足够健壮,丢弃法就是在层之间加入噪音。也可以在数据中使用噪音,等价与Tikhonov正则 无偏差的加入噪音 ​ 对于数据 x x x,加入噪音后的 x ′ x x′的期望值是不变的,…

Unity如何查找两个transform最近的公共parent

查找两个子对象最近的父对象 一、问题背景二、解决方案思路核心算法代码 三、总结 一、问题背景 最近看到个关于Unity的问题:在Hierarchy面板中的游戏对象,给定两个子物体transform对象,如何查找这两个transform最近的公共父级parent。感觉挺…

【前端】ikun-qrcode:极简的二维码生成组件,使用view而非canvas避免层级问题

文章目录 背景ikun-qrcode界面效果如何发布一款自己的插件到uniapp市场。(5分钟搞定) 背景 之前在uniapp上100行搞定二维码生成, 现在封装为vue组件分享出来: 下载地址: https://ext.dcloud.net.cn/plugin?id19351 …

C语言 | Leetcode C语言题解之第239题滑动窗口最大值

题目&#xff1a; 题解&#xff1a; int* maxSlidingWindow(int* nums, int numsSize, int k, int* returnSize) {int prefixMax[numsSize], suffixMax[numsSize];for (int i 0; i < numsSize; i) {if (i % k 0) {prefixMax[i] nums[i];} else {prefixMax[i] fmax(pref…

PHP + Swoole 与 Go 技术选型对比调研报告

1. 引言 在高并发场景下&#xff0c;选择合适的技术栈至关重要。PHP Swoole 和 Go 都是当前流行的技术选型&#xff0c;但它们在性能、开发效率、易用性等方面各有优劣。本报告将从多个维度对比这两种技术&#xff0c;帮助开发者做出更合适的选择。 2. 技术概述 PHP Swool…

linux 修改hostname

在 Linux 系统中修改主机名&#xff08;hostname&#xff09;要遵循以下几步全面的操作流程&#xff1a; 1. 临时修改主机名 你可以立即但临时地更改主机名&#xff0c;这个更改在重启后不会保留。执行以下命令&#xff1a; hostname 新主机名例如&#xff1a; hostname my…

编程世界的对决:JavaScript vs Java

在编程领域&#xff0c;Java和JavaScript这两门语言各有千秋。它们不仅在语法上有着明显的区别&#xff0c;在编程理念、表现力、类型转换以及代码的易读性和复杂性方面也有着巨大的差异。本文将深入探讨JavaScript相较于Java的优势&#xff0c;以及两者在代码风格和开发体验上…

抖音视频素材去哪里找啊?视频素材网站库分享

在这个视觉盛宴的抖音平台上&#xff0c;高质量和有趣的视频素材常常是吸引观众的重要钥匙。如果你也正在寻找那些能让你的视频作品更加出色的资源&#xff0c;那么恭喜你&#xff0c;今天我将为你介绍10个超实用的视频素材网站&#xff0c;让你的抖音视频创作充满创意和效率。…

【ROS2】高级:解锁 Fast DDS 中间件的潜力 [社区贡献]

目标&#xff1a;本教程将展示如何在 ROS 2 中使用 Fast DDS 的扩展配置功能。 教程级别&#xff1a;高级 时间&#xff1a;20 分钟 目录 背景 先决条件在同一个节点中混合同步和异步发布 创建具有发布者的节点创建包含配置文件的 XML 文件执行发布者节点创建一个包含订阅者的节…

单例模式->饿汉模式->懒汉模式->阻塞队列->模拟实现阻塞队列->生产者消费者模型

单例模式->是一种固定套路,类似于"棋谱",按照套路来,可以避免一些问题 单例模式的特点->能够保证在某个类中只存在一个实例,不会创建多个实例 饿汉模式(线程安全):最基础的单例模式,类加载的同时就会创建实例,是线程安全的 public class Singleton {// 在类加…

Flutter应用开发:掌握StatefulWidget的实用技巧

前言 随着移动应用的日益复杂&#xff0c;状态管理成为了 Flutter 应用开发中的一项重要挑战。 状态&#xff0c;即应用中的可变数据&#xff0c;它驱动着用户界面的渲染和交互。 在 Flutter 这样的声明式 UI 框架中&#xff0c;如何高效、可维护地管理状态&#xff0c;对于…

cuda中的cooperative_groups

背景 最近看到一个代码cooperative_groups.this_grid().sync()很好奇&#xff0c;这里好好梳理一下 分析 以前block内部的同步是用syncthreads(), block之间没有提供同步的接口&#xff0c;这样是合理的&#xff0c;假如有block间同步API的话&#xff0c;如果block太多&…

vue程序中如何设置调用springboot服务的url

在Vue程序中调用Spring Boot服务的URL&#xff0c;可以通过以下步骤实现&#xff1a; 安装Axios: Axios是一个基于Promise的HTTP库&#xff0c;可以用于浏览器和Node.js。可以使用npm或yarn安装Axios。 npm install axios # or yarn add axios创建Axios实例: 为了方便管理和复用…

Python--循环控制语句:continue 和 break

在Python编程中&#xff0c;continue 和 break 是两个非常有用的循环控制语句&#xff0c;它们允许我们以不同的方式控制循环的执行流程。 continue 语句 continue 用于中断当前循环的剩余部分&#xff0c;直接进入下一次循环的开始。它的作用是跳过当前循环中剩余的代码&…

GuLi商城-商品服务-API-属性分组-分组修改级联选择器回显

前端代码:略 后端回显接口: 递归方法: @Override publi

算法模板之单调栈【java】

算法模板之单调栈【java】 单调栈&#xff1a;在一维数组中找第一个满足某种条件的数找到数组中每个数【左侧】第一个【大于】它的数找到数组中每个数【左侧】第一个【大于或等于】它的数找到数组中每个数【左侧】第一个【小于】它的数找到数组中每个数【左侧】第一个【小于或等…

C# 反射详解

本文主要是对反射进行详细介绍&#xff0c;具体可以参照微软官方文档 首先我们来定义一个类型 public class Calculator {private int _number1 10;private int _number2 20;public int Number1 { get > _number1; set > _number1 value; }public int Number2 { get…

jquery中pdf在页面的显示和导出

jquery中pdf在页面的显示和导出 01 显示pdf01 .pdf结尾在线接口显示到页面 &#xff08;pdf.js库怎么安装及使用&#xff09;&#xff1a;只显示一页02 如何用PDF.JS显示整个PDF (而不仅仅是一页)&#xff1f;03 jQuery实现在线预览PDF文件(通过a标签链接跳转)&#xff1a; 02 …

RocketMq源码解析十二:消息消费负载

RocketMQ消息队列重新分配是由RebalancService线程来实现,一个MQClientinstance持有一个RebalanceService的实现,并随着MQClientInstance的启动而启动。我们看下下面的代码 位置:MQClientInstance:start方法 public void start() throws MQClientException {synchronized (…