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

CentOS上使用Mosquitto实现Mqtt主题消息发布和订阅mqtt主题消息连同时间戳记录到文件

场景

CentOS上使用rpm离线安装Mosquitto(Linux上Mqtt协议调试工具)附资源下载:

CentOS上使用rpm离线安装Mosquitto(Linux上Mqtt协议调试工具)附资源下载-CSDN博客

上面介绍了mosquitto的离线安装。

如果业务场景中需要订阅某mqtt主题的消息并将收到消息的时间以及消息内容记录到

文件中,便于数据分析。

如果是在windows电脑上可以参考如下

Winform中使用MQTTnet实现MQTT的服务端和客户端之间的通信以及将订阅的消息保存到文件:

Winform中使用MQTTnet实现MQTT的服务端和客户端之间的通信以及将订阅的消息保存到文件_mqttnet publishasync-CSDN博客

如果是在linux上可以使用mosquitto加脚本的方式实现。

注:

博客:
霸道流氓气质-CSDN博客

实现

CentOS上Mosquitto服务的启动、停止、查看状态

上面搭建mosquitto的服务后,需要启动其服务

启动服务器

sudo service mosquitto start

查看状态

sudo service mosquitto status

关闭服务器

sudo service mosquitto stop

Mosquitto实现发布MQTT主题消息、订阅mqtt主题消息的命令

服务启动成功后进行发布mqtt主题消息和订阅测试,用于本地调试测试用

mosquitto源码地址:

GitHub - eclipse/mosquitto: Eclipse Mosquitto - An open source MQTT broker

文档中明确指出发布和订阅主题的指令

发布:

mosquitto_pub -t 'test/topic' -m 'hello world'

订阅:

mosquitto_sub -t 'test/topic' -v

更多订阅指令说明,参照:

mosquitto_sub man page | Eclipse Mosquitto

下面在同一台服务器进行测试

发布mqtt主题与消息

mosquitto_pub -h localhost -t "test" -u badao -P badao -m "hello"

订阅主题与接受消息

mosquitto_sub -h localhost -t "test" -u badao -P badao

测试结果

Linux中实现记录MQTT主题消息内容和当前时间到文件中的指令

执行如下指令

mosquitto_sub -h localhost -t "test" -u badao -P badao | while read payload; do echo "$(date): $payload" >> mqtt_data.log; done

然后再次发布主题消息,在上面指令执行的目录下查看mqtt_data.log文件内容即可

相关文章:

  • 北京网站建设多少钱?
  • 辽宁网页制作哪家好_网站建设
  • 高端品牌网站建设_汉中网站制作
  • 爬虫的流程
  • 【Docker】Docker 常见问题及解决方案
  • MyBatis-Plus 分页插件
  • Gitee基本指令操作
  • 华硕电脑用U盘方式重装系统
  • 【iOS】push和pop、present和dismiss
  • 记某学校小程序漏洞挖掘
  • 13年408计算机考研-计算机网络
  • 深度解读 2024 Gartner DevOps 魔力象限
  • 基于YOLOv5s的无人机航拍输电线瓷瓶检测(附数据集与操作步骤)
  • LLM - 理解 多模态大语言模型(MLLM) 的 对齐微调(Alignment) 与相关技术 (五)
  • DK5V100R20HL贴片12V 2.7A同步整流芯片
  • TensorRT-LLM——优化大型语言模型推理以实现最大性能的综合指南
  • 多目相机贴图
  • 【项目】多设计模式下的同步异步日志系统
  • 【comparator, comparable】小总结
  • Android Volley源码解析
  • CoolViewPager:即刻刷新,自定义边缘效果颜色,双向自动循环,内置垂直切换效果,想要的都在这里...
  • co模块的前端实现
  • React中的“虫洞”——Context
  • Spring Cloud Feign的两种使用姿势
  • windows-nginx-https-本地配置
  • 闭包,sync使用细节
  • 蓝海存储开关机注意事项总结
  • 猫头鹰的深夜翻译:Java 2D Graphics, 简单的仿射变换
  • 前端每日实战:70# 视频演示如何用纯 CSS 创作一只徘徊的果冻怪兽
  • 如何优雅地使用 Sublime Text
  • 一、python与pycharm的安装
  • 在Unity中实现一个简单的消息管理器
  • 掌握面试——弹出框的实现(一道题中包含布局/js设计模式)
  • 容器镜像
  • ​软考-高级-信息系统项目管理师教程 第四版【第19章-配置与变更管理-思维导图】​
  • #70结构体案例1(导师,学生,成绩)
  • #我与Java虚拟机的故事#连载13:有这本书就够了
  • (1)安装hadoop之虚拟机准备(配置IP与主机名)
  • (day18) leetcode 204.计数质数
  • (Matalb回归预测)PSO-BP粒子群算法优化BP神经网络的多维回归预测
  • (八十八)VFL语言初步 - 实现布局
  • (附源码)ssm失物招领系统 毕业设计 182317
  • (附源码)计算机毕业设计ssm基于Internet快递柜管理系统
  • (力扣记录)235. 二叉搜索树的最近公共祖先
  • (四)c52学习之旅-流水LED灯
  • (五)网络优化与超参数选择--九五小庞
  • (限时免费)震惊!流落人间的haproxy宝典被找到了!一切玄妙尽在此处!
  • (转)Unity3DUnity3D在android下调试
  • (转载)虚函数剖析
  • .bat批处理(四):路径相关%cd%和%~dp0的区别
  • .helper勒索病毒的最新威胁:如何恢复您的数据?
  • .Net Core/.Net6/.Net8 ,启动配置/Program.cs 配置
  • .NET/C# 项目如何优雅地设置条件编译符号?
  • []利用定点式具实现:文件读取,完成不同进制之间的
  • [1525]字符统计2 (哈希)SDUT
  • [20190416]完善shared latch测试脚本2.txt
  • [AutoSar]BSW_Com02 PDU详解
  • [AutoSar]工程中的cpuload陷阱(三)测试