| #include <stdio.h> |
| #include "mbtk_mqtt.h" |
| #include "pthread.h" |
| #include "string.h" |
| #include "unistd.h" |
| #include "sys/stat.h" |
| #include "sys/types.h" |
| #include "sys/socket.h" |
| #include "netinet/in.h" |
| #include "arpa/inet.h" |
| #include "fcntl.h" |
| #include "mbtk_sock2.h" |
| /* |
| typedef struct { |
| char clientId[255]; |
| char deviceToken[255]; |
| } regnwl_info_t; |
| */ |
| |
| int aliyun_xiyinyimi_connect(mbtk_mqtt_device_session_t *device, regnwl_info_t *regn); |
| |
| struct opts_struct opts = { |
| (char *)"iot-dev", 0, (char *)"\n", QOS0, "admin", "password", (char *)"localhost", 1883, 0 |
| };//初始化结构体 |
| |
| iot_device_info_t gateway = { |
| .iotstatus = IOT_STATUS_LOGIN, |
| .model = {"2022"}, |
| .company = {"/my"} |
| };//初始化主题 |
| |
| static Cloud_MQTT_t *miot_mqtt; |
| |
| void set_mqtt_t(Cloud_MQTT_t *piot_mqtt) |
| { |
| miot_mqtt = piot_mqtt; |
| } |
| Cloud_MQTT_t * get_mqtt_t() |
| { |
| return miot_mqtt; |
| } |
| |
| void mqtt_data_rx_cb(void *pbuf, int len) |
| { |
| |
| printf("data = %s\n", (unsigned char *)pbuf); //打印接收到的数据 |
| } |
| |
| |
| void MQTTMessageArrived_Cb(MessageData* md) |
| { |
| MQTTMessage *message = md->message; |
| |
| Cloud_MQTT_t *piot_mqtt = get_mqtt_t(); |
| |
| if (NULL != piot_mqtt->DataArrived_Cb) { |
| piot_mqtt->DataArrived_Cb((void *)message->payload, message->payloadlen);//异步消息体 |
| } |
| } |
| |
| |
| void *mqtt_thread(void *arg) |
| { |
| while (gateway.iotstatus != IOT_STATUS_DROP){ |
| printf("gateway.iotstatus is %d\n",gateway.iotstatus); |
| iot_yield(arg,&gateway); //维持服务器稳定,断开重连 |
| } |
| printf("gateway.iotstatus is IOT_STATUS_DROP"); |
| // mqtt_device_disconnect(arg); |
| pthread_exit(NULL); |
| return NULL; |
| } |
| |
| |
| |
| //int mbtk_aliyun_mqtt_register_init(mbtk_mqtt_device_session_t *mbtk_mqtt_device ) |
| int main(int argc, char *argv[]) |
| { |
| |
| printf("aliyun mqtt start2\n"); |
| int ret, len; |
| char will_msg[256] = {"hello world"}; //初始化遗嘱数据 |
| static int i = 0; |
| |
| mbtk_mqtt_device_session_t mbtk_mqtt_device = {0}; |
| memcpy(mbtk_mqtt_device.device_name, argv[1] , strlen(argv[1])); |
| memcpy(mbtk_mqtt_device.product_key, "a14Vv4QUPeP" , strlen("a14Vv4QUPeP")); |
| memcpy(mbtk_mqtt_device.product_secret, "GiBigxEaluyAPnD4" , strlen( "GiBigxEaluyAPnD4")); |
| mbtk_mqtt_device.host = 0; |
| mbtk_mqtt_device.port = 1883; |
| |
| |
| Cloud_MQTT_t *Iot_mqtt; |
| Iot_mqtt = (Cloud_MQTT_t *)malloc(sizeof(Cloud_MQTT_t)); |
| memset(Iot_mqtt,0x0,sizeof(Cloud_MQTT_t)); |
| |
| //一型一密免预注册mqtt |
| mbtk_aliyun_mqtt_one_type_one_secret_unregin_set_info_init(Iot_mqtt, &mbtk_mqtt_device,60*1000,4,mqtt_data_rx_cb); |
| |
| mqtt_will_msg_set(Iot_mqtt, will_msg, strlen(will_msg)); //设置遗嘱 |
| set_mqtt_t(Iot_mqtt); |
| ret = mbtk_aliyun_mqtt_one_type_one_secret_unregin_device_connect(Iot_mqtt); //初始化并连接mqtt服务器 |
| |
| printf("connect success\n"); |
| int rc = mbtk_MQTTSubscribe(&Iot_mqtt->Client, Iot_mqtt->sub_topic, opts.qos, MQTTMessageArrived_Cb); |
| if (rc) { |
| printf("mqtt subscribe fail \n"); |
| char clientId[255] = {0}; |
| char deviceToken[255] = {0}; |
| if(! mbtk_aliyun_mqtt_one_type_one_secret_unregin_get_regin_info(clientId, deviceToken) ) |
| { |
| regnwl_info_t regn_info = {0}; |
| memcpy(regn_info.clientId,clientId , strlen(clientId)); |
| memcpy(regn_info.deviceToken, deviceToken , strlen(deviceToken)); |
| printf("example\n"); |
| printf("%s\n, %s\n", clientId, deviceToken); |
| aliyun_xiyinyimi_connect(&mbtk_mqtt_device, ®n_info); |
| } |
| } |
| |
| return 0; |
| } |
| |
| int aliyun_xiyinyimi_connect(mbtk_mqtt_device_session_t *device, regnwl_info_t *regn) |
| { |
| |
| int ret, len; |
| char will_msg[256] = {"hello world"}; //初始化遗嘱数据 |
| static int retry_count = 0; |
| pthread_t thread_ID; //定义线程id |
| static int i = 0; |
| |
| Cloud_MQTT_t *Iot_mqtt; |
| Iot_mqtt = (Cloud_MQTT_t *)malloc(sizeof(Cloud_MQTT_t)); |
| memset(Iot_mqtt,0x0,sizeof(Cloud_MQTT_t)); |
| |
| |
| iot_aliyun_mqtt_one_type_one_secret_unregin_connect_init(Iot_mqtt,device, regn->clientId, regn->deviceToken, 30,3,"aaa","aaa",mqtt_data_rx_cb); |
| |
| // iot_mqtt_init(Iot_mqtt,host,port, client, user, pass,30,3,"aaa","aaa",mqtt_data_rx_cb); |
| |
| mqtt_will_msg_set(Iot_mqtt, will_msg, strlen(will_msg)); //设置遗嘱 |
| |
| set_mqtt_t(Iot_mqtt); |
| ret = mqtt_device_connect(Iot_mqtt); //初始化并连接mqtt服务器 |
| |
| |
| while (ret < 0 && retry_count <= 5) { |
| printf("ret = %d\r\n", ret); |
| retry_count ++ ; |
| printf("retry_count = %d\n",retry_count); |
| sleep(3); |
| ret = mqtt_device_connect(Iot_mqtt); |
| } |
| if(ret < 0 && retry_count > 5) |
| { |
| printf("reconnect times more than 5 exit\n"); |
| return NULL; |
| } |
| retry_count = 0; |
| |
| printf("connect success\n"); |
| int rc = mbtk_MQTTSubscribe(&Iot_mqtt->Client, Iot_mqtt->sub_topic, opts.qos, MQTTMessageArrived_Cb); |
| if (rc) { |
| printf("mqtt subscribe fail \n"); |
| ret = -105; |
| return 0; |
| } |
| gateway.iotstatus = IOT_STATUS_CONNECT; |
| |
| pthread_create(&thread_ID, NULL, &mqtt_thread, (void *)Iot_mqtt); //创建一个线程执行mqtt客户端 |
| pthread_detach(thread_ID); //设置线程结束收尸 |
| |
| while (1) |
| { |
| mbtk_MQTTPublish("my yes", 6, 0,&Iot_mqtt->Client,Iot_mqtt->pub_topic,2,0);//循环发布"my yes" |
| sleep(3); //睡眠3s |
| i++; |
| if (i > 5) |
| { |
| mbtk_MQTTUnsubscribe(&Iot_mqtt->Client,Iot_mqtt->sub_topic); |
| break; |
| } |
| } |
| return 0; |
| } |
| |
| |
| |
| |