C/C++教程
利用mosquitto库上报数据到阿里云——C语言编程
本文主要是介绍利用mosquitto库上报数据到阿里云——C语言编程，对大家解决编程问题具有一定的参考价值，需要的程序猿们随着小编来一起学习吧！
目录
- mosquitto库简介：
- 使用到的mosquitto库提供的API
- 使用到的cJSON库提供的API
- 源码：
mosquitto库简介：
使用到的mosquitto库提供的API
这里我只列出了我使用到的函数
这里面的参数和返回值以及具体的用法我想大家百度就可以很容易知道了
要了解更多可以参考：https://mosquitto.org/api/files/mosquitto-h.html
mosquitto_lib_init() //Must be called before any other mosquitto functions. mosquitto_new() //Create a new mosquitto client instance. mosquitto_username_pw_set() //Configure username and password for a mosquitto instance. mosquitto_connect() //Connect to an MQTT broker. mosquitto_connect_callback_set() //Set the connect callback. mosquitto_loop_forever() //This function call loop() for you in an infinite blocking loop. mosquitto_publish() //Publish a message on a given topic. mosquitto_disconnect() //Disconnect from the broker. mosquitto_destroy() //Use to free memory associated with a mosquitto client instance. mosquitto_lib_cleanup() //Call to free resources associated with the library.
我使用的是短连接，所以每一次发送完数据都会调用mosquitto_disconnect()
使用到的cJSON库提供的API
通过MQTT协议上报数据到阿里云数据格式是JSON格式，所以我们要用到cJSON库，把我们要发送的数据打包成JSON格式。
下载编译好cJSON库之后，我们可以直接使用其目录下的cJSON.c和cJSON.H文件进行编程
所以的cJSON函数定义在cJSON.c文中，在cJSON.h头文件中声明，想要了解更多的可以进去打卡看
cJSON_CreateObject()//创建一个json对象，返回一个cJSON结构体类型的指针 cjson_params()//添加一个嵌套的JSON数据 cJSON_AddNumberToObject() cJSON_AddItemToObject () cJSON_Print() cJSON_Delete()
源码：
.c 文件
/*********************************************************************************
* Copyright: (C) 2021 li liangshi<1007146932@qq.com>
* All rights reserved.
*
* Filename: mosquitto_pub.c
* Description: This file is mosquitto_pub to aliyun
*
* Version: 1.0.0(2021年08月06日)
* Author: li liangshi <1007146932@qq.com>
* ChangeLog: 1, Release initial version on "2021年08月06日 00时33分39秒"
*
********************************************************************************/
#include "mosquitto_pub.h"
static int g_stop = 0;
void sig_handle(int signum)
{
if(SIGUSR1 == signum)
{
g_stop = 1;
}
}
int main (int argc, char **argv)
{
struct mosquitto *mosqut;
mosquitto_t mosquitto;
int rv = -1;
memset(&mosquitto, 0, sizeof(mosquitto));
rv = init_mosquitto_argc(argc, argv, &mosquitto);
if(rv)
{
printf("Init mosquitto arguments error:%s\n", strerror(errno));
}
signal(SIGUSR1,sig_handle);
rv = mosquitto_pub_start(mosqut, &mosquitto);
if(rv)
{
printf("mosquitto subscribe start error:%s\n", strerror(errno));
}
return 0;
}
int init_mosquitto_argc (int argc, char **argv, mosquitto_t *mosquitto)
{
if (argc < 0 )
return -1;
int ch = -1;
struct option opts[] = {
{"--host", required_argument, NULL, 'H'},
{"--port", required_argument, NULL, 'p'},
{"--topic", required_argument, NULL, 't'},
{"--client_id", required_argument, NULL, 'i'},
{"--user", required_argument, NULL, 'u'},
{"--password", required_argument, NULL, 'P'},
{"--keepalive", required_argument, NULL, 'l'},
{"help", no_argument, NULL, 'h'},
{NULL, 0, NULL, 0 }
};
while((ch=getopt_long(argc, argv, "H:p:t:i:u:P:l:h", opts, NULL)) != -1 )
{
switch(ch)
{
case 'H':
mosquitto->host = optarg;
break;
case 'p':
mosquitto->port = atoi(optarg);
break;
case 't':
mosquitto->topic = optarg;
break;
case 'i':
mosquitto->client_id = optarg;
break;
case 'u':
mosquitto->user = optarg;
break;
case 'P':
mosquitto->password = optarg;
break;
case 'l':
mosquitto->keepalive = atoi(optarg);
break;
case 'h':
print_usage(argv[0]);
return -1;
}
}
if (NULL == mosquitto->host || !mosquitto->keepalive ||!mosquitto->port || NULL == mosquitto->client_id || NULL == mosquitto->password || NULL == mosquitto->user || NULL == mosquitto->topic)
{
print_usage(argv[0]);
return -1;
}
return 0;
}
static void print_usage (char *progname)
{
printf("%s usage : \n", progname);
printf("-H(--host):Input the Aliyun equioment host name.\n");
printf("-p(--port):Input the Aliyun equioment host port.\n");
printf("-i(--client_id):Input the Aliyun equioment client id.\n");
printf("-t(--topic):Input the Aliyun equioment subscribe topic.\n");
printf("-u(--user):Input the Aliyun equioment user name.\n");
printf("-P(--password):Input the Aliyun equioment user's password name.\n");
printf("-l(--keepalive):Input the keepalive.\n");
printf("-h(--help): print this help information.\n");
return ;
}
int mosquitto_pub_start (struct mosquitto *mosqut, mosquitto_t *mosquitto)
{
int rv = 1;
//初始化mosquitto lib
rv = mosquitto_lib_init();
if(rv != MOSQ_ERR_SUCCESS)
{
printf("mosquitto lib init failure:%s\n", strerror(errno));
goto cleanup;
}
//创建一个新的mosquitto实例
mosqut = mosquitto_new(mosquitto->client_id, false, (void *)mosquitto);
if(!mosqut)
{
printf("Mosquitto_new failure:%s\n", strerror(errno));
goto cleanup;
}
printf("mosquitto_new successfully!\n");
//设置回调函数
mosquitto_connect_callback_set(mosqut, connect_pub_callback);
printf("0\n");
if( mosquitto_username_pw_set(mosqut, mosquitto->user, mosquitto->password))
{
printf("mosquitto username and password failure:%s\n", strerror(errno));
goto cleanup;
}
printf("1\n");
while(!g_stop)
{
//连接mqtt服务器
rv = mosquitto_connect(mosqut, mosquitto->host, mosquitto->port, mosquitto->keepalive);
if(rv)
{
printf("Connect to mqtt server failure:%s\n", strerror(errno));
sleep(2);
continue;
}
printf("Connect to mqtt server successfully!\n");
rv = mosquitto_loop_forever(mosqut, -1, 1);
printf("2\n");
sleep(10);
if(rv != MOSQ_ERR_SUCCESS)
{
printf("3\n");
printf("%s\n", strerror(errno));
goto cleanup;
}
}
printf("mosquitto_pub close\n");
return 0;
cleanup:
printf("mosquitto_pub start failure!\n");
mosquitto_destroy(mosqut); //释放mosquitto实例关联的内存
mosquitto_lib_cleanup(); //释放库相关的资源
return 0;
}
void connect_pub_callback (struct mosquitto *mosqut, void *obj, int rc)
{
cJSON* cjson_msg = NULL;
cJSON* cjson_properties = NULL;
char* str;
double temp;
char *datetime;
char *id = "JMQ";
int mid;
mosquitto_t *mosq;
mosq = (mosquitto_t*)obj;
if((temp = get_temp()) < 0 )
{
printf("get temp failuer\n");
}
printf("get temp: %.2f摄氏度\n",temp);
datetime = get_date_time(datetime);
printf("data is:%s\n",datetime);
/* 创建一个JSON数据对象(链表头结点) */
cjson_msg = cJSON_CreateObject();
/* 添加一个嵌套的JSON数据*/
cJSON* cjson_params = cJSON_CreateObject();
cJSON_AddNumberToObject(cjson_params,"CurrentTemperature",temp);
cJSON_AddItemToObject(cjson_msg,"params",cjson_params);
str = cJSON_Print(cjson_msg);
printf("%s\n", str);
if(rc==0)
{
if(mosquitto_publish(mosqut,&mid,mosq->topic,strlen(str)+1,str,0,true)!=MOSQ_ERR_SUCCESS)
{
printf("Mosquitto Pub failure: %s\n",strerror(errno));
return;
}
printf("Mosquitto Pub success,pub_topic:%s\n",mosq->topic);
printf(" rc:%d\n",rc);
}
mosquitto_disconnect(mosqut);
cJSON_Delete(cjson_msg);
}
char *get_date_time (char *datetime)
{
char timechar[1024] = {};
struct tm *p;
time_t now;
time(&now);
p = localtime(&now);
sprintf(timechar, "%d-%d-%d %d:%d:%d", p->tm_year+1900, p->tm_mon+1, p->tm_mday, p->tm_hour, p->tm_min, p->tm_sec);
datetime = timechar;
return datetime;
}
float get_temp ()
{
char buff[512];
char distination_file[128];
char dirpath[200] ="/home/lls/apue/";
int fd,data_size;
//打开指定打目录dirpath
DIR * dir = opendir(dirpath);
struct dirent *direntp;
assert(dir != NULL);
//列出dir里面所以的文件夹和文件
while((direntp = readdir(dir)) !=NULL)
{
//拿文件名的前俩位和28比较，如果有一个文件的名字前俩个字符是28,则返回0
if(strncmp(direntp->d_name,"28",2) == 0)
{
//将dirpath和ent->d_name写入到fw_file这个字符数组中
sprintf(distination_file,"%s%s%s",dirpath,direntp->d_name,"/w1_slave");
fd = open(distination_file, O_RDONLY);
//使文件偏移量移到文件尾，得到文件内容大小
data_size = lseek(fd, 0, SEEK_END);
//然后又使文件偏移量移到文件头，这样才能读文件的内容
lseek(fd, 0, SEEK_SET);
if(data_size=0)
printf("这是个空文件\n");
read(fd,buff,sizeof(buff));
//strstr函数返回字符“t=”buff字符串中首次出现的地址
char *C = strstr(buff,"t=");
float tem = atof((C+2))/1000;
printf("读到的数据为：%.2f\n",tem);
return (tem);
}
}
closedir(dir);
}
.h文件
/********************************************************************************
* Copyright: (C) 2021 li liangshi<1007146932@qq.com>
* All rights reserved.
*
* Filename: mosquitto_pub.h
* Description: This head file is mosquitto_sub.h
*
* Version: 1.0.0(2021年08月06日)
* Author: li liangshi <1007146932@qq.com>
* ChangeLog: 1, Release initial version on "2021年08月06日 00时14分17秒"
*
********************************************************************************/
#ifndef _MOSQUITTO_PUB_H_
#define _MOSQUITTO_PUB_H_
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <getopt.h>
#include <unistd.h>
#include <errno.h>
#include "mosquitto.h"
#include <assert.h>
#include <sys/types.h>
#include <dirent.h>
#include <fcntl.h>
#include <signal.h>
#include <time.h>
#include "cJSON.h"
#include "mosquitto.h"
typedef struct mosquitto_s
{
char *host;
int port;
char *topic;
char *client_id;
char *user;
char *password;
int keepalive;
char pub_message;
}mosquitto_t;
int init_mosquitto_argc (int argc, char **argv, mosquitto_t *mosquitto);
static void print_usage (char *progname);
int mosquitto_pub_start (struct mosquitto *mosqut, mosquitto_t *mosquitto);
void connect_pub_callback (struct mosquitto *mosqut, void *obj, int rc);
char *get_date_time (char *datetime);
float get_temp ();
#endif /* ----- #ifndef _MOSQUITTO_PUB_H_ ----- */
Makefile文件：
VAR=-l
CC=gcc
all:
${CC} *.c -o pub ${VAR}mosquitto
run:
./pub -H "a1xIDqTDkl.iot-as-mqtt.cn-shanghai.aliyuncs.com" -p 1883 -t "/sys/a1xIDqXTDkl/OGlOu7TXgXgItc8UkA9C/thing/event/property/post" -i "hhh|securemode=3,signmethod=hmacsha1,timestamp=60|" -u "OGlOuTXgXgItc8UkA9C&a1xIDXTDkl" -P "1B8BB1F11F7F05D4D4B842D11A1F81DE035FB7" -l 60
这篇关于利用mosquitto库上报数据到阿里云——C语言编程的文章就介绍到这儿，希望我们推荐的文章对大家有所帮助，也希望大家多多支持为之网！
您可能喜欢
-
微信支付提示下单账户与支付账户不一致-icode9专业技术文章分享07-03
-
微信支付提示订单号重复-icode9专业技术文章分享07-03
-
微服务启动nacos注册上去了，但是一直没有收到请求-icode9专业技术文章分享07-02
-
如何检查文件的编码格式-icode9专业技术文章分享07-02
-
sublime 更改编码格式-icode9专业技术文章分享07-02
-
uniAPP 实现全屏左右滚动滚动的效果-icode9专业技术文章分享06-30
-
如何在本地使用授权或插件-icode9专业技术文章分享06-30
-
伪静态规则配置方法汇总-icode9专业技术文章分享06-30
-
易优CMS安装常见问题汇总-icode9专业技术文章分享06-29
-
易优新手必读安装教程-icode9专业技术文章分享06-28
-
忘记eyoucms后台密码怎么办？-icode9专业技术文章分享06-28
-
终极指南：Scrum中如何设置需求优先级06-26
-
AI大模型企业应用实战(25)-为Langchain Agent添加记忆功能06-26
-
小白家庭 nas 搭建方案-icode9专业技术文章分享06-26
-
AI大模型企业应用实战(14)-langchain的Embedding06-23
栏目导航
