c语言 api,c API 文档

DMS C Asynchronous API

头文件

#include "DMSAsyncApi.h"

创建客户端对象

#define ADDRESS "tcp://mqtt.dms.aodianyun.com:1883"

#define CLIENTID "Publisher0"

DMSAsync client;

//创建客户端对象,失败返回 NULL

client = DMSAsync_create(ADDRESS, CLIENTID);

设置回调函数

//成功返回 DMSASYNC_SUCCESS，失败返回 DMSASYNC_FAILURE

//第二个参数为传递给回调函数的context

DMSAsync_setCallbacks(client, client, connectionLost, messageArrived, deliveryComplete);

回调函数定义

int messageArrived(void *context, char *topicName, int topicLen, DMSAsync_message *message)

{

printf("messageArrived-->%s:%.*s\n", topicName, message->payloadlen, (char*)message->payload);

fflush(stdout);

DMSAsync_freeMessage(&message);

DMSAsync_free(topicName);

return 1;

}

void connectionLost(void *conte