確保在“NetBurner”選項下選擇了“NetBurner Project”，然后點擊“Next”。這會將您帶到下面圖 14 中所示的窗口。

圖 14：命名您的項目

?

通常，我們在這里做的唯一一件事就是為項目命名并繼續(xù)。但是，在這種情況下，我們還將取消選中標(biāo)記為“使用默認(rèn)位置”的框，然后單擊“瀏覽”按鈕導(dǎo)航到您克隆回購的文件夾。對我們來說，這是\AwsIotCoreMqttBase。確保在標(biāo)有“工具鏈”的窗口中列出并選擇了“NetBurner 工具鏈”。

從這個窗口點擊“下一步”將帶我們到我們可以選擇我們想要構(gòu)建的配置的地方。我們希望能夠在“Debug”和“Release”模式下運行應(yīng)用程序，因此選中選項，然后再次點擊“Next”。

在下一個窗口中，如圖 15 所示，我們可以指定要為哪個平臺構(gòu)建此應(yīng)用程序。我們將選擇 MODM7AE70。如果您使用我們的其他平臺之一，請相應(yīng)地選擇它。如果您的設(shè)備已經(jīng)插入并連接到您的網(wǎng)絡(luò)，您可以通過點擊標(biāo)有“搜索”的按鈕繼續(xù)查找它的 IP 地址，然后從屏幕上彈出的列表中選擇它。

圖 15：選擇您的設(shè)備

?

如果您的設(shè)備未連接，您可以暫時忽略此字段，然后點擊“下一步”按鈕。下一個窗口顯示了一些可以自動添加到應(yīng)用程序的基本組件，但由于我們使用的是 repo 文件夾中的代碼，我們可以跳過所有這些，只需點擊“完成”。

完成此操作后，您應(yīng)該會看到您的項目已創(chuàng)建并列在 NBEclipse 左側(cè)的“項目資源管理器”選項卡中。您可能會注意到您的項目會自動從右下角的控制臺輸出開始構(gòu)建。如果我們在項目設(shè)置中正確地完成了所有操作并記得移動certificate.cpp和privatekey.cpp到\AwsIotCoreMqttBase\src，那么它應(yīng)該會成功構(gòu)建。如果您在 NBEclipse 控制臺窗口的底部看到以下內(nèi)容，您就知道您已準(zhǔn)備就緒：

圖 16：達到另一個里程碑

?

相反，如果您看到錯誤，請\AwsIotCoreMqttBase\src通過驗證所有源文件是否顯示在 src 文件夾下的“項目資源管理器”選項卡中，確保正確映射到項目中列出的 src 文件夾。還要仔細檢查是否也列出了前面部分中生成的證書和私鑰文件。

做一些改變

為了讓我們的設(shè)備成功連接到 AWS IoT Core 服務(wù)，我們需要對aws_iot_config.h源代碼中的文件進行一些更改。在 NBEclipse 中從項目的 src 文件夾中打開此文件。在此文件的頂部，定義了兩個需要修改的宏。這些是AWS_IOT_MQTT_HOST和AWS_IOT_MQTT_CLIENT_ID。

AWS_IOT_MQTT_HOST ：這是我們需要連接和驗證的端點。要查找此值，請轉(zhuǎn)到您的 AWS IoT Core 管理控制臺，單擊“管理”，然后單擊左側(cè)窗格中的子菜單項“事物”，然后單擊您的“ NBTutorial”注冊的“事物”。在主窗口的左側(cè)，您會找到菜單選項列表。其中，單擊“Interact”，這會將您帶到類似于圖 17 中的頁面。

圖 17：“事物”詳細信息

?

我們正在尋找的值是“HTTPS”標(biāo)題下列出的令人討厭的長值。復(fù)制該值并將其粘貼到您的 aws_iot_config.h 文件中以代替文本。

AWS_IOT_MQTT_CLIENT_ID ：這是您設(shè)備的唯一客戶端 ID，對于連接到此端點的每個設(shè)備都應(yīng)該是唯一的。我們選擇無聊并使用我們的 MAC 地址，但您可以隨意想出您喜歡的創(chuàng)意和有趣的東西（只要它是獨一無二的）。如果您也想使用 MAC 地址，可以在模塊條形碼標(biāo)簽的底部找到它，或者訪問https://discover.netburner.com。無論您選擇什么，將該值復(fù)制到aws_iot_config.h文件中的文本上。

當(dāng)您保存 NBEclipse 項目時，它應(yīng)該會再次自動構(gòu)建項目并顯示一條“構(gòu)建完成”消息，如前所述。如果沒有，您可以通過從 NBEclipse 菜單中進行選擇來手動觸發(fā)構(gòu)建。Project->Build Project

加載您的應(yīng)用程序

此時，我們已準(zhǔn)備好在設(shè)備上加載我們的應(yīng)用程序。您應(yīng)該能夠通過選擇從 IDE 的頂部菜單自動設(shè)置運行配置Run->Run As->As Neturner Application。有關(guān)運行配置的更多詳細信息，請參閱我們的文檔。

如果由于某種原因您的設(shè)備在創(chuàng)建過程中未與項目相關(guān)聯(lián)，您可以將設(shè)備的 IP 地址添加到項目中。通過右鍵單擊“Project Explorer”選項卡中的項目，然后選擇列表最底部的“Properties”選項來執(zhí)行此操作。從那里，從顯示的窗口左側(cè)的列表中選擇“NetBurner 選項”，然后在“設(shè)備選項”部分下的相應(yīng)字段中輸入您的設(shè)備 IP 地址，如下面的圖 18 所示。同樣，您可以通過以下網(wǎng)址找到您的設(shè)備 IP：https://discover.netburner.com/。

圖 18：為您的項目分配 IP 地址

?

可選（和推薦）步驟：當(dāng)程序成功加載后，您可以通過MTTTY 終端監(jiān)視應(yīng)用程序的串行輸出。通過將您的開發(fā)板直接連接到您的計算機來執(zhí)行此操作。根據(jù)您的電路板的跳線配置，這將通過 UART0 DB9 端口或微型 USB 插孔完成。如果一切順利，在一些初始初始化和連接信息之后，您應(yīng)該看到“Publish Success”消息定期滾動，如下圖 19 所示：

圖 19：發(fā)布的成功消息

?

測試

現(xiàn)在到了你一直在等待的時刻。是時候使用帶有 NetBurner 模塊的 MQTT 協(xié)議向 AWS IoT Core 服務(wù)發(fā)送和接收消息了。對于下一組步驟，我們將需要返回到 AWS IoT Core 管理控制臺。然而，這一次，我們將從左側(cè)菜單中選擇“測試”，這會將您帶到類似于圖 20 中所示的控制臺。

圖 20：MQTT 測試

?

我們自稱為天才，巧妙地將用于從 NetBurner 模塊發(fā)布到 AWS 的 MQTT 主題命名為“ NBTutorial/ToAws”。繼續(xù)在“訂閱主題”字段中輸入這個（不帶引號），然后點擊標(biāo)有“訂閱主題”的按鈕。

如果一切順利并且您的設(shè)備正在運行，您應(yīng)該會看到 MQTT 消息開始顯示在窗口的底部，如圖 21 所示。如果沒有，請返回并查看“可選（和推薦）步驟” ”，并驗證您的設(shè)備是否在串行終端中正確初始化 AWS SDK。還要確認(rèn)端口 8883 未在您的防火墻上被阻止，因為這是 MQTT 的默認(rèn)端口，限制它會阻止您的 NetBurner 設(shè)備與 AWS 通信。最后，驗證我們上面創(chuàng)建的策略中的資源 ARN 是否正確以 (*) 結(jié)尾。

圖 21：測試 NetBurner 設(shè)備發(fā)布

?

接下來我們想看看我們的設(shè)備是否已經(jīng)成功訂閱了一個頻道。在同一個 AWS 控制臺中，單擊位于“訂閱”標(biāo)題下的二級左側(cè)菜單中的鏈接“發(fā)布到主題”。我們看到 NetBurner 設(shè)備消息傳入的控制臺底部應(yīng)該被一個名為“Publish”的小框替換。它應(yīng)該包含主題的文本字段，以及要發(fā)送的消息的文本字段，最后是一個標(biāo)記為“發(fā)布到主題”的按鈕。這可以在下面的圖 22 中看到。

圖 22：在 NetBurner 設(shè)備上測試訂閱

?

對于此主題，輸入“ NBTutorial/ToNb”。這很重要，因為它是我們的應(yīng)用程序希望接收消息的主題。您可以將消息保留為默認(rèn)值，即“Hello from AWS IoT console”，或者您可以根據(jù)自己的喜好進行修改。但請注意，它遵循 JSON 格式。

填寫完這些字段后，繼續(xù)點擊旁邊的魔法按鈕（“發(fā)布到主題”）。如果您碰巧通過 UART0 直接連接到您的設(shè)備，請查找您的消息以顯示在串行終端中，如下面的圖 23 所示。

圖 23：勝利的甜蜜滋味。使用 NetBurner 的 MTTTY 串行實用程序?qū)ζ溥M行測試。

?

如果您不喜歡串行終端或沒有串行轉(zhuǎn) USB 適配器，您還可以通過 Web 瀏覽器查看設(shè)備上發(fā)送和接收的最后一條消息。為此，請打開您選擇的瀏覽器并在頂部的 URL 欄中輸入您設(shè)備的 IP 地址。同樣，您可以使用 URL https://discover.netburner.com/ 獲取 IP 地址。將此 IP 地址放入您的瀏覽器將引導(dǎo)您進入一個由 NetBurner 模塊托管的簡單網(wǎng)頁，該網(wǎng)頁顯示最近發(fā)送和接收的消息，如下面的圖 24 所示。

圖 24：更好看的勝利。使用 discover.netburner.com 測試一切

?

到目前為止，我們已經(jīng)逐步了解了如何開始使用 Amazon 的 AWS IoT Core 托管云服務(wù)。為此，我們使用輕量級MQTT消息傳遞協(xié)議和 NetBurner開發(fā)工具包作為物聯(lián)網(wǎng)設(shè)備。雖然我們從頭到尾涵蓋了所有基本要求，但我們也忽略了很多關(guān)于在 NetBurner 模塊上運行的實際應(yīng)用程序的內(nèi)容。現(xiàn)在，我們將查看整個應(yīng)用程序的功能，查看源代碼并近距離接觸執(zhí)行骯臟工作的各個部分。我們已經(jīng)包含了該應(yīng)用程序的重要部分，但如果您想要真正身臨其境的體驗，您可以在此處找到該項目的 GitHub 存儲庫。

源代碼審查

圖 25：項目文件

?

我們的項目包含幾個源文件、AWS SDK 和一個包含index.html我們在 Web 界面中使用的 html 文件夾。我們將主要關(guān)注.cpp直接位于src文件夾中的六個文件（如上圖 25 所示）、它們關(guān)聯(lián)的頭文件和一個配置頭文件。以下是對其中每一項的簡要說明：

main.cpp– 這是應(yīng)用程序的起點。它定義了應(yīng)用程序名稱AWS IoT Core Base ，并為我們的程序提供了入口點UserMain()。稍后會詳細介紹這一點。

post-record-data.cpp– 此文件包含初始化AWS SDK 的函數(shù)，并處理傳入和傳出 MQTT 消息的處理。

network_netburner.cpp– 此文件包含實現(xiàn)AWS SDK API的網(wǎng)絡(luò)接口所需的函數(shù)，并將其綁定到我們的網(wǎng)絡(luò)堆棧。這些都與 TLS 網(wǎng)絡(luò)連接有關(guān)。

timer_netburner.cpp– 此文件包含AWS IoT Core MQTT 客戶端所需的附加功能，并且與用于管理 MQTT 連接的計時器功能相關(guān)。

record-data.cpp– 這包含一個小函數(shù)，用于序列化MQTT 消息中使用的 JSON 數(shù)據(jù)。

html-control.cpp– 此文件包含兩個函數(shù)，用于構(gòu)建顯示最近發(fā)送和接收的 MQTT 消息的 HTML 頁面，如下所示。

aws_iot_config.h– 該文件包含我們連接到服務(wù)和發(fā)布/接收消息所需的所有配置常量值。如前所述，您需要將 和 更改AWS_IOT_MQTT_HOST為AWS_IOT_MQTT_CLIENT_ID特定于您的帳戶和環(huán)境的值。

圖 26：Web 界面顯示最后接收和發(fā)送的消息

?

最初設(shè)定

讓我們將注意力轉(zhuǎn)移到應(yīng)用程序的入口點UserMain()，位于 中main.cpp。在 內(nèi)部，您將看到在我們進入主循環(huán)UserMain()之前或多或少按給定順序調(diào)用以下函數(shù)：while()

init()– 此函數(shù)為應(yīng)用程序設(shè)置網(wǎng)絡(luò)堆棧，啟動配置服務(wù)器，賦予UserMain()正確的任務(wù)優(yōu)先級，并設(shè)置一些調(diào)試細節(jié)。如果您碰巧在申請中忘記了這一點，您很快就會知道。

StartHttp()– 這將啟動設(shè)備上的網(wǎng)絡(luò)服務(wù)器。再簡單不過了。

InitializeAWSSDK()– 這幾乎完全符合您的預(yù)期。它設(shè)置 AWS SDK 并負(fù)責(zé)初始 MQTT 設(shè)置。我們將在下面更深入地探討這一點。

一切都初始化后，我們將進入我們的主要 while 循環(huán)，您將在其中看到以下代碼：

while (1)
{
    // Post our record data
    PostRecordData();
    // Wait 5 seconds before doing it again
    OSTimeDly(TICKS_PER_SECOND * 5);
}

在真正的嵌入式系統(tǒng)中，我們將無限期地繼續(xù)運行我們的 while() 循環(huán)。每五秒鐘我們將調(diào)用PostRecordData()，這將向我們訂閱的 MQTT 主題發(fā)布一條消息，定義如下gTopicNameSend。post-record-data.cpp

初始化適用于 MQTT 的 AWS IoT Core 開發(fā)工具包

如上所述，初始化 AWS SDK for IoT Core 服務(wù)發(fā)生在InitializeAWSSDK()，位于post-record-data.cpp.

InitializeAWSSDK()
{
    IoT_Error_t rc = FAILURE;
    IoT_Client_Init_Params mqttInitParams = iotClientInitParamsDefault;
    IoT_Client_Connect_Params connectParams = iotClientConnectParamsDefault;

    iprintf("\nAWS IoT SDK Version %d.%d.%d-%s\n", VERSION_MAJOR, VERSION_MINOR,
    VERSION_PATCH, VERSION_TAG);

    // Set required MQTT parameters
    mqttInitParams.enableAutoReconnect = false;
    mqttInitParams.pHostURL = AWS_IOT_MQTT_HOST;
    mqttInitParams.port = AWS_IOT_MQTT_PORT;
    mqttInitParams.pRootCALocation = "";
    mqttInitParams.pDeviceCertLocation = (char *) certificate;
    mqttInitParams.pDevicePrivateKeyLocation = (char *) privatekey;
    mqttInitParams.mqttCommandTimeout_ms = 30000;
    mqttInitParams.tlsHandshakeTimeout_ms = 10000;
    mqttInitParams.isSSLHostnameVerify = true;
    mqttInitParams.disconnectHandler = nullptr;
    mqttInitParams.disconnectHandlerData = nullptr;

    rc = aws_iot_mqtt_init(&client, &mqttInitParams);
    if (SUCCESS != rc)
    {
        iprintf("aws_iot_mqtt_init returned error : %d ", rc);
        return false;
    }

    connectParams.keepAliveIntervalInSec = 600;
    connectParams.isCleanSession = true;
    connectParams.MQTTVersion = MQTT_3_1_1;
    connectParams.pClientID = AWS_IOT_MQTT_CLIENT_ID;
    connectParams.clientIDLen = (uint16_t) strlen(AWS_IOT_MQTT_CLIENT_ID);
    connectParams.isWillMsgPresent = false;

    iprintf("Connecting...\n");
    rc = aws_iot_mqtt_connect(&client, &connectParams);
    if (SUCCESS != rc)
    {
        iprintf("Error(%d) connecting to %s:%d\n", rc, mqttInitParams.pHostURL, mqttInitParams.port);
        return false;
    }

    rc = aws_iot_mqtt_autoreconnect_set_status(&client, true);
    if (SUCCESS != rc)
    {
        iprintf("Unable to set Auto Reconnect to true - %d\n", rc);
        return false;
    }

    iprintf("Subscribing to topic: %s, %d\n", gTopicNameRec, strlen(gTopicNameRec));
    rc = aws_iot_mqtt_subscribe(&client, (char *) gTopicNameRec, strlen(gTopicNameRec), QOS1, IoTSubscribeCallbackHandler, nullptr);

    if (SUCCESS != rc)
    {
        iprintf("Error subscribing : %d\n", rc);
        return false;
    }

    return true;
}

在函數(shù)頂部附近，您將看到為調(diào)用 設(shè)置的參數(shù)aws_iot_mqtt_init()。堅持我們提供的價值觀應(yīng)該沒問題。但是，對于特別好奇的人，您可以從官方 AWS API 文檔here.

假設(shè) MQTT 初始化函數(shù)成功，然后我們將設(shè)置我們的連接參數(shù)并將它們傳遞給函數(shù)，aws_iot_mqtt_connet()。您可能猜到了，建立與 AWS IoT Core 服務(wù)的連接。同樣，您應(yīng)該接受我們設(shè)置的值，但您可以在此處找到有關(guān)這些值代表什么的更多信息。如果我們能夠成功建立一個連接，我們將通過一個aws_iot_mqtt_autoreconnect_set_status()包含 true 參數(shù)的調(diào)用來跟進它。如果由于某種原因連接失敗，這將確保我們自動重新連接。

最后，我們通過調(diào)用訂閱我們的主題aws_iot_mqtt_subscribe()。我們將訂閱的主題是gTopicNameRec，它定義在 的頂部post-record-data.cpp。我們還傳遞了一個指向接收消息時調(diào)用的函數(shù)的指針IoTSubscribeCallbackHandler()。

發(fā)布 MQTT 數(shù)據(jù)

現(xiàn)在我們已經(jīng)建立了與 AWS IoT Core 服務(wù)的連接，我們已準(zhǔn)備好開始使用 MQTT 協(xié)議發(fā)布消息。正如我們之前提到的，我們將每五秒從我們的UserMain()函數(shù)中發(fā)布一條新消息，并調(diào)用PostRecordData()中定義的post-record-data.cpp。

void PostRecordData()
{
    char buffer[200] = { 0 };
    CreateOutMessage(gJsonOut);
    gJsonOut.PrintObjectToBuffer(buffer, 199, false);

    IoT_Publish_Message_Params paramsQOS1;
    paramsQOS1.qos = QOS1;
    paramsQOS1.payload = (void *) buffer;
    paramsQOS1.payloadLen = strlen(buffer);
    paramsQOS1.isRetained = 0;

    IoT_Error_t rc = aws_iot_mqtt_publish(&client, gTopicNameSend, strlen(gTopicNameSend), ?msQOS1);
    if (SUCCESS != rc)
    {
        iprintf("Error publishing : %d\n", rc);
    }
    else
    {
        iprintf("Publish success:\r\n");
        gJsonOut.PrintObject(true);
        iprintf("\r\n");
    }
}

您會注意到我們做的第一件事就是打電話CreateOutMessage()。這將構(gòu)建我們的 MQTT 有效負(fù)載并將其存儲在 中gJsonOut，這是一個ParsedJsonDataSet對象。我們將其保存在全局，以便可以通過我們的模塊提供的網(wǎng)頁來引用和顯示它。記錄的內(nèi)容是消息創(chuàng)建時間的時間戳和每當(dāng)調(diào)用函數(shù)時遞增的靜態(tài) ID。記錄由類定義，并與設(shè)備 ID 一起PostRecord序列化。gJsonOutAWS_IOT_MQTT_CLIENT_ID

在我們的有效載荷結(jié)構(gòu)正確的情況下，我們將其轉(zhuǎn)儲到緩沖區(qū)中，然后再設(shè)置我們的 IoT 發(fā)布參數(shù)。

接收 MQTT 消息

如前所述，我們aws_iot_mqtt_subscribe()在初始設(shè)置期間致電給我們訂閱了主題gTopicNameRec. 該函數(shù)的參數(shù)之一 為IoTSubscribeCallbackHandler將用于處理傳入消息的函數(shù)提供了處理程序。

void IoTSubscribeCallbackHandler(AWS_IoT_Client *pClient, char *topicName, uint16_t topicNameLen, IoT_Publish_Message_Params *params, void *pData)
{
    iprintf("Received Message:\r\n");
    ParsedJsonDataSet jsonIn = ParsedJsonDataSet((char *) params->payload, (int) params->payloadLen);
    jsonIn.PrintObject(true);
    iprintf("\r\n");

    jsonIn.PrintObjectToBuffer( recJson, 256, true);
}

我們知道函數(shù)的簽名應(yīng)該是什么，因為 Amazon 非常友好地在他們的API 文檔中為我們提供了很好的細分。該函數(shù)本身非常短，因為我們只是從 MQTT 消息中獲取有效負(fù)載數(shù)據(jù)，并使用它來構(gòu)造一個ParsedJsonDataSet對象。然后我們將該對象的內(nèi)容存儲到緩沖區(qū)中，以便我們可以在網(wǎng)頁上提供它并顯示最后收到的消息是什么。

網(wǎng)頁界面

我們利用 NetBurner 生成動態(tài) Web 內(nèi)容的能力來顯示最近接收和發(fā)布的 MQTT 消息。為此，我們定義了兩個函數(shù)，html-control.cpp它們會在數(shù)據(jù)從設(shè)備提供給請求瀏覽器之前將數(shù)據(jù)打印到網(wǎng)頁。這些是PrintOutData()和PrintInData()。

index.html 中特殊格式的注釋會觸發(fā)這些函數(shù)，并且它們具有結(jié)構(gòu)，。這使得通過 Web 界面顯示任何類型的應(yīng)用程序級數(shù)據(jù)變得非常容易。我們有關(guān)于該系統(tǒng)的大量文檔，并包括幾個功能齊全的示例以及我們的 NNDK。

實施 AWS 開發(fā)工具包依賴項

當(dāng)然，AWS SDK 必須有一種方法可以綁定到 NetBurner 平臺和網(wǎng)絡(luò)堆棧中。我們這里使用的SDK提供了兩個接口：網(wǎng)絡(luò)接口和定時器接口。如上所述，這些接口的功能分別定義在network_netburner.cpp和timer_netburner.cpp中。

網(wǎng)絡(luò)接口提供所有 TLS 功能，用于啟動和關(guān)閉安全連接，以及通過這些連接讀取和寫入數(shù)據(jù)。計時器接口提供保持 MQTT 連接活動和啟動所需的超時功能。

在我們連接到 AWS IoT Core 服務(wù)并開始發(fā)送和接收 MQTT 消息之前，需要這兩個接口的功能。如果您從一開始就按照說明生成和編譯證書和私鑰，那么應(yīng)該不需要修改這里實現(xiàn)的功能。

包起來

我們希望您覺得這個項目既有趣又有教育意義。我們在制作過程中玩得很開心，也很想聽聽您的體驗！我們在這里提供了堅實的基礎(chǔ)，但這真的只是這個特定項目的開始。天空是極限，所以出去開始試驗吧！

如果您對深入解釋感興趣，這兩篇Netburner 文章提供了更多信息。