当前位置：首页 > news >正文

Linux平台搭建MQTT测试环境

news 来源：原创 2025/9/21 5:26:48

Paho MQTT

Paho MQTT‌ 是 Eclipse 基金会下的一个开源项目，旨在为多种编程语言提供 ‌MQTT 协议‌的客户端实现。MQTT（Message Queuing Telemetry Transport）是一种轻量级的发布/订阅（Pub/Sub）消息传输协议，专为物联网（IoT）等低带宽、高延迟或不稳定网络环境设计。

关键信息：

‌定义‌：
- ‌Paho‌ 是 Eclipse IoT 技术栈的一部分，提供跨平台的 MQTT 客户端库，支持设备与服务器之间的双向通信。
- ‌paho.mqtt‌ 通常指特定语言的客户端库，例如 paho-mqtt 是 Python 的客户端库名称。
‌支持的语言‌：
- ‌Python‌: paho-mqtt（通过 pip install paho-mqtt 安装）
- ‌Java‌: Eclipse Paho Java Client
- ‌C/C++‌: Eclipse Paho C/C++
- ‌JavaScript‌: Paho MQTT over WebSocket（适用于浏览器）
- 其他语言（如 Go、.NET 等）也有社区支持的实现。
‌核心功能‌：
- 发布消息到 MQTT Broker（如 Mosquitto、EMQX、AWS IoT Core）。
- 订阅主题并接收消息。
- 支持 MQTT 3.1.1 和 5.0 协议版本。
- 提供 QoS（服务质量）级别（0/1/2），确保消息可靠性。
- 支持 TLS/SSL 加密、持久会话、遗嘱消息（Last Will）等特性。
‌典型应用场景‌：
- 物联网设备与云平台通信（如传感器上报数据、远程控制设备）。
- 移动端与服务器实时消息推送。
- 跨系统异步通信（如微服务架构中的事件驱动）。

测试Demo

1. 安装MQTT Broker（Mosquitto）

# 安装Mosquitto Broker及客户端工具
sudo apt-get update
sudo apt-get install -y mosquitto mosquitto-clients# 启动Mosquitto服务（部分系统需手动启动）
sudo systemctl start mosquitto
sudo systemctl enable mosquitto# 验证Broker是否运行
sudo systemctl status mosquitto

2. 安装C语言MQTT库（推荐Paho MQTT C库）

# 安装依赖项
sudo apt-get install build-essential cmake openssl libssl-dev# 下载并编译Paho MQTT C库
git clone https://github.com/eclipse/paho.mqtt.c.git
cd paho.mqtt.c
mkdir build
cd build
cmake ..
make
sudo make install
sudo ldconfig  # 更新动态库缓存

3. 编写MQTT测试程序

‌发布者（publisher.c）
------------------------------------------------------------------
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include "MQTTClient.h"#define ADDRESS     "tcp://localhost:1883"
#define CLIENTID    "Publisher"
#define TOPIC       "test/topic"
#define QOS         1
#define TIMEOUT     10000Lint main() {MQTTClient client;MQTTClient_connectOptions conn_opts = MQTTClient_connectOptions_initializer;MQTTClient_message pubmsg = MQTTClient_message_initializer;MQTTClient_deliveryToken token;int rc;// 创建客户端实例rc = MQTTClient_create(&client, ADDRESS, CLIENTID, MQTTCLIENT_PERSISTENCE_NONE, NULL);if (rc != MQTTCLIENT_SUCCESS) {fprintf(stderr, "Failed to create client: %d\n", rc);exit(EXIT_FAILURE);}// 连接Brokerconn_opts.keepAliveInterval = 20;conn_opts.cleansession = 1;rc = MQTTClient_connect(client, &conn_opts);if (rc != MQTTCLIENT_SUCCESS) {fprintf(stderr, "Failed to connect: %d\n", rc);MQTTClient_destroy(&client);exit(EXIT_FAILURE);}// 发送消息pubmsg.payload = (void*)"Hello from C MQTT!";pubmsg.payloadlen = strlen(pubmsg.payload);pubmsg.qos = QOS;pubmsg.retained = 0;rc = MQTTClient_publishMessage(client, TOPIC, &pubmsg, &token);if (rc != MQTTCLIENT_SUCCESS) {fprintf(stderr, "Failed to publish: %d\n", rc);exit(EXIT_FAILURE);}printf("Message published. Token: %d\n", token);// 断开连接并清理MQTTClient_disconnect(client, 10000);MQTTClient_destroy(&client);return 0;
}

‌订阅者（subscriber.c）
----------------------------------------------------------------------------
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include "MQTTClient.h"#define ADDRESS     "tcp://localhost:1883"
#define CLIENTID    "Subscriber"
#define TOPIC       "test/topic"
#define QOS         1
#define TIMEOUT     10000Lvolatile MQTTClient_deliveryToken deliveredtoken;void delivered(void *context, MQTTClient_deliveryToken dt) {deliveredtoken = dt;
}int msgarrvd(void *context, char *topicName, int topicLen, MQTTClient_message *message) {printf("Received message: %.*s\n", message->payloadlen, (char*)message->payload);MQTTClient_freeMessage(&message);MQTTClient_free(topicName);return 1;
}void connlost(void *context, char *cause) {fprintf(stderr, "Connection lost. Cause: %s\n", cause);
}int main() {MQTTClient client;MQTTClient_connectOptions conn_opts = MQTTClient_connectOptions_initializer;int rc;rc = MQTTClient_create(&client, ADDRESS, CLIENTID, MQTTCLIENT_PERSISTENCE_NONE, NULL);if (rc != MQTTCLIENT_SUCCESS) {fprintf(stderr, "Failed to create client: %d\n", rc);exit(EXIT_FAILURE);}// 设置回调函数MQTTClient_setCallbacks(client, NULL, connlost, msgarrvd, delivered);conn_opts.keepAliveInterval = 20;conn_opts.cleansession = 1;rc = MQTTClient_connect(client, &conn_opts);if (rc != MQTTCLIENT_SUCCESS) {fprintf(stderr, "Failed to connect: %d\n", rc);MQTTClient_destroy(&client);exit(EXIT_FAILURE);}// 订阅主题rc = MQTTClient_subscribe(client, TOPIC, QOS);if (rc != MQTTCLIENT_SUCCESS) {fprintf(stderr, "Failed to subscribe: %d\n", rc);exit(EXIT_FAILURE);}printf("Subscribed to topic: %s\n", TOPIC);printf("Press Q<Enter> to quit\n");while(getchar() != 'Q');// 清理MQTTClient_unsubscribe(client, TOPIC);MQTTClient_disconnect(client, TIMEOUT);MQTTClient_destroy(&client);return 0;
}

4. 编译程序

# 编译发布者
gcc publisher.c -o publisher -lpaho-mqtt3c# 编译订阅者
gcc subscriber.c -o subscriber -lpaho-mqtt3c

‌5. 运行测试

Linux平台搭建MQTT测试环境

Paho MQTT Paho MQTT‌ 是 Eclipse 基金会下的一个开源项目，旨在为多种编程语言提供 ‌MQTT 协议‌的客户端实现。MQTT（Message Queuing Telemetry Transport）是一种轻量级的发布/订阅（Pub/Sub）消息传输协议&#xff…...

编程日记 2025/9/21 5:26:48

【AI学习】AI Agent（人工智能体）

1，AI agent 1）定义是一种能够感知环境、基于所感知到的信息进行推理和决策，并通过执行相应动作来影响环境、进而实现特定目标的智能实体。它整合了多种人工智能技术，具备自主学习、自主行动以及与外界交互的能力，旨…...

编程日记 2025/9/21 5:19:47

克魔助手(Kemob)安装与注册完整教程 - Windows/macOS双平台指南

iOS设备管理工具克魔助手便携版使用全指南前言：为什么需要专业的iOS管理工具在iOS开发和设备管理过程中，开发者经常需要突破系统限制，实现更深层次的控制和调试。本文将详细介绍一款实用的便携式工具的使用方法，帮助开发者快速…...

编程日记 2025/9/21 5:24:22

了解GPIO对应的主要功能

GPIO GPIO是通用输入输出端口的简称，芯片上的GPIO引脚与外部设备连接实现通讯、控制以及数据采集等功能，最基本的输出功能是通过控制引脚输出高低电平继而实现开关控制，比如引脚接入LED灯可控制LED灯的亮灭，接入继电器或三极管可…...

编程日记 2025/9/10 12:44:23

Dubbo 注册中心与服务发现

注册中心与服务发现注册中心概述注册中心是dubbo服务治理的核心组件，Dubbo依赖注册中心的协调实现服务发现，自动化的服务发现是微服务实现动态扩容、负载均衡、流量治理的基础。 Dubbo的服务发现机制经历了Dubbo2时代的接口级服务发现、Dubbo3时代的…...

编程日记 2025/9/19 10:42:24

一文详解LibTorch环境搭建：Ubuntu20.4配置LibTorch CUDA与cuDNN开发环境

随着深度学习技术的迅猛发展，越来越多的应用程序开始集成深度学习模型以提供智能化服务。为了满足这一需求，开发者们不仅依赖于Python等高级编程语言提供的便捷框架，也开始探索如何将这些模型与C应用程序相结合，以便在性能关键型应…...

编程日记 2025/9/14 10:57:30

micro ubuntu 安装教程

micro ubuntu 安装教程官网地址 : https://micro-editor.github.io 以下是在 Ubuntu 系统中安装 micro 编辑器的详细教程： 方法 1：通过 apt 直接安装（推荐） 适用于 Ubuntu 20.04 及以上版本（官方仓库已收录…...

编程日记 2025/9/10 4:52:49

观成科技：利用DoH加密信道的C2流量分析

概述 DoH（DNS over HTTPS）是一种通过HTTPS协议加密传输DNS查询的信道，将DNS请求封装在HTTP/2或HTTP/3中，DoH没有标准端口，部分服务沿用TLS的443端口。传统DNS明文传输易被拦截或篡改，而DoH通过加密提升了隐…...

编程日记 2025/9/11 16:08:08

Magnetohydrodynamic Shocks in the Interplanetary Space: a Theoretical Review ( Part 2 ) Magnetohydrodynamic Shocks in the Interplanetary Space: a Theoretical Review | Brazilian Journal of Physics Magnetohydrodynamic Shocks 1. The Rankine-Hu…...

编程日记 2025/9/14 14:40:49

Java垃圾回收的隐性杀手：过早晋升的识别与优化实战

目录一、现象与症状二、过早晋升的成因 （一）Young区（Eden区）配置过小 （二）分配速率过高 （三）晋升年龄阈值（MaxTenuringThreshold）配置不当三、动态晋…...

编程日记 2025/9/14 3:22:28

2noise团队开源ChatTTS，支持多语言、流式合成、语音的情感、停顿和语调控制

简介 ChatTTS 是一个开源的文本转语音（Text-to-Speech, TTS）项目，由 2noise 团队开发，专门为对话场景设计。它在 GitHub 上广受欢迎，因其自然流畅的语音合成能力和多功能性而备受关注。项目背景目标：设计…...

编程日记 2025/9/13 13:31:44

企业级防火墙与NAT网关配置

实训背景某公司需部署一台Linux网关服务器，要求实现以下功能： 基础防火墙：仅允许SSH（22）、HTTP（80）、HTTPS（443）入站，拒绝其他所有流量。共享上网&#xf…...

编程日记 2025/9/11 4:15:02

AI数据分析的正道是AI+BI，而不是ChatBI

一、AI大模型在数据分析中的应用现状与局限当前用户直接上传PDF、Excel等原始数据至AI大模型进行自动分析的趋势显著，但其技术成熟度与落地效果仍需审慎评估。 1.主流AI大模型的数据分析能力对比 GPT-4/Claude 3系列：在通用数据分析任务中表现突出&a…...

编程日记 2025/9/8 10:11:30

C++设计模式优化实战：提升项目性能与效率

🧑 博主简介：CSDN博客专家、CSDN平台优质创作者，高级开发工程师，数学专业，拥有高级工程师证书；擅长C/C、C#等开发语言，熟悉Java常用开发技术，能熟练应用常用数据库SQL server,Oracle…...

编程日记 2025/9/8 5:36:34

G1学习打卡

🍨 本文为🔗365天深度学习训练营中的学习记录博客🍖 原作者：K同学啊 import argparse import os import numpy as np import torchvision.transforms as transforms from torchvision.utils import save_image from torch.utils.…...

编程日记 2025/9/9 1:34:11

8.2 对话框2

编程日记 2025/9/19 17:14:36

Java中的列表（List）：操作与实现详解

引言列表（List）是Java集合框架中最基础且使用最频繁的线性数据结构。它允许有序存储元素，支持重复值和快速访问。本文将深入探讨Java列表的核心操作方法，并剖析两种经典实现类（ArrayList和LinkedList）的底…...

编程日记 2025/9/14 22:33:23

在kotlin的安卓项目中使用dagger

在 Kotlin 的 Android 项目中使用 Dagger（特别是 Dagger Hilt，官方推荐的简化版）进行依赖注入（DI）可以大幅提升代码的可测试性和模块化程度。 1. 配置 Dagger Hilt 1.1 添加依赖在 bu…...

编程日记 2025/9/21 1:13:55

MongoDB常见面试题总结（上）

MongoDB 基础 MongoDB 是什么？ MongoDB 是一个基于分布式文件存储的开源 NoSQL 数据库系统，由 C 编写的。MongoDB 提供了面向文档的存储方式，操作起来比较简单和容易，支持“无模式”的数据建模，可以存储比较复杂…...

编程日记 2025/9/8 17:52:21

leetcode6.Z字形变换

题目说是z字形变化，但其实模拟更像n字形变化，找到字符下标规律就逐个拼接就能得到答案 class Solution {public String convert(String s, int numRows) {if(numRows1)return s;StringBuilder stringBuilder new StringBuilder();for (int i 0; i <…...

编程日记 2025/9/18 13:37:04

VSCode中选择Anaconda的Python环境

1、安装Anaconda 2、安装VSCode 一、创建创建新的 Conda 环境 conda create --name myenv python3.8 conda activate myenv 二、在 VSCode 中配置 Conda 环境 1、打开 VSCode，安装 Python 插件。 2、按 CtrlShiftP 打开命令面板，输入并选择 Pytho…...

编程日记 2025/9/10 1:29:14

【基于规则】基于距离的相似性度量

基于点：设时两条序曲线分别为X，Y，在曲线上选取点Xx和Yy，计算点之间的距离，用来度量两条曲线的相似性。这类算法的精确度取决于选点的规则，以及距离的计算方式欧几里得距离：不允许时间偏移，直接计算两个时序数据点之间的距离，适用于长度相同的序列 dtw：优化了选点的方…...

编程日记 2025/9/15 17:33:53

Python 序列构成的数组(当列表不是首选时)

当列表不是首选时虽然列表既灵活又简单，但面对各类需求时，我们可能会有更好的选择。比如，要存放 1000 万个浮点数的话，数组（array）的效率要高得多，因为数组在背后存的并不是 float 对象&…...

编程日记 2025/9/19 8:12:47

LeetCode零钱兑换（动态规划）

题目描述给你一个整数数组 coins ，表示不同面额的硬币；以及一个整数 amount ，表示总金额。计算并返回可以凑成总金额所需的最少的硬币个数。如果没有任何一种硬币组合能组成总金额，返回 -1 。你可以认为每种硬币的数量是无…...

编程日记 2025/9/19 20:27:48

vscode+wsl 运行编译 c++

linux 的 windows 子系统（wsl）是 windows 的一项功能，可以安装 Linux 的发行版，例如（Ubuntu，Kali，Arch Linux）等，从而可以直接在 windows 下使用 Linux 应用程序&#xf…...

编程日记 2025/9/16 10:19:45

C++学习之libevent ②

目录 1.连接服务器函数bufferevent_socket_connect() 2.bufferevent缓冲区的读写函数bufferevent_write() bufferevent_read() 3.给bufferevent设置回调函数bufferevent_setcb（） 4.bufferevent回调函数的函数原型 5.基于bufferevent的套接字客户端处…...

编程日记 2025/9/11 3:44:06

彩色路径第32次CCF-CSP计算机软件能力认证

应该用dp做的但是我太懒懒得看题解了留到考试的时候看超时20分代码： #include<bits/stdc.h> using namespace std; int N, M, L, K; struct Edge {int to, length;Edge(int to, int length) :to(to), length(length) {} }; vector<int> color;//颜色…...

编程日记 2025/9/19 18:24:26

第1章绪论

自1946年，第一台计算机问世以来，计算机产业飞速发展。为了编写出一个好得程序，必须分析待处理的对象的特征以及各处理对象之间存在的关系。这就是数据结构这门学科形成和发展的背景。 1.1什么是数据结构数据结构是计算机科学中组织和存储数…...

编程日记 2025/9/20 8:33:28

SpringCloud微服务（一）Eureka+Nacos

一、认识微服务技术对比： SpringCloud： 版本匹配： 二、服务拆分以及远程调用消费者与提供者： Eureka： 搭建EurekaServer： Ribbon负载均衡： 实现原理： IRule：规则接口…...

编程日记 2025/9/18 20:22:50

Python 字典和集合（子类化UserDict）

本章内容的大纲如下： 常见的字典方法如何处理查找不到的键标准库中 dict 类型的变种set 和 frozenset 类型散列表的工作原理散列表带来的潜在影响（什么样的数据类型可作为键、不可预知的顺序，等等） 子类化UserDict 就创造自…...

编程日记 2025/9/8 0:17:16

时区转换工具+PWA离线网页

时区转换工具PWA离线网页一、时区转换工具对比工具说明Date原生 JS API，有限的时区支持，无法指定时区，仅使用本地时区。Intl.DateTimeFormat原生格式化显示，可指定时区，但不能修改时区逻辑。luxon强烈推荐&#xf…...

编程日记 2025/9/9 0:08:58

Hadoop序列化与反序列化具体实践

首先创建两个类两个类的代码 Student类： import org.apache.hadoop.io.Writable;import java.io.DataInput; import java.io.DataOutput; import java.io.IOException;public class Student implements Writable {public Student(String name, int age) {this.n…...

编程日记 2025/9/10 21:19:14

Github AI开发者生态最新动态今日速览（20250408）

以下是截至2025年4月8日的GitHub AI开发者生态最新动态速览，结合技术更新、工具发布及行业趋势： 1. GitHub Copilot 重大升级与生态扩展 Agent Mode全量发布：Copilot在VS Code中启用Agent模式，可自主完成多文件代码重构、测试驱动…...

编程日记 2025/9/15 18:03:34

通过扣子平台将数据写入飞书多维表格

目录 1.1 创建飞书开放平台应用 1.2 创建飞书多维表格 1.3 创建扣子平台插件 1.1 创建飞书开放平台应用 1.1.1 打开地址：飞书开放平台，点击创建应用注：商店应用需要申请ISV资质，填写企业主体信息，个人的话&#x…...

编程日记 2025/9/13 13:30:29

WEB安全--内网渗透--Kerberos之AS_REQAS_REP

一、前言之前的文章提到过，在内网的域环境中，服务器之间默认使用的是Kerberos协议。光了解NTLM协议是远远不够的，为了内网渗透，我后面将详细介绍Kerberos协议的原理以及漏洞的利用。二、Kerberos协议 Kerberos是一种网络身份…...

编程日记 2025/9/19 1:37:56

【Hadoop入门】Hadoop生态之MapReduce简介

1 MapReduce核心原理 MapReduce是一种分布式计算框架，专为处理大规模数据集设计。其核心理念是将复杂计算任务分解为两个核心阶段： Map阶段：将输入数据分割为独立片段，并行处理生成中间键值对Reduce阶段：对Map阶段输出…...

编程日记 2025/9/20 23:08:14

使用Scrapy编写图像下载程序示例

最近闲来无事想要用Scrapy库来编写一个图像下载程序。首先，我得回忆一下Scrapy的基本结构。Scrapy是一个强大的爬虫框架，适合用来抓取网页数据，包括图片。不过，用户可能不太熟悉Scrapy的具体用法，特别是图片下载的部分…...

编程日记 2025/9/19 6:10:32

Linux/树莓派网络配置、远程登录与图形界面访问实验

一.准备工作 1.修改网络适配器（选择本机网卡） 2.创建一个新的用户。 3.使用新用户登录，使用ip a指令查看IP（现代 Linux 发行版（如 Ubuntu、Debian、CentOS、Fedora 等））。通过sudo arp-sca…...

编程日记 2025/9/14 1:33:23

01-Redis-基础

1 redis诞生历程 redis的作者笔名叫做antirez，2008年的时候他做了一个记录网站访问情况的系统，比如每天有多少个用户，多少个页面被浏览，访客的IP、操作系统、浏览器、使用的搜索关键词等等(跟百度统计、CNZZ功能一样)。最开始存储…...

编程日记 2025/9/12 3:34:58

MCP-Playwright: 赋予AI模型操控浏览器的能力

在人工智能快速发展的时代，我们一直在寻找让AI与现实世界更好地交互的方式。今天我想向大家介绍一个强大的开源项目：MCP-Playwright，它正在改变AI模型与Web环境交互的方式。源码地址：https://github.com/executeautomation/mcp-…...

编程日记 2025/9/11 1:16:27

Scala集合计算高级函数及案例

一、说明 1.过滤：遍历集合，获取满足指定条件的元素组成新集合 2.转化 / 映射（map）：将集合中的每个元素映射到某一个函数 List(1, 2, 3, 4, 5, 6, 7, 8, 9)中每个元素加 1，得到List(2, 3, 4, 5, 6, 7, 8,…...

编程日记 2025/9/18 13:07:27

如何测试一个API接口？从原理到实践详解

在微服务架构和前后端分离的现代软件开发中，API接口是系统的“血管”，承担着数据传输与逻辑处理的核心功能。本文将用通俗的语言，结合实例，系统讲解API接口测试的原理、方法及工具，助你掌握这一关键技能。目录 …...

编程日记 2025/9/18 18:58:56

弹簧质点系统（C++实现）

本文实现一个简单的物理算法：弹簧质点系统（Mass-Spring System）。这是一个经典的物理模拟算法，常用于模拟弹性物体（如布料、弹簧等）的行为。我们将使用C来实现这个算法，并结合链表数据结构来管理…...

编程日记 2025/9/20 2:14:35

java设计模式-代理模式

代理模式(proxy) 基本介绍 1、代理模式：为一个对象提供一个替身，一控制对这个对象的访问。即通过代理对象访问目标对象。这样做的好处是：可以在目标对象实现的基础上，增强额外的功能操作，及扩展目标对象的功能。 2、被…...

编程日记 2025/9/4 20:41:30

【比赛编排软件的设计与实现】

有个朋友想要一个比赛编排软件，闲来无事，花几个晚上的时间帮忙编写了一下，主要本人也比较喜欢看NBA，想尝试实现类似的功能。最终实现功能展示如下： ![请添加图片描述](https://i-blog.csdnimg.cn/direct/6af8f323452…...

编程日记 2025/9/16 0:52:28

nginx如何实现负载均衡？

Nginx 是一款高性能的 Web 服务器和反向代理服务器，它可以通过配置实现负载均衡功能。以下是实现负载均衡的详细步骤和方法： 1. 基本概念负载均衡是将客户端请求分发到多个后端服务器上，以提高系统的可用性和性能。Nginx 支持多种负载均衡策…...

编程日记 2025/9/12 8:04:16

Jetson NX开发板基础配置全指南

一、系统刷机教程 1. 准备工作硬件准备： ✅ Jetson NX开发板 ✅ 19V 电源适配器 ✅ Type-C数据线 ✅ 16GB以上Micro SD卡软件准备： 🔹 SDK Manager 🔹 Ubuntu 20.04虚拟机或者物理机 2. 刷机步骤进入恢复模式： …...

编程日记 2025/9/15 6:02:39

【Linux高级IO（三）】Reactor

核心代码 Epoller.hpp #pragma once#include "nocopy.hpp" #include <cerrno> #include <sys/epoll.h> #include <unistd.h> #include <string.h> #include "Log.hpp"class Epoller : public nocopy //类Epoller继承自nocopy类&a…...

编程日记 2025/9/21 1:13:43