#include "aliIotLink.h"
|
|
|
SHA256 sha256;
|
|
AliIotLink::AliIotLink(PubSubClient& client)
|
{
|
_client = &client;
|
}
|
void AliIotLink::begin()
|
{
|
//randomSeed(analogRead(A0)); //获取IO随机值【非安全的伪随机】作为种子
|
//delayMicroseconds(random(0,10000)); //延迟随机时间
|
|
generateClientId();
|
readUrl();
|
readUser();
|
readPasswd();
|
_client->setServer(_URL.c_str(),_port); //写入服务器名称与端口号
|
|
}
|
|
|
void AliIotLink::begin(String __DeviceName,String __ProductKey,String __DeviceSecret)
|
{
|
_Id = __DeviceName;
|
_DeviceName = __DeviceName;
|
_ProductKey = __ProductKey;
|
_DeviceSecret = __DeviceSecret;
|
//randomSeed(analogRead(A0));
|
//delayMicroseconds(random(0,10000));
|
generateClientId();
|
readUrl();
|
readUser();
|
readPasswd();
|
_client->setServer(_URL.c_str(),_port); //写入服务器名称与端口号
|
}
|
|
void AliIotLink::writeUrl(String __ServerUrl) // 设置登录网址
|
{
|
//_ServerUrl = __ServerUrl;
|
}
|
//服务器端口设置
|
void AliIotLink::writePort(uint16_t __port)
|
{
|
_port = __port;
|
}
|
//硬件设备名称
|
void AliIotLink::writeID(String __Id)
|
{
|
_Id = __Id;
|
}
|
// 设置设备硬件标签名称【阿里云提供】
|
void AliIotLink::writeDeviceName(String __DeviceName)
|
{
|
_DeviceName = __DeviceName;
|
}
|
//【阿里云提供】
|
void AliIotLink::writeProductKey(String __ProductKey)
|
{
|
_ProductKey = __ProductKey;
|
}
|
//【阿里云提供】
|
void AliIotLink::writeDeviceSecret(String __DeviceSecret)
|
{
|
_DeviceSecret = __DeviceSecret;
|
}
|
|
void AliIotLink::generateClientId()
|
{
|
//ID+参数+随机数+结尾符号
|
randomSeed(micros());
|
Times =random(0, 65535);
|
_ClientId = _Id + FPSTR(_ClientIdSuffix) + Times +"|";
|
}
|
|
//获取合成好的登录用的ClientId
|
String AliIotLink::readClientId()
|
{
|
return _ClientId;
|
}
|
|
|
//合成访问网址
|
String AliIotLink::readUrl()
|
{
|
_URL = _ProductKey + F(".") + FPSTR(_ServerUrl);
|
return _URL;
|
}
|
|
//合成访问用户名
|
String AliIotLink::readUser()
|
{
|
_Username = _DeviceName + "&" + _ProductKey ;
|
return _Username;
|
}
|
|
|
//合成访问密码
|
String AliIotLink::readPasswd()
|
{
|
String _Passwd = "clientId" + _Id + "deviceName" + _DeviceName +"productKey"+_ProductKey + "timestamp" + Times;
|
_PasswdHash = "";
|
|
byte hashData[64];
|
|
HMAC(_DeviceSecret.c_str(), 32, _Passwd.c_str(), _Passwd.length(), hashData);
|
|
for (int i = 0; i < 32; i++) //hash 固定长度
|
{
|
_PasswdHash = _PasswdHash + "0123456789ABCDEF"[hashData[i] >> 4];
|
_PasswdHash = _PasswdHash + "0123456789ABCDEF"[hashData[i] & 0xf];
|
}
|
|
//
|
return _PasswdHash;
|
//返回HASH密文
|
}
|
//===================mqtt部分=====================
|
|
bool AliIotLink::connect()
|
{
|
|
|
return _client->connect(_ClientId.c_str(),_Username.c_str(),_PasswdHash.c_str()); //像服务器传递 ClientId，用户名，密码
|
|
|
}
|
|
//重连
|
void AliIotLink::reconnect()
|
{
|
|
while(!_client->connected()) //检查网络网络是否不正常，断开的网络会锁定重试
|
{
|
|
if (connect()) //重连并判断是否成功
|
{
|
|
//成功
|
for(byte a = 0;a<TopicNum;a++)
|
{
|
subscribe(TopicName[a].c_str());
|
}
|
|
//填写上线订阅，应该是个String数组传入循环订阅处理
|
}
|
else
|
{
|
//链接失败
|
|
delay(5000); //暂停5秒钟重试
|
}
|
}
|
}
|
|
|
//循环检测
|
void AliIotLink::loop()
|
{
|
if (!_client->connected())
|
{
|
reconnect();
|
}
|
_client->loop();
|
}
|
|
|
int AliIotLink::state() //错误消息返回
|
{
|
return _client->state();
|
}
|
|
|
|
//回调函数
|
void AliIotLink::setCallback(MQTT_CALLBACK_SIGNATURE)
|
{
|
_client->setCallback(callback);
|
//SerialUSB.println(callback);
|
}
|
//监听Topic
|
void AliIotLink::subscribe(const char* topic)
|
{
|
_client->subscribe(topic);
|
}
|
//推送消息
|
void AliIotLink::publish(const char* topic, const char* payload)
|
{
|
_client->publish(topic,payload);
|
}
|
|
|
//登记topic
|
void AliIotLink::subTopic(String topic)
|
{
|
TopicName[TopicNum] = topic;
|
TopicNum++;
|
if(TopicNum > MQTT_Topic_Quantity)
|
{
|
TopicNum = MQTT_Topic_Quantity;
|
}
|
}
|
|
void AliIotLink::HMAC( char const *key, byte KeySize, char const *data, byte dataSize, byte *hashData)
|
{
|
uint8_t result[32];
|
sha256.resetHMAC(key, KeySize); //传入KEY,和key长度
|
sha256.update(data, dataSize);// 传输 hash明文
|
sha256.finalizeHMAC(key, KeySize, result, sizeof(result)); // 计算
|
for (byte a = 0; a < sizeof(result); a++) //传出签名
|
{
|
*(hashData + a) = result[a];
|
}
|
}
|
