【知识分享】MQTT实战-使用mosquitto客户端连接emqx服务器

本文主要是介绍【知识分享】MQTT实战-使用mosquitto客户端连接emqx服务器,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

一、简介

    MQTT(Message Queuing Telemetry Transport)是一种轻量级的、基于发布/订阅模式的通信协议,旨在实现物联网设备之间的低带宽、高延迟的通信。MQTT协议设计简洁,使用TCP/IP协议进行通信,适用于各种网络环境,尤其适合在有限的网络带宽和不稳定的网络连接条件下进行通信。

    MQTT的工作原理是基于发布/订阅模式的消息传递,它包括两个主要角色:发布者(Publisher)和订阅者(Subscriber)。发布者负责发布消息到主题(Topic),而订阅者则可以订阅感兴趣的主题,从而接收相应的消息。这种模式使得设备之间可以实现异步通信,同时降低了对网络和系统资源的占用。MQTT的两个常用的开源库,mosquitto和emqx。本文服务端使用的是emqx,而客户端则用mosquitto开源库。

二、通信时序框图

在这里插入图片描述

三、服务器搭建

  • 创建MQTT服务

    可以进入emqx官网参考下载过程。
在这里插入图片描述
    按照官网执行以下三个步骤,即可打开emqx服务。

curl -s https://assets.emqx.com/scripts/install-emqx-deb.sh | sudo bash
sudo apt-get install emqx
sudo systemctl start emqx

    如果要查看服务开启状态,则使用以下命令。

sudo systemctl status emqx

    如果需要关闭服务,则使用以下命令。

sudo systemctl stop emqx
  • 服务测试

    首先安装mosquitto客户端。

sudo apt install mosquitto-clients

    先打开一个终端,输入以下命令。

mosquitto_sub -h localhost -t "topic"

    再打开另外一个终端,输入以下命令,如果可以在前一个终端界面上看到发送的信息,则说明服务正常开启。

mosquitto_pub -h localhost -t "topic" -m "Hello, MQTT"

四、客户端代码实现

    这里我们实现两个客户端用来相互通信。
客户端1代码

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <mosquitto.h>#define MQTT_SERVER_ADDRESS     "127.0.0.1"
#define MQTT_SERVER_PORT        1883
#define MQTT_TOPIC              "topic"struct mosquitto *mosq = NULL;void on_connect(struct mosquitto *mosq, void *obj, int rc)
{if (rc == 0) {printf("Connected to MQTT broker\n");} else {fprintf(stderr, "Failed to connect to MQTT broker: %s\n", mosquitto_strerror(rc));exit(EXIT_FAILURE);}
}void on_publish(struct mosquitto *mosq, void *obj, int mid)
{printf("Message published\n");
}int main()
{int rc;int protocol_version = MQTT_PROTOCOL_V311;mosquitto_lib_init(); // 初始化Mosquitto库mosq = mosquitto_new(NULL, true, NULL);if (!mosq) {fprintf(stderr, "Error: Out of memory.\n");return EXIT_FAILURE;}mosquitto_connect_callback_set(mosq, on_connect);mosquitto_publish_callback_set(mosq, on_publish);// 设置MQTT协议版本mosquitto_opts_set(mosq, MOSQ_OPT_PROTOCOL_VERSION, &protocol_version);rc = mosquitto_connect(mosq, MQTT_SERVER_ADDRESS, MQTT_SERVER_PORT, 60); // 连接到MQTT brokerif (rc != MOSQ_ERR_SUCCESS) {fprintf(stderr, "Unable to connect to MQTT broker: %s\n", mosquitto_strerror(rc));return EXIT_FAILURE;}printf("Connected to MQTT broker\n");while (1) {char payload[100];printf("Enter message: ");fgets(payload, sizeof(payload), stdin);payload[strcspn(payload, "\n")] = '\0';rc = mosquitto_publish(mosq, NULL, MQTT_TOPIC, strlen(payload), payload, 0, false);if (rc != MOSQ_ERR_SUCCESS) {fprintf(stderr, "Failed to publish message: %s\n", mosquitto_strerror(rc));}}mosquitto_destroy(mosq); // 销毁Mosquitto对象mosquitto_lib_cleanup(); // 清理Mosquitto库return 0;
}

客户端2代码

#include <stdio.h>
#include <stdlib.h>
#include <mosquitto.h>#define MQTT_SERVER_ADDRESS     "localhost"
#define MQTT_SERVER_PORT        1883
#define MQTT_TOPIC              "topic"struct mosquitto *mosq = NULL;void on_connect(struct mosquitto *mosq, void *obj, int rc)
{if (rc == 0) {printf("Connected to MQTT broker\n");mosquitto_subscribe(mosq, NULL, MQTT_TOPIC, 0); // 订阅主题} else {fprintf(stderr, "Failed to connect to MQTT broker: %s\n", mosquitto_strerror(rc));exit(EXIT_FAILURE);}
}void on_message(struct mosquitto *mosq, void *obj, const struct mosquitto_message *msg)
{printf("Received message: %.*s\n", (int)msg->payloadlen, (char *)msg->payload);
}int main()
{int rc;int protocol_version = MQTT_PROTOCOL_V311;mosquitto_lib_init(); // 初始化Mosquitto库mosq = mosquitto_new(NULL, true, NULL);if (!mosq) {fprintf(stderr, "Error: Out of memory.\n");return EXIT_FAILURE;}mosquitto_connect_callback_set(mosq, on_connect);mosquitto_message_callback_set(mosq, on_message);// 设置MQTT协议版本printf("protocol version is:%d\n", protocol_version);mosquitto_opts_set(mosq, MOSQ_OPT_PROTOCOL_VERSION, &protocol_version);rc = mosquitto_connect(mosq, MQTT_SERVER_ADDRESS, MQTT_SERVER_PORT, 60); // 连接到MQTT brokerif (rc != MOSQ_ERR_SUCCESS) {fprintf(stderr, "Unable to connect to MQTT broker: %s\n", mosquitto_strerror(rc));return EXIT_FAILURE;}printf("Connected to MQTT broker\n");mosquitto_loop_start(mosq); // 启动MQTT客户端循环while (1) {// 保持客户端运行}mosquitto_disconnect(mosq); // 断开连接mosquitto_destroy(mosq); // 销毁Mosquitto对象mosquitto_lib_cleanup(); // 清理Mosquitto库return 0;
}
  • 本地编译测试
gcc -o MyMQTT *.c -lpthread -lmosquitto

五、交叉编译

    先上mosquitto官网下载mosquitto源码,这里下载的是当前最新版本2.0.18。
在这里插入图片描述
    解压,并进入文件夹。

tar xvf mosquitto-2.0.18.tar.gz
cd mosquitto-2.0.18

    打开config.mk配置文件,将CJSON注释掉,并且把编译静态库功能打开。
在这里插入图片描述
    如果不用SSL加密,把WITH_TLS:=yes也注释掉,不然就得再装个openssl
在这里插入图片描述
    执行make命令进行编译,注意这里要使用交叉编译工具,即把CC替换成交叉编译gcc,把CXX替换成交叉编译g++。

make CC=/opt/atk-dlrk356x-toolchain/bin/aarch64-buildroot-linux-gnu-gcc CXX=/opt/atk-dlrk356x-toolchain/bin/aarch64-buildroot-linux-gnu-g++

    然后再执行安装命令,这里注意加上sudo权限。

sudo make install

    安装后库会在/usr/local/lib中,头文件会在/usr/local/include中。
在这里插入图片描述
    然后回到上面的例子工程中,使用交叉编译工具进行编译,编译的时候指定链接静态库mosquitto

/opt/atk-dlrk356x-toolchain/bin/aarch64-buildroot-linux-gnu-gcc -static -o MyMQTT *.c -lpthread -L/usr/local/lib -lmosquitto -I/usr/local/include

六、注意事项

1、使用mosquitto_connect接口进行MQTT连接时,第4个参数是保持心跳持续时间,这个值不能设为0,不然一直连接不上。
2、注意协议版本号,需要保持通信双方协议版本号一致,正常默认是V3.11。
3、如果要使用交叉编译时,需要安装宿主机对应架构的mosquitto库,比如需要交叉编译arm架构的,那需要手动下载mosquitto的源码包,编译生成对应的库,编译时链接到该库。

这篇关于【知识分享】MQTT实战-使用mosquitto客户端连接emqx服务器的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



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

相关文章

网页解析 lxml 库--实战

lxml库使用流程 lxml 是 Python 的第三方解析库,完全使用 Python 语言编写,它对 XPath表达式提供了良好的支 持,因此能够了高效地解析 HTML/XML 文档。本节讲解如何通过 lxml 库解析 HTML 文档。 pip install lxml lxm| 库提供了一个 etree 模块,该模块专门用来解析 HTML/XML 文档,下面来介绍一下 lxml 库

Ilya-AI分享的他在OpenAI学习到的15个提示工程技巧

Ilya(不是本人,claude AI)在社交媒体上分享了他在OpenAI学习到的15个Prompt撰写技巧。 以下是详细的内容: 提示精确化:在编写提示时,力求表达清晰准确。清楚地阐述任务需求和概念定义至关重要。例:不用"分析文本",而用"判断这段话的情感倾向:积极、消极还是中性"。 快速迭代:善于快速连续调整提示。熟练的提示工程师能够灵活地进行多轮优化。例:从"总结文章"到"用

Java架构师知识体认识

源码分析 常用设计模式 Proxy代理模式Factory工厂模式Singleton单例模式Delegate委派模式Strategy策略模式Prototype原型模式Template模板模式 Spring5 beans 接口实例化代理Bean操作 Context Ioc容器设计原理及高级特性Aop设计原理Factorybean与Beanfactory Transaction 声明式事物

服务器集群同步时间手记

1.时间服务器配置(必须root用户) (1)检查ntp是否安装 [root@node1 桌面]# rpm -qa|grep ntpntp-4.2.6p5-10.el6.centos.x86_64fontpackages-filesystem-1.41-1.1.el6.noarchntpdate-4.2.6p5-10.el6.centos.x86_64 (2)修改ntp配置文件 [r

W外链微信推广短连接怎么做?

制作微信推广链接的难点分析 一、内容创作难度 制作微信推广链接时,首先需要创作有吸引力的内容。这不仅要求内容本身有趣、有价值,还要能够激起人们的分享欲望。对于许多企业和个人来说,尤其是那些缺乏创意和写作能力的人来说,这是制作微信推广链接的一大难点。 二、精准定位难度 微信用户群体庞大,不同用户的需求和兴趣各异。因此,制作推广链接时需要精准定位目标受众,以便更有效地吸引他们点击并分享链接

中文分词jieba库的使用与实景应用(一)

知识星球:https://articles.zsxq.com/id_fxvgc803qmr2.html 目录 一.定义: 精确模式(默认模式): 全模式: 搜索引擎模式: paddle 模式(基于深度学习的分词模式): 二 自定义词典 三.文本解析   调整词出现的频率 四. 关键词提取 A. 基于TF-IDF算法的关键词提取 B. 基于TextRank算法的关键词提取

使用SecondaryNameNode恢复NameNode的数据

1)需求: NameNode进程挂了并且存储的数据也丢失了,如何恢复NameNode 此种方式恢复的数据可能存在小部分数据的丢失。 2)故障模拟 (1)kill -9 NameNode进程 [lytfly@hadoop102 current]$ kill -9 19886 (2)删除NameNode存储的数据(/opt/module/hadoop-3.1.4/data/tmp/dfs/na

Hadoop数据压缩使用介绍

一、压缩原则 (1)运算密集型的Job,少用压缩 (2)IO密集型的Job,多用压缩 二、压缩算法比较 三、压缩位置选择 四、压缩参数配置 1)为了支持多种压缩/解压缩算法,Hadoop引入了编码/解码器 2)要在Hadoop中启用压缩,可以配置如下参数

Makefile简明使用教程

文章目录 规则makefile文件的基本语法:加在命令前的特殊符号:.PHONY伪目标: Makefilev1 直观写法v2 加上中间过程v3 伪目标v4 变量 make 选项-f-n-C Make 是一种流行的构建工具,常用于将源代码转换成可执行文件或者其他形式的输出文件(如库文件、文档等)。Make 可以自动化地执行编译、链接等一系列操作。 规则 makefile文件

性能分析之MySQL索引实战案例

文章目录 一、前言二、准备三、MySQL索引优化四、MySQL 索引知识回顾五、总结 一、前言 在上一讲性能工具之 JProfiler 简单登录案例分析实战中已经发现SQL没有建立索引问题,本文将一起从代码层去分析为什么没有建立索引? 开源ERP项目地址:https://gitee.com/jishenghua/JSH_ERP 二、准备 打开IDEA找到登录请求资源路径位置