基于MQTT协议的Mosquitto的使用及libmosquitto客户端编程
概述:工作之余学习mqtt,使用开源的Mosquitto实现mqtt的使用。如:broker(服务器/代理),消息订阅及发布。
系统环境:ubuntu14.04
1,MQTT简介
MQTT 是一个轻量级协议,使用基于 TCP/IP 协议的发布/订阅消息转发模式,在物联网应用中大规模使用。 MQTT 协议的中心是 broker( 服务器/代理) ,客户端通过订阅消息和发布消息进行数据交互 ,如下图所示:
2,Mosquitto安装
(1)mosquitto下载
下载地址,进入下载页面,选择source中第一个下载mosquitto-1.4.9.tar.gz
(2)mosquitto依赖库安装
$ sudo apt-get install libssl-dev
$ sudo apt-get install libc-ares-dev
$ sudo apt-get install uuid-dev
(3)mosquitto的安装
//解压
$ tar zxvf mosquitto-1.4.9.tar.gz
$ cd mosquitto-1.4.9
$ make
$ sudo make install
(4)编译问题解决
如果出现error while loading shared libraries: libmosquitto.so.1: cannot open shared object file: No such file or directory
//创建链接
$ sudo ln -s /usr/local/lib/libmosquitto.so.1 /usr/lib/libmosquitto.so.1
//更新链接
$ sudo ldconfig
3,mosquitto使用
进入命令行界面
(1)启动mosquitto服务器
$ mosquitto -v
(2)订阅消息(如topic)
$ mosquitto_sub -v -t topic
(3)发布消息
$ mosquitto_pub -t topic -m good
效果如下图所示:
4,libmosquitto客户端编程(发布消息,订阅消息)
在安装mosquitto成功后,可以在/usr/local/lib文件夹中有libmosquitto.so.1等文件,如下图所示:
这里贴一个demo
客户端(订阅消息)
#include <stdio.h>
#include <stdlib.h>
#include <mosquitto.h>
#include <string.h>#define HOST "localhost"
#define PORT 1883
#define KEEP_ALIVE 60bool session = true;void my_message_callback(struct mosquitto *mosq, void *userdata, const struct mosquitto_message *message)
{if(message->payloadlen){printf("%s %s", message->topic, message->payload);}else{printf("%s (null)\n", message->topic);}fflush(stdout);
}void my_connect_callback(struct mosquitto *mosq, void *userdata, int result)
{int i;if(!result){/* Subscribe to broker information topics on successful connect. */mosquitto_subscribe(mosq, NULL, "Gai爷:", 2);}else{fprintf(stderr, "Connect failed\n");}
}void my_subscribe_callback(struct mosquitto *mosq, void *userdata, int mid, int qos_count, const int *granted_qos)
{int i;printf("Subscribed (mid: %d): %d", mid, granted_qos[0]);for(i=1; i<qos_count; i++){printf(", %d", granted_qos[i]);}printf("\n");
}void my_log_callback(struct mosquitto *mosq, void *userdata, int level, const char *str)
{/* Pring all log messages regardless of level. */printf("%s\n", str);
}int main()
{struct mosquitto *mosq = NULL;//libmosquitto 库初始化mosquitto_lib_init();//创建mosquitto客户端mosq = mosquitto_new(NULL,session,NULL);if(!mosq){printf("create client failed..\n");mosquitto_lib_cleanup();return 1;}//设置回调函数,需要时可使用//mosquitto_log_callback_set(mosq, my_log_callback);mosquitto_connect_callback_set(mosq, my_connect_callback);mosquitto_message_callback_set(mosq, my_message_callback);//mosquitto_subscribe_callback_set(mosq, my_subscribe_callback);//客户端连接服务器if(mosquitto_connect(mosq, HOST, PORT, KEEP_ALIVE)){fprintf(stderr, "Unable to connect.\n");return 1;}//循环处理网络消息mosquitto_loop_forever(mosq, -1, 1);mosquitto_destroy(mosq);mosquitto_lib_cleanup();return 0;
}
客户端(发布消息)
#include <stdio.h>
#include <stdlib.h>
#include <mosquitto.h>
#include <string.h>#define HOST "localhost"
#define PORT 1883
#define KEEP_ALIVE 60
#define MSG_MAX_SIZE 512bool session = true;int main()
{char buff[MSG_MAX_SIZE];struct mosquitto *mosq = NULL;//libmosquitto 库初始化mosquitto_lib_init();//创建mosquitto客户端mosq = mosquitto_new(NULL,session,NULL);if(!mosq){printf("create client failed..\n");mosquitto_lib_cleanup();return 1;}//连接服务器if(mosquitto_connect(mosq, HOST, PORT, KEEP_ALIVE)){fprintf(stderr, "Unable to connect.\n");return 1;}//开启一个线程,在线程里不停的调用 mosquitto_loop() 来处理网络信息int loop = mosquitto_loop_start(mosq);if(loop != MOSQ_ERR_SUCCESS){printf("mosquitto loop error\n");return 1;}while(fgets(buff, MSG_MAX_SIZE, stdin) != NULL){/*发布消息*/mosquitto_publish(mosq,NULL,"Gai爷:",strlen(buff)+1,buff,0,0);memset(buff,0,sizeof(buff));}mosquitto_destroy(mosq);mosquitto_lib_cleanup();return 0;
}
注意
在编译程序时需加上-lmosquitto链接。如:
$ gcc -o mosquitto_client_sub mosquitto_client_sub.c -lmosquitto
5,客户端使用
(1)开启mosquitto服务
$ mosquitto -v
(2)启动订阅消息客户端及发布消息客户端
$ ./mosquitto_client_sub
$ ./mosquitto_client_pub
(3)效果
参考资料:
如果想详细了解mqtt中libmosquitto的使用可以看一下这篇文章。
基于MQTT协议的Mosquitto的使用及libmosquitto客户端编程相关推荐
- MQTT协议与mosquitto的安装使用
MQTT (Message Queuing Telemetry Transport,消息队列遥测传输) 是一种标准化的发布/订阅消息传输协议.它是一种非常轻量级的协议,由于对带宽需求很低,从而成为了 ...
- 电信运营商基于 MQTT 协议 构建千万级 IoT 设备管理平台
MQTT 是用于物联网的标准消息传递协议.它被设计为一种非常轻量级的发布/订阅消息传送,非常适合以较小的代码占用量和网络带宽连接远程设备.MQTT 协议具有以下特点: 轻巧高效:MQTT 客户端非常小 ...
- 基于MQTT协议的WZ指令开发V3.0版本支持onenet
title: 基于MQTT协议的WZ指令开发V3.0版本支持onenet tags: WZ指令 date: 2019-02-18 10:53:00 视频讲解:(V3.0版本)-https://www. ...
- STM32F103代码远程升级(五)基于MQTT协议WiFi远程升级代码的实现
文章目录 一.WiFi模块的选用与介绍 二.ESP8266的固件擦除与烧写 1.ESP8266 Flash擦除工具的安装与使用. 2.ESP8266固件烧写 (1)在线获取固件文件 (2)获取SDK ...
- 基于MQTT协议实现微信小程序控制树莓派
基于MQTT协议实现微信小程序控制树莓派 在我的github上有源码,大家可以直接下载来用 https://github.com/yjc-123/-MQTT- ,这里给大家说一下实现的过程. 小程序端 ...
- MQTT协议应用场景1: 外网手机客户端 与 内网树莓派3B 的通讯
实验目的:将外网手机客户端发送的字符串 通过树莓派3B的串口输出 不了解MQTT协议的请参考:MQTT协议体验 Mosquitto安装和使用 不了解使用Python操作树莓派串口的请参考:Raspbe ...
- MQTT协议之Mosquitto
MQTT协议简介 消息队列遥测传输协议 Message Queuing Telemetry Transport. Based on TCP/IP, published by IBM in 1999. ...
- MQTT协议版本Mosquitto移植到嵌入式arm平台
文章目录 前言 一.mosquitto是什么? 二.交叉编译 1.交叉编译openssl源码 2.交叉编译e2fsprogs源码 3.交叉编译c-ares源码 4.交叉编译uuid源码 5.交叉编译m ...
- 基于mqtt协议的消息推送服务器,基于 MQTT 协议的推送服务
一.简述 MQTT(Message Queuing Telemetry Transport,消息队列遥测传输协议),是一种基于发布/订阅(publish/subscribe)模式的"轻量级& ...
最新文章
- 腾讯云python环境_腾讯云centos6.5 搭建python机器学习环境
- oracle查询一个字符串所在表
- 一个完整的网上商城的源码_黄冈微信分销商城系统-源码码网
- WPF:使用Json.NET在TreeView中树形显示JSON数据
- Vue.js(5)- 全局组件
- ai皮肤检测分数_德国猫咪皮肤检测仪,为什么这么火?| 云美来
- webpack的一些plugin,怎么使用webpack对项目进行优化
- 中运量71路线路图_上海新增公交线路835路 连接中运量71路与虹桥枢纽
- linux安装jdk详细步骤,需要有一定的语法基础
- ISO14443A读卡流程(作为示例参考)
- 彭聃龄普通心理学第5版笔记和课后习题答案
- 团队领导力(一)规划+落实
- 苹果手机如何只用数据线修改定位
- python树莓派串口通信实例_使用树莓派和Python实现ModbusTCP通讯
- Windows 7 更新补丁大包子
- Eclipse 常用快捷键整理
- 卓帆宝库分享大学生如何轻松挣钱
- 产品经理和项目经理的差异
- 如何用 ARKit 将太阳系装进 iPhone(二)
- Python入门自学进阶-Web框架——16、Django登录/注册