diff --git a/.vscode/settings.json b/.vscode/settings.json
index 63df4c0..e6de926 100644
--- a/.vscode/settings.json
+++ b/.vscode/settings.json
@@ -15,7 +15,9 @@
"memory_resource": "cpp",
"system_error": "cpp",
"*.tcc": "cpp",
- "functional": "cpp"
+ "functional": "cpp",
+ "string.h": "c",
+ "arduino.h": "c"
},
"C_Cpp.errorSquiggles": "disabled"
}
\ No newline at end of file
diff --git a/lib/aliyun_iot_sdk/src/aliyun_iot_sdk.cpp b/lib/aliyun_iot_sdk/src/aliyun_iot_sdk.cpp
index ec12650..fd0ef6a 100644
--- a/lib/aliyun_iot_sdk/src/aliyun_iot_sdk.cpp
+++ b/lib/aliyun_iot_sdk/src/aliyun_iot_sdk.cpp
@@ -23,6 +23,7 @@ static const char *deviceName = NULL;
static const char *productKey = NULL;
static const char *deviceSecret = NULL;
static const char *region = NULL;
+static const char *iotInstanceId = NULL;
struct DeviceProperty {
String key;
@@ -90,7 +91,7 @@ static void parmPass(JsonVariant parm) {
}
static void callback(char *topic, byte *payload, unsigned int length) {
- Serial.print("Message arrived [");
+ Serial.print("INFO\tMessage arrived [");
Serial.print(topic);
Serial.print("] ");
payload[length] = '\0';
@@ -153,12 +154,15 @@ int AliyunIoTSDK::begin(PubSubClient &mqttClient,
const char *_productKey,
const char *_deviceName,
const char *_deviceSecret,
+ const char *_iotInstanceId,
const char *_region) {
client = new PubSubClient(mqttClient);
productKey = _productKey;
deviceName = _deviceName;
deviceSecret = _deviceSecret;
+ iotInstanceId = _iotInstanceId;
region = _region;
+ int port = 443;
long times = millis();
String timestamp = String(times);
@@ -183,13 +187,20 @@ int AliyunIoTSDK::begin(PubSubClient &mqttClient,
sprintf(ALINK_TOPIC_PROP_SET, "/sys/%s/%s/thing/service/property/set", productKey, deviceName);
sprintf(ALINK_TOPIC_EVENT, "/sys/%s/%s/thing/event", productKey, deviceName);
- sprintf(domain, "%s.iot-as-mqtt.%s.aliyuncs.com", productKey, region);
- client->setServer(domain, MQTT_PORT);
+ if (NULL != iotInstanceId) {
+ sprintf(domain, "%s.mqtt.iothub.aliyuncs.com", productKey);
+ port = 443;
+ } else {
+ sprintf(domain, "%s.iot-as-mqtt.%s.aliyuncs.com", productKey, region);
+ port = 1883;
+ }
+
+ client->setServer(domain, port);
#if defined USE_STANDARD_THING_MODEL_TOPIC
client->setCallback(callback);
#endif
- Serial.print("connection check in begin\n");
+ Serial.print("INFO\tconnection check in begin\n");
return mqttCheckConnect();
}
@@ -199,8 +210,6 @@ int AliyunIoTSDK::loop() {
if (millis() - lastMs >= CHECK_INTERVAL) {
lastMs = millis();
mqttStatus = mqttCheckConnect();
- // Serial.print("MQTT connect return: ");
- // Serial.println(mqttStatus);
}
if (0 == mqttStatus) {
@@ -215,9 +224,10 @@ void AliyunIoTSDK::sendEvent(const char *eventId, const char *param) {
snprintf(topicKey, sizeof(topicKey) - 1, "%d/%s/post", 0, eventId);
char jsonBuf[1024];
sprintf(jsonBuf, ALINK_EVENT_BODY_FORMAT, param, eventId);
+ Serial.print("INFO\tsend : ");
Serial.println(jsonBuf);
boolean d = client->publish(topicKey, jsonBuf);
- Serial.print("publish: 0 successfully: ");
+ Serial.print("INFO\tpublish : 0 successfully : ");
Serial.println(d);
}
@@ -227,13 +237,13 @@ void AliyunIoTSDK::sendEvent(const char *eventId) {
void AliyunIoTSDK::sendCustom(const char *topic, const char *eventBody) {
boolean d = client->publish(topic, eventBody);
- Serial.print("publish:0 sucessfully:");
+ Serial.print("INFO\tpublish : 0 sucessfully : ");
Serial.println(d);
}
void AliyunIoTSDK::sendCustomData(const char *topic, const uint8_t *data, int length) {
boolean d = client->publish(topic, data, length);
- Serial.print("publish:0 sucessfully:");
+ Serial.print("INFO\tpublish : 0 sucessfully : ");
Serial.println(d);
}
@@ -255,8 +265,6 @@ void AliyunIoTSDK::messageBufferCheck() {
bufferSize++;
}
}
- // Serial.println("bufferSize:");
- // Serial.println(bufferSize);
if (bufferSize > 0) {
if (bufferSize >= MESSAGE_BUFFER_SIZE) {
sendBuffer();
@@ -301,9 +309,10 @@ void addMessageToBuffer(char *key, String value) {
void AliyunIoTSDK::send(const char *param) {
char jsonBuf[1024];
sprintf(jsonBuf, ALINK_BODY_FORMAT, param);
+ Serial.print("INFO\tsend : ");
Serial.println(jsonBuf);
boolean d = client->publish(ALINK_TOPIC_PROP_POST, jsonBuf);
- Serial.print("publish:0 sucessfully:");
+ Serial.print("INFO\tpublish : 0 sucessfully : ");
Serial.println(d);
}
diff --git a/lib/aliyun_iot_sdk/src/aliyun_iot_sdk.h b/lib/aliyun_iot_sdk/src/aliyun_iot_sdk.h
index ec33946..413486a 100644
--- a/lib/aliyun_iot_sdk/src/aliyun_iot_sdk.h
+++ b/lib/aliyun_iot_sdk/src/aliyun_iot_sdk.h
@@ -62,12 +62,14 @@ public:
* @param _productKey : AliyunIoT product key
* @param _deviceName : AliyunIoT device name
* @param _deviceSecret : AliyunIoT device secret
+ * @param _iotInstanceId : AliyunIoT instance ID
* @param _region : AliyunIoT region
*/
static int begin(PubSubClient &mqttClient,
const char *_productKey,
const char *_deviceName,
const char *_deviceSecret,
+ const char *_iotInstanceId,
const char *_region);
/**
diff --git a/lib/aliyun_iot_sdk/如何使用 arduino-aliyun-iot-sdk 2 行代码接入物联网平台.md b/lib/aliyun_iot_sdk/如何使用 arduino-aliyun-iot-sdk 2 行代码接入物联网平台.md
deleted file mode 100644
index 56ad984..0000000
--- a/lib/aliyun_iot_sdk/如何使用 arduino-aliyun-iot-sdk 2 行代码接入物联网平台.md
+++ /dev/null
@@ -1,210 +0,0 @@
-> 文中提到的 AliyunIoTSDK 这个 arduino 库，可以在 arduino 库商店里搜索到（搜索 AliyunIoTSDK），但是版本可能不一定是最新的，也可以手动把 github 上的项目 clone 下来，放到 arduino 的 library 库下，保证功能是最新的。
-
-> github 地址：[https://github.com/xinyu198736/arduino-aliyun-iot-sdk](https://github.com/xinyu198736/arduino-aliyun-iot-sdk)
-
-> 有问题，欢迎提 issues 或 PR 共建，我对 c++ 不是特别熟悉，写出来的代码可能不一定是最合理的。
-
-## 阿里云物联网平台简介
-
-阿里云物联网平台提供接入物联网场景的一整套基础设施，强大的在线配置能力，基本可以实现无代码开发接入各类应用，实现大规模的物联网应用场景。
-
-核心能力模块包括：
-
-- 产品&设备创建和管理
-- 服务可视化开发
-- 控制界面可视化开发
-- 数据分析和监控运维等辅助设施
-
-基于以上功能模块，可以快速在阿里云定义设备模型和事件等信息，然后快速创建和接入设备，再利用可视化的开发平台，可以零代码实现非常强大的功能。
-
-不过，今天我们要介绍一个比较特殊的接入场景，使用嵌入式系统快速接入阿里云物联网平台，这里以 esp8266 为例。
-
-> esp8266 是一款集成网络模块的嵌入式芯片，自带 32 位处理器，各种外设接口，wifi 模块等，可以使用 arduino 平台进行编程，兼容大量 arduino 库。
-
-
-本文就是以 arduino 编程方式，使用的 esp8266 开发板为 NodeMCU 1.0 ，淘宝成本仅为 8~10 元。
-
-
-## 场景
-
-本次我们想利用 ESP8266 芯片实现一个简单的可远程控制的空调控制器，具备以下功能：
-
-- 批量部署，可通过云平台集中管理和远程控制空调开关、温度、模式等
-- 芯片可感知环境温度、亮度，并上报物联网平台
-- 芯片可远程触发事件，上报物联网平台
-- 成本尽量低，不超过 30 元
-
-首先，我们进行硬件选型，经过功能评估，选用以下硬件：
-
-- nodemcu 核心板（基于 esp8266） 10.89元/个
-- DS18B20模块 温度传感 3.18元/个
-- GY-30 光照传感 4.38元/个
-- 红外发射板 3.5元/个
-- 杜邦线母对母 1.45元/串
-- 电源插头 1.4元/个
-- 数据线 1.8元/个
-- 按钮开关 0.75元/个
-
-
-## 开始接入
-
-具体的连线，我们这里不展开，我们主要探讨如何使用 arduino 快速接入物联网平台。
-
-第一步，在物联网创建产品，建立物模型，并创建设备，获取设备配置信息。
-
-
-创建产品，并定义物模型
-
-
-创建设备，与产品绑定，获取设备鉴权信息
-
第二步，用 arduino 连接 nodemcu 开发板，开始硬件端的开发。
-
-具体接线可以自己研究，这里只是个展示，哈哈
-
-
-## 硬件端开发
-这里不讨论如何使用 arduino 进行 esp8266 芯片开发，直接进入代码环节，相关基础知识可以百度一下。
-
-首先，亮相一个我自己封装的 aliyun iot 上层 SDK（ [arduino-aliyun-iot-sdk](https://github.com/xinyu198736/arduino-aliyun-iot-sdk) ），底层连接基于 PubSubClient 库，并且对模型操作做了一些上层封装，可以方便的发送数据和订阅远程指令。
-```cpp
-// 引入 wifi 模块，并实例化，不同的芯片这里的依赖可能不同
-#include
-static WiFiClient espClient;
-
-// 引入阿里云 IoT SDK
-#include
-
-// 设置产品和设备的信息，从阿里云设备信息里查看
-#define PRODUCT_KEY "xxx"
-#define DEVICE_NAME "Device_D"
-#define DEVICE_SECRET "xxxxxxxxxxxxxx"
-#define REGION_ID "cn-shanghai"
-
-// 设置 wifi 信息
-#define WIFI_SSID "xxxxx"
-#define WIFI_PASSWD "xxxxx"
-
-void setup()
-{
- Serial.begin(115200);
-
- // 初始化 wifi
- wifiInit(WIFI_SSID, WIFI_PASSWD);
-
- // 初始化 iot，需传入 wifi 的 client，和设备产品信息
- AliyunIoTSDK::begin(espClient, PRODUCT_KEY, DEVICE_NAME, DEVICE_SECRET, REGION_ID);
-
- // 绑定一个设备属性回调，当远程修改此属性，会触发 powerCallback
- // PowerSwitch 是在设备产品中定义的物联网模型的 id
- AliyunIoTSDK::bindData("PowerSwitch", powerCallback);
-
- // 发送一个数据到云平台，LightLuminance 是在设备产品中定义的物联网模型的 id
- AliyunIoTSDK::send("LightLuminance", 100);
-}
-
-void loop()
-{
- AliyunIoTSDK::loop();
-}
-
-// 初始化 wifi 连接
-void wifiInit(const char *ssid, const char *passphrase)
-{
- WiFi.mode(WIFI_STA);
- WiFi.begin(ssid, passphrase);
- while (WiFi.status() != WL_CONNECTED)
- {
- delay(1000);
- Serial.println("WiFi not Connect");
- }
- Serial.println("Connected to AP");
-}
-
-// 电源属性修改的回调函数
-void powerCallback(JsonVariant p)
-{
- int PowerSwitch = p["PowerSwitch"];
- if (PowerSwitch == 1)
- {
- // 启动设备
- }
-}
-```
-
-核心代码只有三句：
-
-```cpp
-// 初始化 iot，需传入 wifi 的 client，和设备产品信息
-AliyunIoTSDK::begin(espClient, PRODUCT_KEY, DEVICE_NAME, DEVICE_SECRET, REGION_ID);
-
-// 绑定一个设备属性回调，当远程修改此属性，会触发 powerCallback
-// PowerSwitch 是在设备产品中定义的物联网模型的 id
-AliyunIoTSDK::bindData("PowerSwitch", powerCallback);
-
-// 发送一个数据到云平台，LightLuminance 是在设备产品中定义的物联网模型的 id
-AliyunIoTSDK::send("LightLuminance", 100);
-```
-
-注意这里的数据绑定和数据发送，是非常有用和方便的，不需要自己去写做匹配的代码，也不需要自己组装数据，并且会自动合并数据，节约上报的频率。
-
-将设备配置信息配置进代码，烧录到板子，运行即可，是不是炒鸡方便呢。
-
-注意事项：
-
-- 阿里云对客户端的链接参数有一些限制，需要修改 PubSubClient 的连接参数，否则无法使用
- - PubSubClient 中的 MQTT_MAX_PACKET_SIZE 修改为 1024
- - PubSubClient 中的 MQTT_KEEPALIVE 修改为 60
-- 默认 5000ms 检测一次连接状态，可以通过 AliyunIoTSDK.cpp 中的 CHECK_INTERVAL 修改此值
-- 掉线后会一直尝试重新连接，可能会触发阿里云的一些限流规则（已经做了规避），并且会导致挤掉其他同设备 ID 的设备
-
-### 资源
-目前 AliyunIoTSDK 这个 arduino 库，可以在 arduino 库商店里搜索到（搜索 AliyunIoTSDK），但是版本可能不一定是最新的，可以手动把 github 上的项目 clone 下来，放到 arduino 的 library 库下，保证功能是最新的。
-
-github 地址：[https://github.com/xinyu198736/arduino-aliyun-iot-sdk](https://github.com/xinyu198736/arduino-aliyun-iot-sdk)
-
-有问题，欢迎提 issues 或 PR 共建，我对 c++ 不是特别熟悉，写出来的代码可能不一定是最合理的。
-
-
-## 可视化开发界面和服务
-完成了设备的连接之后，已经迈出了第一步，如果你想要自己开发一个界面，可视化的控制空调，或者想利用一些远程设备的数据触发一些自定义的规则和逻辑（例如如果某个数据超标，报警到钉钉群等），用阿里云的物联网平台的话，这些都不需要自己去开发，直接使用物联网平台的“开发服务”拖拖拽拽即可完成。
-
-
-### 界面开发
-界面开发的核心是 拖动布局、数据源绑定、交互绑定、自定义变量等。
-
-
-布局界面，右侧可以设置各种控件属性
-
-
-数据源绑定，可以方便的和产品模型数据绑定
-
-
-交互绑定，可以与服务进行绑定，触发某个服务，并传入设备属性
-
-
-控件可以给自定义变量赋值，其他组件可以与变量绑定
-
-使用上述的功能，加上各种设备绑定功能，基本可以完成一个很复杂的界面的开发，但是如果你需要通过交互触发远程指令，或者监听远程的数据做一些判断逻辑，光有界面是不够的。
-
-
-### 服务开发
-上面提到的逻辑开发，就需要使用“服务开发”了，服务开发的触发点主要是两类：设备触发、界面交互触发。
-
-
-设备触发的服务，中间的路径选择是用来做条件判断分流的，最右侧是触发通知逻辑节点
-
-
-一个温度控制服务，通过界面控件触发，最终生成设备控制逻辑
-
-
-## 结语
-本文不是 arduino 教学，也不是 esp8266 教学，更不是硬件教学，所以没有展开细节，需要读者具备一定的基础，请各位谅解，如果对 arduino 开发感兴趣，可以加我微信交流（微信号：mier963，注明 arduino）。
-
-最后展示一下成果：
-
-一个成品，包含四个传感器模块，包括一个硬件按钮
-
-
-空调远程控制界面
-
另外，还可以给这个控制器加入一些很有意思的功能，例如定点关闭所有设备，根据环境亮度开关空调等。
-
diff --git a/src/aliot_client.cpp b/src/aliot_client.cpp
index 7684240..a6457bf 100644
--- a/src/aliot_client.cpp
+++ b/src/aliot_client.cpp
@@ -25,7 +25,7 @@
#include "serials.h"
#include "iot_hub.h"
-#include "ir_baby.h"
+#include "iris_client.h"
#include "aliyun_iot_sdk.h"
@@ -45,6 +45,7 @@ extern String g_downstream_topic;
extern int g_mqtt_port;
extern String g_aliot_region;
+extern String g_aliot_instance_id;
// private variable definitions
@@ -55,7 +56,8 @@ static AliyunIoTSDK iot;
// public function definitions
int connectToAliyunIoT(PubSubClient &mqtt_client) {
- if (0 == iot.begin(mqtt_client, g_product_key.c_str(), g_device_name.c_str(), g_device_secret.c_str(), g_aliot_region.c_str())) {
+ if (0 == iot.begin(mqtt_client, g_product_key.c_str(), g_device_name.c_str(), g_device_secret.c_str(),
+ g_aliot_instance_id.c_str(), g_aliot_region.c_str())) {
sendIrisKitConnect();
}
INFOLN("Aliyun IoT connected");
diff --git a/src/emq_client.cpp b/src/emq_client.cpp
index bd818fb..481a26b 100644
--- a/src/emq_client.cpp
+++ b/src/emq_client.cpp
@@ -25,7 +25,7 @@
#include "serials.h"
#include "iot_hub.h"
-#include "ir_baby.h"
+#include "iris_client.h"
#include "emq_client.h"
diff --git a/src/iot_hub.cpp b/src/iot_hub.cpp
index 9d1c985..c15ee4f 100644
--- a/src/iot_hub.cpp
+++ b/src/iot_hub.cpp
@@ -26,7 +26,7 @@
#include "serials.h"
#include "iot_hub.h"
-#include "ir_baby.h"
+#include "iris_client.h"
#include "global.h"
#include "emq_client.h"
@@ -43,6 +43,7 @@ String g_mqtt_server = "";
String g_product_key = "";
String g_device_name = "";
String g_device_secret = "";
+String g_device_token = "";
String g_mqtt_client_id = "";
String g_mqtt_user_name = "";
@@ -51,6 +52,7 @@ String g_upstream_topic = "";
String g_downstream_topic = "";
String g_aliot_region = "cn-shanghai";
+String g_aliot_instance_id = "iot-060a2sie";
int g_mqtt_port = 1883;
int g_app_id = 0;
diff --git a/src/ir_emit.cpp b/src/ir_emit.cpp
index e38f471..427d296 100644
--- a/src/ir_emit.cpp
+++ b/src/ir_emit.cpp
@@ -28,7 +28,7 @@
#include "global.h"
#include "serials.h"
#include "user_settings.h"
-#include "ir_baby.h"
+#include "iris_client.h"
#include "http_client.h"
#include "utils.h"
diff --git a/src/ir_emit.h b/src/ir_emit.h
index 84cf667..011c5b2 100644
--- a/src/ir_emit.h
+++ b/src/ir_emit.h
@@ -21,8 +21,8 @@
* SOFTWARE.
*/
-#ifndef IRIS_KIT_IR_H
-#define IRIS_KIT_IR_H
+#ifndef IRIS_KIT_EMIT_H
+#define IRIS_KIT_EMIT_H
#include
#include
@@ -54,4 +54,4 @@ bool saveIR(String file_name);
void initAC(String);
-#endif // IRIS_KIT_IR_H
\ No newline at end of file
+#endif // IRIS_KIT_EMIT_H
\ No newline at end of file
diff --git a/src/ir_baby.cpp b/src/iris_client.cpp
similarity index 96%
rename from src/ir_baby.cpp
rename to src/iris_client.cpp
index a31fc6a..2064300 100644
--- a/src/ir_baby.cpp
+++ b/src/iris_client.cpp
@@ -37,7 +37,7 @@
#include "http_client.h"
#include "ir_emit.h"
-#include "ir_baby.h"
+#include "iris_client.h"
extern StaticJsonDocument<1024> http_request_doc;
@@ -109,6 +109,7 @@ int authIrisKit(String credential_token,
String& product_key,
String& device_name,
String& device_secret,
+ String& device_token,
int& app_id) {
int ret = -1;
int tsi = -1;
@@ -160,9 +161,11 @@ int authIrisKit(String credential_token,
int resultCode = http_response_doc["status"]["code"];
if (0 == resultCode) {
INFOLN("response valid, try getting entity");
- device_secret = (const char*) http_response_doc["entity"]["deviceToken"];
+ // for aliot connection, use deviceToken as deviceSecret
+ device_token = (const char*) http_response_doc["entity"]["deviceToken"];
app_id = (int) http_response_doc["entity"]["appId"];
- INFOF("HTTP response deserialized, PK = %s, DN = %s, DS = %s\n", product_key.c_str(), device_name.c_str(), device_secret.c_str());
+ INFOF("HTTP response deserialized, PK = %s, DN = %s, DS = %s, DT = %s\n",
+ product_key.c_str(), device_name.c_str(), device_secret.c_str(), device_token.c_str());
ret = 0;
} else {
INFOF("response invalid, code = %d\n", resultCode);
diff --git a/src/ir_baby.h b/src/iris_client.h
similarity index 97%
rename from src/ir_baby.h
rename to src/iris_client.h
index 005cfae..93ecf8d 100644
--- a/src/ir_baby.h
+++ b/src/iris_client.h
@@ -57,6 +57,7 @@ int authIrisKit(String credential_token,
String& product_key,
String& device_name,
String& device_secret,
+ String& device_token,
int& app_id);
void sendIrisKitConnect();
diff --git a/src/iris_kit.cpp b/src/iris_kit.cpp
index cbfd96a..2a92b5c 100644
--- a/src/iris_kit.cpp
+++ b/src/iris_kit.cpp
@@ -32,7 +32,7 @@
#include "iot_hub.h"
#include "http_client.h"
#include "global.h"
-#include "ir_baby.h"
+#include "iris_client.h"
#include "serials.h"
#include "user_settings.h"
#include "utils.h"
@@ -48,6 +48,7 @@ extern String g_mqtt_server;
extern String g_product_key;
extern String g_device_name;
extern String g_device_secret;
+extern String g_device_token;
extern String g_mqtt_client_id;
extern String g_mqtt_password;
extern int g_app_id;
@@ -165,6 +166,7 @@ void setup() {
g_product_key,
g_device_name,
g_device_secret,
+ g_device_token,
g_app_id)) {
break;
}