本文分享自华为云社区《采用华为云 IOT 平台设计的高速公路多节点温度采集系统 (STM32+NBIOT)》，作者：DS 小龙哥。
一、前言
当前的场景是，在高速公路上部署温度采集设备，在高速路地表安装温度检测传感器，检测当前路段的路面实际温度。一段高速路上有多个地点需要采集温度数据。 采集温度数据需要上传到云平台进行数据存储，并且通过可视化界面展示温度变化曲线，支持查询最近几天的温度信息。
二、设计思路
（1）云平台选型：使用华为云物联网云平台。
（2）云数据存储： 使用 OBS 存储，存放设备上传的历史数据。
（3）设备选项：NBIOT 模块 + 温度采集模块，实现温度采集上报。
（4）数据可视化：采用华为云 IoT 应用侧接口，获取传感器设备上传到云端的数据，在本地设计界面进行可视化显示温度数据。
下面是温度数据可视化展示效果：
本篇文章主要介绍设备上云的详细流程，介绍华为云物联网云端产品、设备创建流程，数据转存方式，应用侧开发接口等等。
硬件选型： （1）STM32 开发板: STM32F103C8T6
（2）NBIOT 模块 --BC26
BC26 模块是一款高性能、低功耗、多频段 LTE Cat NB1 无线通信模块。
（3）温度采集模块
pt100 是铂热电阻，它的阻值会随着温度的变化而改变。PT 后的 100 即表示它在 0℃时阻值为 100 欧姆，在 100℃时它的阻值约为 138.5 欧姆。其工作原理：当 PT100 在 0℃时，其电阻为 100 欧姆。它的电阻会随着温度的升高而上升，并且它的电阻会匀速增加。热电阻是一种常用于中低温的温度传感器。它的工作原理是基于电阻的热效应，即电阻的阻值随温度的变化而变化。铂金热敏电阻的热阻精度最高，具有抗振动、稳定性好、耐高压等特点。因此，它被制成各种标准温度计进行测量和校准。
三、华为云 IOT 平台
3.1 创建产品
官网地址: https://www.huaweicloud.com/
（1）设备接入 IOTDA
在产品页面找到 iot 物联网，选择设备接入 IOTDA
设备接入服务（IoT Device Access）是华为云的物联网平台，提供海量设备连接上云、设备和云端双向消息通信、批量设备管理、远程控制和监控、OTA 升级、设备联动规则等能力，并可将设备数据灵活流转到华为云其他服务，帮助物联网行业用户快速完成设备联网及行业应用集成，基础版每月一百万条消息免费。
在页面上选择免费试用。
点击后，会进入到设备接入控制台页面。
（2）设备接入地址
在基础版详情页面，点击右边的按需计费详情，可以查看物联网服务器接入的 IP 地址，端口号、接入方式。
如果是设备接入，可以选择 MQTT 或者 MQTTS 协议，在单片机上只有 MQTT 协议验证比较方便，通过 MQTT 三元组即可完成设备连接，当前我这里的设备选择是 MQTT 协议连接华为云平台。
域名：a161a58a78.iot-mqtts.cn-north-4.myhuaweicloud.com IP地址: 121.36.42.100 端口号: 1883
复制代码（3）创建产品
在左边选项卡里点击产品，进入产品页面，点击右上角创建产品。
根据自己的产品信息，填写表单：
（4）完成产品创建
点击查看详情，可以进入到创建成功的产品页面。
（5）定义产品模型
产品创建之后，接着需要在平台上构建一款设备的抽象模型，使平台理解该款设备支持的功能。
比如：温度采集设备肯定会向云平台上传采集的温度信息；在产品模型里就可以定义一个温度的属性字段。
选择下面的自定义模型。
添加服务 ID。
添加属性。
新增属性字段。当前在多节点温度采集的设备里，主要是采集温度上传，这里就新增一个温度的属性。
产品模型创建完成。
3.2 创建设备
（1）创建单个设备
设备注册的方式有很多：
【1】创建支持单个设备手动创建。
【2】如果设备特别多可以选择批量注册。
【3】通过 API 接口进行动态注册。
当前为了演示流程，这里选择第一种方式，手动创建单个设备。
在设备页面，选择所有设备选项，点击右边的注册设备按钮。
（2）单设备注册填写信息
点击注册设备之后，会弹出一个表单填写信息。
其中产品就选择刚才创建的产品，设备标识码这一项一般是填设备的 ID（设备的唯一标识符，方便绑定设备）。目前还没有对接硬件，我这里就填 dev1，方便接下来的测试。 下面的设备 ID 这一项如果不填，会自动生成，可以不管；最后输入密匙（这个密匙的作用：通过对每个设备进行身份验证，可以安全地将每个设备连接到平台，并且安全地管理这些设备），填好之后点击确定。
（3）设备创建完成
创建好之后，保存生成的设备 ID 和密匙。
得到的密匙和 ID 的格式文本如下：
{ "device_id": "6353a8163ec34a6d03c8dfe5_dev1", "secret": "12345678" }
复制代码这个设备密匙和 ID，后面生成 MQTT 登录参数时需要用到。
（4）创建多个温度设备节点
由于本项目是实现多节点温度上传到云平台，每个节点都是一个独立的温度采集设备，为了方便演示效果，还需要多创建几个设备。
接下来的创建流程，和刚才第一个设备一样，这里就不再截图演示了。
点击创建设备按钮，继续注册。
目前一共创建了 4 个设备，其中 main_dev 设备是用来作为显示终端，在本地用显示屏显示其他温度采集节点采集的温度信息。 剩下 3 个设备 dev1，dev2，dev3 是表示 3 个独立的温度采集节点。
这 4 个设备的密匙和 ID 信息如下：
{ "device_id": "6353a8163ec34a6d03c8dfe5_dev1", "secret": "12345678" } { "device_id": "6353a8163ec34a6d03c8dfe5_dev2", "secret": "12345678" } { "device_id": "6353a8163ec34a6d03c8dfe5_dev3", "secret": "12345678" } { "device_id": "6353a8163ec34a6d03c8dfe5_main_dev", "secret": "12345678" }
复制代码3.3 模拟设备上云测试
目前设备创建之后，这些设备都还没有激活。接下来会使用 MQTT 客户端来模拟真实设备上云，上传温度数据。
这里的上云，包括数据交互都采用 MQTT 客户端来模拟实现，不涉及到实际的硬件，只要模拟能测试成功，并且能得到自己想要的结果，那硬件就没有问题了。
（1）生成 MQTT 鉴权三元组
设备要连接华为云平台的方式，在第一节创建产品的时候就已经介绍了，本次项目里的设备是采用 MQTT 协议接入云平台。 在完成设备模拟上云之前，需要先生成设备的 MQTT 协议鉴权三元组。
华为云提供了一个在线工具，用来生成 MQTT 鉴权三元组： https://iot-tool.obs-website.cn-north-4.myhuaweicloud.com/
工具打开的界面如下效果：
前面两行就是填设备创建后生成的设备 ID 和设备密匙，填好之后，生成下面 3 行信息，生成的 3 行就是 MQTT 协议登录需要用的参数。
按照格式分别生成 4 个设备的鉴权信息：
得到的三元组如下：
ClientId 6353a8163ec34a6d03c8dfe5_dev1_0_0_2022102209 Username 6353a8163ec34a6d03c8dfe5_dev1 Password c58c45d514832b119b4302eafb3e74854849ca94079e9aed75efedf176e9c388 ClientId 6353a8163ec34a6d03c8dfe5_dev2_0_0_2022102209 Username 6353a8163ec34a6d03c8dfe5_dev2 Password c58c45d514832b119b4302eafb3e74854849ca94079e9aed75efedf176e9c388 ClientId 6353a8163ec34a6d03c8dfe5_dev3_0_0_2022102209 Username 6353a8163ec34a6d03c8dfe5_dev3 Password c58c45d514832b119b4302eafb3e74854849ca94079e9aed75efedf176e9c388 ClientId 6353a8163ec34a6d03c8dfe5_main_dev_0_0_2022102209 Username 6353a8163ec34a6d03c8dfe5_main_dev Password c58c45d514832b119b4302eafb3e74854849ca94079e9aed75efedf176e9c388
复制代码（2）MQTT 客户端模拟设备登录
得到 MQTT 三元组之后，接下来用 MQTT 客户端模拟设备登录云平台。
按照软件的输入框提示，输入对应的信息，点击登录。 其中的 IP 地址和端口号在第一小节的产品创建里就介绍过了。 后面输入的这 3 行就是上一步生成的 MQTT 鉴权三元组。
登录成功。
然后打开云平台的控制台，查看设备在线情况：
可以看到 dev1 已经在线了， 刚才模拟的设备就是 dev1。
（3）主题订阅与发布
目前设备已经成功登录，接下来要解决的问题就是数据传输问题了。
MQTT 协议里要理解的两个概念就是主题订阅，主题发布。 设备上传数据到平台，属于 主题发布。 设备想要知道其他设备的数据或者云平台下发的指令，需要进行主题订阅。
帮助文档的地址： https://support.huaweicloud.com/api-iothub/iot_06_v5_3002.html
MQTT 消息由固定报头（Fixed header）、可变报头（Variable header）和有效载荷（Payload）三部分组成。
其中固定报头（Fixed header）和可变报头（Variable header）格式的填写请参考 MQTT 标准规范，有效载荷（Payload）的格式由应用定义，即设备和物联网平台之间自己定义。
常见 MQTT 消息类型主要有 CONNECT、SUBSCRIBE、PUBLISH。
CONNECT：指客户端请求和服务端连接。有效载荷（Payload）的主要参数，参考设备连接鉴权填写。 SUBSCRIBE：指客户端订阅请求。有效载荷（Payload）中的主要参数“Topic name”，参考Topic定义中订阅者为设备的Topic。 PUBLISH：平台发布消息。 可变报头（Variable header）中的主要参数“Topic name”，指设备上报到物联网平台时发布者为设备的Topic。详细请参考Topic定义。 有效载荷（Payload）中的主要参数为完整的数据上报和命令下发的消息内容，目前是一个JSON对象。 上行Topic是指设备向平台发送请求，或上报数据，或回复响应。 下行Topic是指平台向设备下发指令，或回复响应。 设备与平台建立连接后，需要订阅下行Topic，否则无法收到平台下发的指令或回复的响应。应用侧接口的调用，需要设备侧的配合，例如应用侧下发命令，设备侧需要先订阅“平台命令下发”的下行Topic，否则设备无法收到平台命令，应用下发命令的接口也会报超时。 在产品页面，可以看到主题的格式，以及对于主题的用途：**
【1】订阅主题
对于设备而言，一般会订阅平台下发消息给设备 这个主题。
设备想接收平台下发的消息，就需要订阅平台下发消息给设备 的主题，订阅后，平台下发消息给设备，设备就会收到消息。
主题的格式如下:
$oc/devices/{device_id}/sys/messages/down 以dev1设备1为例，最终的格式: $oc/devices/6353a8163ec34a6d03c8dfe5_dev1/sys/messages/down
复制代码【2】发布主题
对于设备，发布主题，也就显示向云平台上传数据。
发布的主题格式如下:
$oc/devices/{device_id}/sys/properties/report 以dev1设备1为例最终的格式: $oc/devices/6353a8163ec34a6d03c8dfe5_dev1/sys/properties/report
复制代码发布主题时，需要上传数据，这个数据格式是 JSON 格式。
上传的 JSON 数据格式如下:
{ "services": [ { "service_id": <填服务ID>, "properties": { "<填属性名称1>": <填属性值>, "<填属性名称2>": <填属性值>, .......... } } ] }
复制代码根据 JSON 格式，一次可以上传多个属性字段。 这个 JSON 格式里的，服务 ID，属性字段名称，属性值类型，在前面创建产品的时候就已经介绍了，不记得可以翻到前面去查看。
根据这个格式，组合温度节点一次上传的数据:
{"services": [{"service_id": "temp","properties":{"temp":24.6}}]} （4）MQTT 客户端模拟设备上报数据
打开 MQTT 客户端填入订阅主题，发布主题，和需要发布的数据，然后分别点击订阅主题按钮，发布主题按钮。 右边提示成功之后，就可以打开云平台看上传的效果了。 （这里是以 dev1，设备 1 为例）
打开云平台看到 dev1 已经在线。
点击 dev1, 进去查看设备上传的数据。 可以看到，刚才上传的数据已经收到了。
到此，设备上传数据到云平台已经完成。
四、设备数据转存
如果设备上传的数据需要进行保存，后续进行分析做其他用途，可以利用数据转发服务，让平台将设备上报数据推送给自己的应用服务器，由应用服务器进行保存；也可以选择让平台将设备上报数据转发给 OBS 对象存储服务，由 OBS 进行存储，进行永久保存，非常方便。如果存储在 OBS 里，自己设计应用侧界面时，也可以直接拉取 OBS 里的数据下来进行显示，处理，分析。
4.1 创建 OSB 存储桶 地址: https://www.huaweicloud.com/product/obs.html
对象存储服务（Object Storage Service,OBS）是一个基于对象的存储服务，提供了海量、安全、高可靠、低成本的数据存储能力。
（1）选择管理控制台
（2）创建桶
填充桶信息： 我这里选择的是 华北 - 北京一
我这里因为要长期使用，这里选择 1 年的购买权。
（3）创建成功
4.2 配置数据转发规则
（1）创建规则
选择左侧导航栏的规则>数据转发，单击右上角的创建规则。
填充规则转发的信息：
（2）设置转发目标
单击添加，设置转发目标。
这里的区域选择 -- 华北-北京一。 因为前面的 OBS 桶创建的时候，设置区域设置的是北京一，然后点击授权。
授权之后，选择刚才创建的 OBS 桶，设置存储数据的目录和文件名字。
存储的数据可以直接转存 JSON 数据到 OBS 存储桶，也可以存放成 CSV 文件到存储桶。
如果选择存储 JSON，就是直接将设备上传的数据存放到 OBS 存储里，如果选择存储 CSV 文件，可以自己选择需要存储的字段。 下面我演示一下存储成 CSV 文件时如何进行设置。 （选择 JSON 文件不需要进行任何设置，直接将设备上传的数据 JSON 存储进去了）。
下面设置转发的字段： （如果提示没有授权，点击授权即可）
这个转发字段就是表示需要存放的数据是那些，对于路灯而言，肯定是需要存储上报的温度、湿度、电量、光照强度的属性的。 这些属性在创建产品的时候设置，设备上报的也是这些属性。
这是设备上传一次云平台的完整 JSON 数据格式:
{ "resource": "device.property", "event": "report", "event_time": "20221018T131627Z", "request_id": "5ee95a0c-262d-43c3-8d31-af453f9952ef", "notify_data": { "header": { "app_id": "7211833377cf435c8c0580de390eedbe", "device_id": "634e3e423ec34a6d03c84bfb_1126626497", "node_id": "1126626497", "product_id": "634e3e423ec34a6d03c84bfb", "gateway_id": "634e3e423ec34a6d03c84bfb_1126626497" }, "body": { "services": [ { "service_id": "temp", "properties": { "temp": 28, }, "event_time": "20221018T131627Z" } ] } } }
复制代码当前设备上传到云端服务器有一个温度属性字段 temp，如果想转发设备上传的这个温度字段，就可以这样写：
notify_data.body.services[0].properties.temp 后面的存储目标字段，为了好区分，直接填 temp 即可。
如果设备还上传了其他属性字段也想转发，按照上面格式设置即可。
如果存储数据时，想知道这个数据是那个产品，那个设备上传的，也可以将设备 ID 和产品 ID 转发存储起来：格式如下。
notify_data.header.app_id notify_data.header.device_id
复制代码下面是我设置好，转发存储的字段：
确定后，点击设置完成。
（3）测试规则
设置好之后，在设置转发目标的页面点击测试。
输入数据模板，然后点击连通性测试。如果测试结果显示成功，说明整体流程没有问题了。
（4）启用规则
设置完成后，点击启用规则。
（5）数据上报测试
为了验证转发规则是否生效，接下来使用 MQTT 客户端多上报几次数据到云平台。
上传之后，打开 OBS 存储桶的控制台页面。打开转发规则存储的 OBS 桶。
找到存储数据的文件，点击下载。
下载下来，打开可以看到存储的数据:
到此，数据转发，存储已经成功了。
五、应用侧 - 可视化大屏开发
对于数据的可视化显示，华为云提供了（Data Lake Visualization）一站式数据可视化平台，数据可视化服务 (DLV) 可以从 OBS 文件读取数据呈现为可视化报表，实现数据的可视化显示。
下面是华为云的 DLV 大屏从 OBS 读取数据显示的流程：
当前我这里的需求是需要在本地自己设计界面显示数据，没有采用华为云的 DLV 大屏，如果自己本地软件需要显示设备上传的数据，就需要使用华为云物联网的平台的应用侧 API 接口，读取设备上传的数据进行，本地进行显示；如果需要历史数据，可以读取 OBS 存储桶里存储的数据进行显示。
5.1 应用侧接口 帮助文档地址: https://support.huaweicloud.com/usermanual-iothub/iot_01_0045.html
5.2 查询设备影子数据接口
应用侧接口可以查询发送指令给设备查询属性，也可以读取设备的影子数据。
【1】查询设备查询：这个是实时查询，相当于应用侧接口发送指令给在线设备，设备收到指令，将当前最新的数据再上传。这个需要保证设备在线，离线是无法调用的。
【2】影子数据：影子数据相当于保存设备上传的最新一次数据。 读取读取影子设备数据，是不需要设备在线。
（1）接口 URI 地址
（2）请求参数说明
（3）响应参数
（4）请求示例
GET https://{Endpoint}/v5/iot/{project_id}/devices/{device_id}/shadow Content-Type: application/json X-Auth-Token: ******** Instance-Id: ********
复制代码（5）响应示例
Status Code: 200 OK
Content-Type: application/json { "device_id" : "40fe3542-f4cc-4b6a-98c3-61a49ba1acd4", "shadow" : [ { "service_id" : "WaterMeter", "desired" : { "properties" : { "temperature" : "60" }, "event_time" : "20151212T121212Z" }, "reported" : { "properties" : { "temperature" : "60" }, "event_time" : "20151212T121212Z" }, "version" : 1 } ] }
复制代码（6）错误码
5.3 接口调试
在线调试地址：https://apiexplorer.developer.huaweicloud.com/apiexplorer/debug?product=IoTDA&api=ShowDeviceShadow
下面是调试影子 数据查询接口，查询设备影子数据： 右边返回的是设备上传的最新数据。
5.4 接口总结
请求地址: https://iotda.cn-north-4.myhuaweicloud.com/v5/iot/{project_id}/devices/{device_id}/shadow 请求方式: GET 请求头: { "X-Auth-Token": "这个需要自己获取", "Content-Type": "application/json" }
复制代码5.5 如何获取 X-Subject-Token
使用 API 访问华为云的所有服务接口，都需要填 X-Subject-Token 参数，下面介绍步骤：
（1）创建一个新的 IAM 帐户
鼠标悬停在右上角的用户名称上，弹出下拉框，选择统一身份认证。
（2）选择创建用户
（3）使用调试接口测试获取 oken
调试接口地址: https://apiexplorer.developer.huaweicloud.com/apiexplorer/debug?product=IAM&api=KeystoneCreateUserTokenByPassword
右边响应头里的 X-Subject-Token 就是获取的 token。
（4）上面的这些账户名称从哪里获取？
（5）请求地址和数据格式
获取 X-Subject-Token 请求的地址： https://iam.cn-north-4.myhuaweicloud.com/v3/auth/tokens
请求头数据:
（6）代码实现
/* 功能: 获取token */ void Widget::GetToken() { //表示获取token function_select=3; QString requestUrl; QNetworkRequest request; //设置请求地址 QUrl url; //获取token请求地址 requestUrl = QString("https://iam.%1.myhuaweicloud.com/v3/auth/tokens") .arg(SERVER_ID); //自己创建的TCP服务器,测试用 //requestUrl="http://10.0.0.6:8080"; //设置数据提交格式 request.setHeader(QNetworkRequest::ContentTypeHeader, QVariant("application/json;charset=UTF-8")); //构造请求 url.setUrl(requestUrl); request.setUrl(url); QString text =QString("{"auth":{"identity":{"methods":["password"],"password":" "{"user":{"domain": {" ""name":"%1"},"name": "%2","password": "%3"}}}," ""scope":{"project":{"name":"%4"}}}}") .arg(MAIN_USER) .arg(IAM_USER) .arg(IAM_PASSWORD) .arg(SERVER_ID); //发送请求 manager->post(request, text.toUtf8()); }
复制代码5.6 查询设备影子数据代码
（1）这是请求代码
//查询设备属性 void Widget::Get_device_properties() { //表示获取token function_select=0; QString requestUrl; QNetworkRequest request; //设置请求地址 QUrl url; //获取token请求地址 requestUrl = QString("https://iotda.%1.myhuaweicloud.com/v5/iot/%2/devices/%3/shadow") .arg(SERVER_ID) .arg(PROJECT_ID) .arg(device_id); //设置数据提交格式 request.setHeader(QNetworkRequest::ContentTypeHeader, QVariant("application/json")); //设置token request.setRawHeader("X-Auth-Token",Token); //构造请求 url.setUrl(requestUrl); request.setUrl(url); //发送请求 manager->get(request); } //更新设备属性 void Widget::on_pushButton_update_device_clicked() { Get_device_properties(); }
复制代码（2）这是请求一次返回的 JSON 数据
{ "device_id": "6353a8163ec34a6d03c8dfe5_dev1", "shadow": [ { "service_id": "temp", "desired": { "properties": null, "event_time": null }, "reported": { "properties": { "temp": 45.6 }, "event_time": "20221024T013607Z" }, "version": 49 } ] }
复制代码5.7 界面设计最终效果
六、硬件部分
6.1 MQTT 版本
注意：华为云、OneNet、腾讯 IOT 等平台规定接入的 MQTT 协议版本必须是 3.1.1 。
在 BC26 里，需要执行这行代码配置 MQTT 协议版本为 3.1.1
AT+QMTCFG="version",0,4
复制代码6.2 BC26 上云配置代码
#include "BC26.h" //BC26复位 //引脚是PC0 //高电平有效 void BC26_Reset(void) { //开时钟 RCC->APB2ENR|=1<<4; //配置GPIO口 GPIOC->CRL&=0xFFFFFFF0; GPIOC->CRL|=0x00000003; //开始复位 GPIOC->ODR|=1<<0; DelayMs(2000); GPIOC->ODR&=~(1<<0); } /* 函数功能:向BC26模块发送指令 函数参数: char *cmd 发送的命令 char *check_data 检测返回的数据 返回值: 0表示成功 1表示失败 */ u8 BC26_SendCmd(char *cmd,char *check_data) { u16 i,j; for(i=0;i<5;i++) //测试的总次数 { USART2_RX_FLAG=0; USART2_RX_CNT=0; memset(USART2_RX_BUFFER,0,sizeof(USART2_RX_BUFFER)); USARTx_StringSend(USART2,cmd); //发送指令 for(j=0;j<500;j++) //等待的时间(ms单位) { if(USART2_RX_FLAG) { USART2_RX_BUFFER[USART2_RX_CNT]='\0'; if(strstr((char*)USART2_RX_BUFFER,check_data)) { return 0; } else break; } delay_ms(30); //一次的时间 } } return 1; } //初始化BC26模块 int BC26_Init(void) { if(BC26_SendCmd("AT\r\n","OK")) { USART1_Printf("BC26模块不存在.\r\n"); return 1; } else { USART1_Printf("BC26模块正常!\r\n"); } if(BC26_SendCmd("AT+CIMI\r\n","OK")) { USART1_Printf("模块未插卡.\r\n"); return 3; } else { USART1_Printf("卡已经插好.\r\n"); } if(BC26_SendCmd("AT+CGATT=1\r\n","OK")) { USART1_Printf("配置:网络激活失败.\r\n"); return 3; } else { USART1_Printf("配置:网络激活成功.\r\n"); } if(BC26_SendCmd("AT+CGATT?\r\n","OK")) { USART1_Printf("状态:网络激活失败.\r\n"); return 4; } else { USART1_Printf("状态:网络激活成功.\r\n"); } if(BC26_SendCmd("AT+CSQ\r\n","OK")) { USART1_Printf("查询信号质量失败.\r\n"); return 5; } else { USART1_Printf("信号质量:%s\r\n",USART2_RX_BUFFER); } // if(BC26_SendCmd("AT+QGNSSC=1\r\n","OK")) // { // USART1_Printf("激活GPS定位失败.\r\n"); // return 6; // } // else // { // USART1_Printf("激活GPS定位成功.\r\n"); // } // // if(BC26_SendCmd("AT+QGNSSAGPS=1\r\n","OK")) // { // USART1_Printf("开启AGPS定位失败.\r\n"); // return 6; // } // else // { // USART1_Printf("开启AGPS定位成功.\r\n"); // } // // if(BC26_SendCmd("AT+CGPADDR=1\r\n","OK")) // { // USART1_Printf("激活GPRS场景失败.\r\n"); // return 7; // } // else // { // USART1_Printf("激活GPRS场景成功.\r\n"); // } // // DelayMs(1000); // DelayMs(1000); if(BC26_SendCmd("AT+CEREG?\r\n","+CEREG: 0,1")) { USART1_Printf("网络注册状态:失败.\r\n"); return 9; } else { USART1_Printf("网络注册状态:成功.\r\n"); } return 0; } //发送使用的缓冲区 char BC26_SEND_BUFF[500]; //MQTT协议登录服务器 int BC26_MQTT_Connect(void) { //1. 先关闭之前的连接 USART1_Printf("正在关闭之前的连接...\r\n"); BC26_SendCmd("AT+QMTCLOSE=0\r\n","OK"); DelayMs(4000); //关闭服务 BC26_SendCmd("AT+QMTCONN?\r\n","OK"); DelayMs(4000); //2. 连接MQTT服务器 USART1_Printf("正在连接MQTT服务器..\r\n"); sprintf(BC26_SEND_BUFF,"AT+QMTOPEN=0,"%s",%s\r\n",MQTT_SERVER_ADDR,MQTT_SERVER_PORT); if(BC26_SendCmd(BC26_SEND_BUFF,"OK")) { USART1_Printf("MQTT服务器连接失败:%s\r\n",BC26_SEND_BUFF); return 1; } else { USART1_Printf("MQTT服务器连接成功.\r\n"); } DelayMs(3000); //3. 登录MQTT服务器 USART1_Printf("正在登录MQTT服务器...\r\n"); sprintf(BC26_SEND_BUFF,"AT+QMTCONN=0,"%s","%s","%s"\r\n",MQTT_CLIENT_ID,MQTT_USERNAME,MQTT_PASSWORD); if(BC26_SendCmd(BC26_SEND_BUFF,"OK")) { USART1_Printf("MQTT服务器登录失败:%s\r\n",BC26_SEND_BUFF); return 2; } else { USART1_Printf("MQTT服务器登录成功.\r\n"); } DelayMs(3000); //4. 订阅主题 USART1_Printf("正在订阅主题...\r\n"); sprintf(BC26_SEND_BUFF,"AT+QMTSUB=0,1,"%s",2\r\n",MQTT_TOPIC_SUB_GET); if(BC26_SendCmd(BC26_SEND_BUFF,"OK")) { USART1_Printf("MQTT主题订阅失败:%s\r\n",BC26_SEND_BUFF); } else { USART1_Printf("MQTT主题订阅成功.\r\n"); } return 0; } //MQTT发布主题 int MQTT_PublishTheme(char *text) { char send_buf[3]; sprintf(BC26_SEND_BUFF,"AT+QMTPUB=0,0,0,0,"%s"\r\n",MQTT_TOPIC_SUB_SET); if(BC26_SendCmd(BC26_SEND_BUFF,">")) { USART1_Printf("发布主题等待输入失败:%s\r\n",BC26_SEND_BUFF); return 1; } USARTx_StringSend(USART2,text); //发送主题内容 //发送结束符 send_buf[0] = 0x1a; send_buf[1] = '\0'; if(BC26_SendCmd(send_buf,"OK")) { USART1_Printf("发布主题内容失败:%s\r\n",BC26_SEND_BUFF); return 2; //发送结束符号 } else { USART1_Printf("发布主题内容成功.\r\n"); } USART1_Printf("发布主题内容:%s\r\n",text); return 0; } //MQTT响应应用层的属性请求 int MQTT_SendAttribute(char *text,char *request_id) { char send_buf[3]; sprintf(BC26_SEND_BUFF,"AT+QMTPUB=0,0,0,0,"%s%s"\r\n",MQTT_TOPIC_SUB_SET_RUN,request_id); if(BC26_SendCmd(BC26_SEND_BUFF,">")) { USART1_Printf("(响应)发布主题等待输入失败:%s\r\n",BC26_SEND_BUFF); return 1; } USARTx_StringSend(USART2,text); //发送主题内容 //发送结束符 send_buf[0] = 0x1a; send_buf[1] = '\0'; if(BC26_SendCmd(send_buf,"OK")) { USART1_Printf("(响应)发布主题内容失败:%s\r\n",BC26_SEND_BUFF); return 2; //发送结束符号 } else { USART1_Printf("(响应)发布主题内容成功.\r\n"); } USART1_Printf("(响应)发布主题内容:%s\r\n",text); return 0; } /* 函数功能: 获取一次GPS经纬度数据 函数参数: double *Longitude :经度 double *latitude :纬度 返回值: 0表示定位成功,1表示数据接收失败,2表示定位失败 */ u8 BC26_GetGPS_Data(double *Longitude,double *latitude) { /*1. 发送获取GPS数据的指令*/ if(BC26_SendCmd("AT+QGNSSRD="NMEA/RMC"\r\n", "OK\r\n"))return 1; /*2. 对GPS数据进行解码*/ if(GPS_GNRMC_Decoding((char *)USART2_RX_BUFFER,Longitude,latitude))return 2; //解码成功 return 0; } /* 函数功能: 开启GPS功能 返 回 值：0表示成功 1表示失败 */ u8 BC26_StartGPS(void) { //先判断GPS功能是否启动 if(BC26_SendCmd("AT+QGNSSC?\r\n","+QGNSSC: 1")) { //没有启动就启动GPS功能 if(BC26_SendCmd("AT+QGNSSC=1\r\n","OK\r\n")) { USART1_Printf("开启GPS功能失败.\r\n"); return 1; //GPS功能启动失败 } else { USART1_Printf("开启GPS功能成功.\r\n"); } } return 0; }
复制代码6.3 MQTT 3.1 协议介绍
地址: http://docs.oasis-open.org/mqtt/mqtt/v3.1.1/os/mqtt-v3.1.1-os.html
规范共分七章： 第一章 - 介绍 第二章 - MQTT控制包格式 第三章 - MQTT控制包 第四章 - 操作行为 第五章 - 安全 第六章 - 使用WebSocket进行网络传输 第七章 - 一致性目标 
/3 
