準(zhǔn)備開發(fā)環(huán)境

本示例使用Ubuntu 16.04-LTS作為開發(fā)環(huán)境。執(zhí)行以下命令構(gòu)建開發(fā)環(huán)境。

sudo apt-get update sudo apt-get install build-essential git sed cmake

下載C語言Paho MQTT庫

執(zhí)行以下命令，克隆C語言版本的Paho MQTT庫。

git clone git@github.com:eclipse/paho.mqtt.embedded-c.git

Paho嵌入式C工程提供了三個(gè)子項(xiàng)目。

• MQTTPacket：提供MQTT數(shù)據(jù)包的序列化與反序列化，以及部分輔助函數(shù)。

• MQTTClient：封裝MQTTPacket生成的高級(jí)別C++客戶端程序。

• MQTTClient-C：封裝MQTTPacket生成的高級(jí)別C客戶端程序。

  MQTTClient-C中包含：

  ├── CMakeLists.txt ├── samples │   ├── CMakeLists.txt │   ├── FreeRTOS │   └── linux ├── src │   ├── CMakeLists.txt │   ├── FreeRTOS │   ├── MQTTClient.c │   ├── MQTTClient.h │   ├── cc3200 │   └── linux └── test     ├── CMakeLists.txt     └── test1.c

  了解Paho MQTT的更多API細(xì)節(jié)，可以查看MQTTClient.h。

• samples目錄提供FreeRTOS和linux兩個(gè)例程，分別支持FreeRTOS和Linux系統(tǒng)。

• src目錄提供MQTTClient的代碼實(shí)現(xiàn)能力，以及用于移植到FreeRTOS、cc3200和Linux的網(wǎng)絡(luò)驅(qū)動(dòng)。

接入物聯(lián)網(wǎng)平臺(tái)

1. 單擊打開aiot_mqtt_sign.c，下載阿里云提供的計(jì)算MQTT連接參數(shù)所需的源碼。

   aiot_mqtt_sign.c文件定義了函數(shù)aiotMqttSign()。函數(shù)說明如下。

• 原型

  int aiotMqttSign(const char *productKey, const char *deviceName, const char *deviceSecret,                  char clientId[150], char username[65], char password[65]);

• 功能

  用于計(jì)算設(shè)備接入物聯(lián)網(wǎng)平臺(tái)的MQTT連接參數(shù)username、password和clientid。

• 輸入?yún)?shù)

  參數(shù)	類型	說明
  productKey	const char *	設(shè)備所屬產(chǎn)品的ProductKey，該設(shè)備在物聯(lián)網(wǎng)平臺(tái)上的身份證書信息之一。
  deviceName	const char *	設(shè)備名稱，該設(shè)備在物聯(lián)網(wǎng)平臺(tái)上的身份證書信息之一。
  deviceSecret	const char *	設(shè)備密鑰，該設(shè)備在物聯(lián)網(wǎng)平臺(tái)上的身份證書信息之一。

• 輸出參數(shù)

  參數(shù)	類型	說明
  username	char *	MQTT連接所需的用戶名。
  password	char *	MQTT連接所需的密碼。
  clientId	char *	MQTT客戶端ID。

• 返回碼說明

  返回碼	說明
  0	成功
  -1	失敗

2. 添加實(shí)現(xiàn)設(shè)備接入物聯(lián)網(wǎng)平臺(tái)的程序文件。

   您需編寫程序調(diào)用aiot_mqtt_sign.c中的aiotMqttSign()函數(shù)計(jì)算MQTT連接參數(shù)，實(shí)現(xiàn)接入物聯(lián)網(wǎng)平臺(tái)和通信。

   開發(fā)說明和示例代碼如下。

   關(guān)于設(shè)備、服務(wù)器和物聯(lián)網(wǎng)平臺(tái)的通信方式介紹，請(qǐng)參見通信方式概述。

• 調(diào)用NetworkInit和NetworkConnect建立TCP連接。

• 調(diào)用MQTTClientInit初始化MQTT客戶端。

• 配置MQTT建連參數(shù)結(jié)構(gòu)體MQTTPacket_connectData。

• 調(diào)用aiotMqttSign()接口，生成連接MQTT服務(wù)端的三個(gè)建連參數(shù)clientId、username和password。

  #define EXAMPLE_PRODUCT_KEY            "a11xsrW****" #define EXAMPLE_DEVICE_NAME            "paho_****" #define EXAMPLE_DEVICE_SECRET       "Y877Bgo8X5owd3lcB5wWDjryNPoB****" extern int aiotMqttSign(const char *productKey, const char *deviceName, const char *deviceSecret,                         char clientId[150], char username[65], char password[65]); /* invoke aiotMqttSign to generate mqtt connect parameters */ char clientId[150] = {0}; char username[65] = {0}; char password[65] = {0}; if ((rc = aiotMqttSign(EXAMPLE_PRODUCT_KEY, EXAMPLE_DEVICE_NAME, EXAMPLE_DEVICE_SECRET, clientId, username, password) < 0)) {     printf("aiotMqttSign -%0x4x\n", -rc);     return -1; } printf("clientid: %s\n", clientId); printf("username: %s\n", username); printf("password: %s\n", password);

• 接入物聯(lián)網(wǎng)平臺(tái)。

  需配置以下內(nèi)容：

  示例代碼：

  /* network init and establish network to aliyun IoT platform */ NetworkInit(&n); rc = NetworkConnect(&n, host, port); printf("NetworkConnect %d\n", rc); /* init mqtt client */ MQTTClientInit(&c, &n, 1000, buf, sizeof(buf), readbuf, sizeof(readbuf)); /* set the default message handler */ c.defaultMessageHandler = messageArrived; /* set mqtt connect parameter */ MQTTPacket_connectData data = MQTTPacket_connectData_initializer; data.willFlag = 0; data.MQTTVersion = 3; data.clientID.cstring = clientId; data.username.cstring = username; data.password.cstring = password; data.keepAliveInterval = 60; data.cleansession = 1; printf("Connecting to %s %d\n", host, port); rc = MQTTConnect(&c, &data); printf("MQTTConnect %d, Connect aliyun IoT Cloud Success!\n", rc);

• 發(fā)布消息。

  調(diào)用MQTTPublish()接口，向指定的自定義Topic發(fā)布自定義格式消息。

  char *pubTopic = "/"EXAMPLE_PRODUCT_KEY"/"EXAMPLE_DEVICE_NAME"/user/update"; int cnt = 0; unsigned int msgid = 0; while (!toStop) {     MQTTYield(&c, 1000);         if (++cnt % 5 == 0) {         MQTTMessage msg = {             QOS1,             0,             0,             0,             "Hello world",             strlen("Hello world"),         };         msg.id = ++msgid;         rc = MQTTPublish(&c, pubTopic, &msg);         printf("MQTTPublish %d, msgid %d\n", rc, msgid);     } }

  通信Topic介紹，請(qǐng)參見什么是Topic。

• 訂閱Topic，獲取云端下發(fā)的消息。

  void messageArrived(MessageData* md) {     MQTTMessage* message = md->message;     printf("%.*s\t", md->topicName->lenstring.len, md->topicName->lenstring.data);     printf("%.*s\n", (int)message->payloadlen, (char*)message->payload); } char *subTopic = "/"EXAMPLE_PRODUCT_KEY"/"EXAMPLE_DEVICE_NAME"/user/get"; printf("Subscribing to %s\n", subTopic); rc = MQTTSubscribe(&c, subTopic, 1, messageArrived); printf("MQTTSubscribe %d\n", rc);

3. 將第一步下載的aiot_mqtt_sign.c文件和第二步編輯的文件放到../paho.mqtt.embedded-c/MQTTClient-C/samples/linux中，然后編譯工程。

示例Demo

使用Demo代碼程序接入物聯(lián)網(wǎng)平臺(tái)。

1. 下載Demo包，并解壓縮。解壓縮后，代碼包里有以下兩個(gè)文件。

   . +-- aiot_c_demo.c +-- aiot_mqtt_sign.c

   文件	說明
   aiot_mqtt_sign.c	該文件中的代碼用于生成MQTT建連參數(shù)。aiot_c_demo.c運(yùn)行時(shí)，會(huì)調(diào)用該文件中定義的aiotMqttSign()函數(shù)，計(jì)算出連接參數(shù)username、password和clientId。
   aiot_c_demo.c	該文件包含設(shè)備與物聯(lián)網(wǎng)平臺(tái)連接和通信的邏輯代碼。

2. 在aiot_c_demo.c中，修改設(shè)備信息為您的設(shè)備信息。

• 將EXAMPLE_PRODUCT_KEY、EXAMPLE_DEVICE_NAME和EXAMPLE_DEVICE_SECRET替換為您的設(shè)備證書信息。

• 將char *host = EXAMPLE_PRODUCT_KEY".iot-as-mqtt.cn-shanghai.aliyuncs.com"中的地域代碼（cn-shanghai）替換為您的物聯(lián)網(wǎng)平臺(tái)設(shè)備所在地域代碼。地域代碼表達(dá)方法，請(qǐng)參見地域和可用區(qū)。

3. 將aiot_mqtt_sign.c和已修改的aiot_c_demo.c文件放到Paho工程的目錄../paho.mqtt.embedded-c/MQTTClient-C/samples/linux中。

4. 編譯工程，并運(yùn)行程序。

   有兩種方法可以編譯出可執(zhí)行的程序。

   運(yùn)行成功，接入物聯(lián)網(wǎng)平臺(tái)的本地日志如下。

   clientid: paho_mqtt&a11xsrW****|timestamp=2524608000000,_v=sdk-c-1.0.0,securemode=3,signmethod=hmacsha256,lan=C| username: paho_mqtt&a11xsrW**** password: 36E955DC3D9D012EF62C80657A29328B1CFAE6186C611A17DC7939FAB637**** NetworkConnect 0 Connecting to a11xsrW****.iot-as-mqtt.cn-shanghai.aliyuncs.com 443 MQTTConnect 0, Connect aliyun IoT Cloud Success! Subscribing to /a11xsrW****/paho_mqtt/user/get MQTTSubscribe 0 MQTTPublish 0, msgid 1 MQTTPublish 0, msgid 2 MQTTPublish 0, msgid 3 MQTTPublish 0, msgid 4 MQTTPublish 0, msgid 5 ...

   在物聯(lián)網(wǎng)平臺(tái)控制臺(tái)上，可查看設(shè)備狀態(tài)和日志。

• 選擇設(shè)備管理 > 設(shè)備，可看到該設(shè)備的狀態(tài)會(huì)顯示為在線。

• 選擇監(jiān)控運(yùn)維 > 日志服務(wù)，可查看云端運(yùn)行日志和設(shè)備本地日志日志。詳情請(qǐng)參見云端運(yùn)行日志、設(shè)備本地日志。

• 使用CMake。

• 使用build.sh。

1. 修改/paho.mqtt.embedded-c/MQTTClient-C/samples/linux目錄下的build.sh文件為以下內(nèi)容。

   cp ../../src/MQTTClient.c . sed -e 's/""/"MQTTLinux.h"/g' ../../src/MQTTClient.h > MQTTClient.h gcc \     -o aiot_c_demo \     -I ../../src -I ../../src/linux -I ../../../MQTTPacket/src \     aiot_mqtt_sign.c aiot_c_demo.c \     MQTTClient.c \     ../../src/linux/MQTTLinux.c \     ../../../MQTTPacket/src/MQTTFormat.c \     ../../../MQTTPacket/src/MQTTPacket.c \     ../../../MQTTPacket/src/MQTTDeserializePublish.c \     ../../../MQTTPacket/src/MQTTConnectClient.c \     ../../../MQTTPacket/src/MQTTSubscribeClient.c \     ../../../MQTTPacket/src/MQTTSerializePublish.c \     ../../../MQTTPacket/src/MQTTConnectServer.c \     ../../../MQTTPacket/src/MQTTSubscribeServer.c \     ../../../MQTTPacket/src/MQTTUnsubscribeServer.c \     ../../../MQTTPacket/src/MQTTUnsubscribeClient.c

2. 修改完成后，在當(dāng)前目錄下執(zhí)行命令./build.sh，完成編譯。

   完成編譯后，生成aiot_c_demo可執(zhí)行文件。

3. 執(zhí)行命令./aiot_c_demo，運(yùn)行程序。

4. 在/paho.mqtt.embedded-c/MQTTClient-C/samples/linux目錄下的CMakeLists.txt文件中，增加aiot_c_demo.c和aiot_mqtt_sign.c。

   修改后的CMakeLists.txt文件內(nèi)容如下。

   add_executable(   stdoutsubc   stdoutsub.c ) add_executable(   aiot_c_demo   aiot_c_demo.c   aiot_mqtt_sign.c ) target_link_libraries(stdoutsubc paho-embed-mqtt3cc paho-embed-mqtt3c) target_include_directories(stdoutsubc PRIVATE "../../src" "../../src/linux") target_compile_definitions(stdoutsubc PRIVATE MQTTCLIENT_PLATFORM_HEADER=MQTTLinux.h) target_link_libraries(aiot_c_demo paho-embed-mqtt3cc paho-embed-mqtt3c) target_include_directories(aiot_c_demo PRIVATE "../../src" "../../src/linux") target_compile_definitions(aiot_c_demo PRIVATE MQTTCLIENT_PLATFORM_HEADER=MQTTLinux.h)

5. 回到/paho.mqtt.embedded-c目錄，執(zhí)行以下命令，完成編譯。

   mkdir build.paho cd build.paho cmake .. make

6. 編譯完成后，在/paho.mqtt.embedded-c/build.paho目錄下執(zhí)行以下命令，運(yùn)行程序。

   ./MQTTClient-C/samples/linux/aiot_c_demo

錯(cuò)誤碼

如果設(shè)備通過MQTT協(xié)議接入物聯(lián)網(wǎng)平臺(tái)失敗，請(qǐng)根據(jù)錯(cuò)誤碼排查問題。服務(wù)端錯(cuò)誤碼說明，請(qǐng)參見錯(cuò)誤排查