STM32 阿里云MQTT esp8266 AT命令

stm32通过esp8266 AT命令连接阿里云物联网。不引用库，自己写协议数据以便了解MQTT

为方便调试，上位机的AT命令可以通过stm32发送给esp8266，

1、先看效果

依次发送AT命令连接到阿里云

最后设置每隔60秒发送心跳

阿里云可以看到上线设备

2、连接地址

连接地址的格式为
${YourProductKey}.iot-as-mqtt.${YourRegionId}.aliyuncs.com
{YourProductKey}是阿里云产品key
{YourRegionId}是地域码，参考阿里云【地域和可用区】

3、MQTT的CONNECT部分

那一串16进制数据（这串数据通过下面的c语言生成，生成的是16进制字符串）：

#define MYCLIENT_ID          "xxxxx"
#define MYCLIENT_ID_Full    "xxxxx|securemode=3,signmethod=hmacsha1|"
#define DEVICE_NAME         "yyyyy"
#define PRODUCT_KEY         "jjjjj"
#define USER_NAME           "yyyyy&jjjjj"
#define DEVICE_SECRET       "zzzzzzzzzzzz"
#define USER_PASSWORD       "6A3026C603CA534335512514F596A5F87DE2B542"

xxxx：是客户端单片机自己的id，随便填（没有使用时间戳timestamp）

yyyyyy：是阿里云设备名

zzzzzzzzzzzz：是阿里云设备密钥

jjjjjjj：是阿里云产品key

#define Append(x,y)      memcpy(x + strlen(x),y,strlen(y))
#define AppendU16(x,y)  AppendNum(x,y,4)
#define AppendU8(x,y)   AppendNum(x,y,2)
const char *gEncode = "0123456789ABCDEF";
void AppendNum(char* datas,u16 lenth,u8 size) {char len[4];u8 i;u8 move;move=(size-1)<<2;for(i=0;i<size;i++,move-=4){len[i]=gEncode[(lenth >> move) & 0xf];}len[i]='\0';Append(datas,len);
}
void AppendStr(char* datas,const char* str) {char temp[512];u16 i=0;while(*str){temp[i++]=gEncode[((*str)>>4) & 0xf];temp[i++]=gEncode[(*str) & 0xf];str++;}temp[i]='\0';if(datas[0])Append(datas,temp);elsememcpy(datas,temp,strlen(temp));
}void test3() {char datas[1024];u16 lenth;lenth=strlen(MYCLIENT_ID_Full)+strlen(USER_NAME)+strlen(USER_PASSWORD)+2*3+10;memset(datas,0,1024);//类型(×)Append(datas,"10");//接下来的剩余数据的长度(我的数据不超过128，所以只需1个byte)AppendU8(datas,lenth);//协议类型、长度、版本等等(×)Append(datas,"00044d51545404c2003c");//客户端单片机ID长度AppendU16(datas,strlen(MYCLIENT_ID_Full));//客户端单片机IDAppendStr(datas,MYCLIENT_ID_Full);//用户名长度AppendU16(datas,strlen(USER_NAME));//用户名AppendStr(datas,USER_NAME);//密码长度AppendU16(datas,strlen(USER_PASSWORD));//密码AppendStr(datas,USER_PASSWORD);printf("%s\r\n",datas);
}

4、USER_PASSWORD用户密码生成

4.1、使用阿里云的“Password生成小工具”（打开页面，搜索这个工具名称）

4.2、用C语言计算

void test4() {char datas[1024];char sign_hex[100];char res[100];memset(datas, 0, 1024);Append(datas,"clientId");Append(datas,MYCLIENT_ID);Append(datas,"deviceName");Append(datas,DEVICE_NAME);Append(datas,"productKey");Append(datas,PRODUCT_KEY);//Append(datas,"timestamp");//Append(datas,TIMESTAMP);memset(sign_hex, 0, 100);hmac_sha1((u8*)DEVICE_SECRET,strlen(DEVICE_SECRET), (u8*)datas, strlen(datas), sign_hex);memset(res, 0, 100);AppendStr(res,sign_hex);printf("%s\r\n",res);
}

引用到的sha1文件

#include "hmacsha1.h"#define MAX_MESSAGE_LENGTH 1000/*****************************/
/**** Function Prototypes ****/
/*****************************/unsigned long int ft(int t,unsigned long int x,unsigned long int y,unsigned long int z);int get_testcase(   int test_case,unsigned char *plaintext,unsigned char *key,int *key_length_ptr);void sha1   (unsigned char *message,int message_length,unsigned char *digest);/**************************/
/* Debug out              */
/**************************/#ifdef HMAC_DEBUG
debug_out(unsigned char *label,unsigned char *data,int data_length)
{
int i,j;
int num_blocks;
int block_remainder;num_blocks = data_length / 16;block_remainder = data_length % 16;printf("%s\n",label);for (i=0; i< num_blocks;i++){printf("\t");for (j=0; j< 16;j++){printf("%02x ", data[j + (i*16)]);}printf("\n");}if (block_remainder > 0){printf("\t");for (j=0; j<block_remainder; j++){printf("%02x ", data[j+(num_blocks*16)]);}printf("\n");}
}
#endif/****************************************/
/* sha1()                               */
/* Performs the NIST SHA-1 algorithm    */
/****************************************/unsigned long int ft(int t,unsigned long int x,unsigned long int y,unsigned long int z)
{
unsigned long int a,b,c;if (t < 20){a = x & y;b = (~x) & z;c = a ^ b;}else if (t < 40){c = x ^ y ^ z;}else if (t < 60){a = x & y;b = a ^ (x & z);c = b ^ (y & z);}else if (t < 80){c = (x ^ y) ^ z;}return c;
}unsigned long int k(int t)
{
unsigned long int c;if (t < 20){c = 0x5a827999;}else if (t < 40){c = 0x6ed9eba1;}else if (t < 60){c = 0x8f1bbcdc;}else if (t < 80){c = 0xca62c1d6;}return c;
}unsigned long int rotr(int bits, unsigned long int a)
{
unsigned long int c,d,e,f,g;c = (0x0001 << bits)-1;d = ~c;e = (a & d) >> bits;f = (a & c) << (32 - bits);g = e | f;return (g & 0xffffffff );}unsigned long int rotl(int bits, unsigned long int a)
{
unsigned long int c,d,e,f,g;c = (0x0001 << (32-bits))-1;d = ~c;e = (a & c) << bits;f = (a & d) >> (32 - bits);g = e | f;return (g & 0xffffffff );}void sha1   (unsigned char *message,int message_length,unsigned char *digest)
{
int i;
int num_blocks;
int block_remainder;
int padded_length;unsigned long int l;
unsigned long int t;
unsigned long int h[5];
unsigned long int a,b,c,d,e;
unsigned long int w[80];
unsigned long int temp;#ifdef SHA1_DEBUG
int x,y;
#endif/* Calculate the number of 512 bit blocks */padded_length = message_length + 8; /* Add length for l */padded_length = padded_length + 1; /* Add the 0x01 bit postfix */l = message_length * 8;num_blocks = padded_length / 64;block_remainder = padded_length % 64;if (block_remainder > 0){num_blocks++;}padded_length = padded_length + (64 - block_remainder);/* clear the padding field */for (i = message_length; i < (num_blocks * 64); i++){message[i] = 0x00;           }/* insert b1 padding bit */message[message_length] = 0x80;/* Insert l */message[(num_blocks*64)-1] = (unsigned char)( l        & 0xff);message[(num_blocks*64)-2] = (unsigned char)((l >> 8)  & 0xff);message[(num_blocks*64)-3] = (unsigned char)((l >> 16) & 0xff);message[(num_blocks*64)-4] = (unsigned char)((l >> 24) & 0xff);/* Set initial hash state */h[0] = 0x67452301;h[1] = 0xefcdab89;h[2] = 0x98badcfe;h[3] = 0x10325476;h[4] = 0xc3d2e1f0;#ifdef SHA1_DEBUGprintf("INITIAL message_length = %d\n", message_length);printf("INITIAL padded_length = %d\n", padded_length);printf("INITIAL num_blocks = %d\n", num_blocks);for (x=0;x<num_blocks; x++){printf("\t\t"); for (y=0; y<16;y++){printf("%02x ",message[y + (x*64)]);}printf("\n");printf("\t\t"); for (y=0; y<16;y++){printf("%02x ",message[16 + y + (x*64)]);}printf("\n");printf("\t\t"); for (y=0; y<16;y++){printf("%02x ",message[32 + y + (x*64)]);}printf("\n");printf("\t\t"); for (y=0; y<16;y++){printf("%02x ",message[48 + y + (x*64)]);}printf("\n");}#endiffor (i = 0; i < num_blocks; i++){/* Prepare the message schedule */for (t=0; t < 80; t++){if (t < 16){w[t]  = (256*256*256) * message[(i*64)+(t*4)];w[t] += (256*256    ) * message[(i*64)+(t*4) + 1];w[t] += (256        ) * message[(i*64)+(t*4) + 2];w[t] +=                 message[(i*64)+(t*4) + 3];}else if (t < 80){w[t] = rotl(1,(w[t-3] ^ w[t-8] ^ w[t-14] ^ w[t-16]));}}#ifdef SHA1_DEBUGprintf("\tW(0) = %08lX \t W(9)  = %08lX \n", w[0], w[8]);printf("\tW(1) = %08lX \t W(10) = %08lX \n", w[1], w[9]);printf("\tW(2) = %08lX \t W(11) = %08lX \n", w[2], w[10]);printf("\tW(3) = %08lX \t W(12) = %08lX \n", w[3], w[11]);printf("\tW(4) = %08lX \t W(13) = %08lX \n", w[4], w[12]);printf("\tW(5) = %08lX \t W(14) = %08lX \n", w[5], w[13]);printf("\tW(6) = %08lX \t W(15) = %08lX \n", w[6], w[14]);printf("\tW(7) = %08lX \t W(16) = %08lX \n\n", w[7], w[15]);#endif/* Initialize the five working variables */a = h[0];b = h[1];c = h[2];d = h[3];e = h[4];/* iterate a-e 80 times */for (t = 0; t < 80; t++){temp = (rotl(5,a) + ft(t,b,c,d)) & 0xffffffff;temp = (temp + e) & 0xffffffff;temp = (temp + k(t)) & 0xffffffff;temp = (temp + w[t]) & 0xffffffff;e = d;d = c;c = rotl(30,b);b = a;a = temp;
#ifdef SHA1_DEBUGprintf("t = %2ld\t %08lx, %08lx, %08lx, %08lx, %08lx\n", t,a,b,c,d,e);
#endif}/* compute the ith intermediate hash value */
#ifdef SHA1_DEBUGprintf("  +   \t %08lx, %08lx, %08lx, %08lx, %08lx\n", h[0],h[1],h[2],h[3],h[4]);
#endifh[0] = (a + h[0]) & 0xffffffff;h[1] = (b + h[1]) & 0xffffffff;h[2] = (c + h[2]) & 0xffffffff;h[3] = (d + h[3]) & 0xffffffff;h[4] = (e + h[4]) & 0xffffffff;#ifdef SHA1_DEBUGprintf("  =   \t %08lx, %08lx, %08lx, %08lx, %08lx\n", h[0],h[1],h[2],h[3],h[4]);
#endif}digest[3]  = (unsigned char) ( h[0]       & 0xff);digest[2]  = (unsigned char) ((h[0] >> 8) & 0xff);digest[1]  = (unsigned char) ((h[0] >> 16) & 0xff);digest[0]  = (unsigned char) ((h[0] >> 24) & 0xff);digest[7]  = (unsigned char) ( h[1]       & 0xff);digest[6]  = (unsigned char) ((h[1] >> 8) & 0xff);digest[5]  = (unsigned char) ((h[1] >> 16) & 0xff);digest[4]  = (unsigned char) ((h[1] >> 24) & 0xff);digest[11]  = (unsigned char) ( h[2]       & 0xff);digest[10]  = (unsigned char) ((h[2] >> 8) & 0xff);digest[9] = (unsigned char) ((h[2] >> 16) & 0xff);digest[8] = (unsigned char) ((h[2] >> 24) & 0xff);digest[15] = (unsigned char) ( h[3]       & 0xff);digest[14] = (unsigned char) ((h[3] >> 8) & 0xff);digest[13] = (unsigned char) ((h[3] >> 16) & 0xff);digest[12] = (unsigned char) ((h[3] >> 24) & 0xff);digest[19] = (unsigned char) ( h[4]       & 0xff);digest[18] = (unsigned char) ((h[4] >> 8) & 0xff);digest[17] = (unsigned char) ((h[4] >> 16) & 0xff);digest[16] = (unsigned char) ((h[4] >> 24) & 0xff);}/******************************************************/
/* hmac-sha1()                                        */
/* Performs the hmac-sha1 keyed secure hash algorithm */
/******************************************************/void hmac_sha1(unsigned char *key,int key_length,unsigned char *data,int data_length,unsigned char *digest){int b = 64; /* blocksize */unsigned char ipad = 0x36;unsigned char opad = 0x5c;unsigned char k0[64];unsigned char k0xorIpad[64];unsigned char step7data[64];unsigned char step5data[MAX_MESSAGE_LENGTH+128];unsigned char step8data[64+20];int i;for (i=0; i<64; i++){k0[i] = 0x00;}if (key_length != b)    /* Step 1 */{/* Step 2 */if (key_length > b)      {sha1(key, key_length, digest);for (i=0;i<20;i++){k0[i]=digest[i];}}else if (key_length < b)  /* Step 3 */{for (i=0; i<key_length; i++){k0[i] = key[i];}}}else{for (i=0;i<b;i++){k0[i] = key[i];}}
#ifdef HMAC_DEBUGdebug_out("k0",k0,64);
#endif/* Step 4 */for (i=0; i<64; i++){k0xorIpad[i] = k0[i] ^ ipad;}
#ifdef HMAC_DEBUGdebug_out("k0 xor ipad",k0xorIpad,64);
#endif/* Step 5 */for (i=0; i<64; i++){step5data[i] = k0xorIpad[i];}for (i=0;i<data_length;i++){step5data[i+64] = data[i];}
#ifdef HMAC_DEBUGdebug_out("(k0 xor ipad) || text",step5data,data_length+64);
#endif/* Step 6 */sha1(step5data, data_length+b, digest);#ifdef HMAC_DEBUGdebug_out("Hash((k0 xor ipad) || text)",digest,20);
#endif/* Step 7 */for (i=0; i<64; i++){step7data[i] = k0[i] ^ opad;}#ifdef HMAC_DEBUGdebug_out("(k0 xor opad)",step7data,64);
#endif/* Step 8 */for (i=0;i<64;i++){step8data[i] = step7data[i];}for (i=0;i<20;i++){step8data[i+64] = digest[i];}#ifdef HMAC_DEBUGdebug_out("(k0 xor opad) || Hash((k0 xor ipad) || text)",step8data,20+64);
#endif/* Step 9 */sha1(step8data, b+20, digest);#ifdef HMAC_DEBUGdebug_out("HASH((k0 xor opad) || Hash((k0 xor ipad) || text))",digest,20);
#endif
}

STM32 阿里云MQTT esp8266 AT命令相关推荐

【开源】手机APP通过IoT点亮LED灯（STM32+ESP8266+阿里云+MQTT+Android)
(STM32+ESP8266+阿里云+MQTT+Android) 本项目利用Android Studio编写了连接阿里云和MQTT的APP,并在UI界面简单设计了标题,连接按钮,点灯按钮,灭灯按钮.如 ...
阿里云MQTT + STM32 + MQTT + ESP8266 01S WIFI 实现远程继电器控制开关和采集温湿度登录阿里云网站，进入物联网云平台
单片机型号: STM32F103C8T6 WIFI型号: ESP8266 01S WIFI 运行协议: TCP STM32运行MQTT协议登录阿里云网站,进入物联网云平台进入阿里云官网并登录账号后 ...
【STM32 x ESP8266】连接阿里云 MQTT 服务器（报文连接）
具体如何在阿里云创建一个 MQTT 服务器我就不写出来了,可以去百度一下(主要是我忘了,不好演示). 有关 MQTT 报文的一些标识在我前面的一篇文章中讲过,感兴趣的可以去看看(有关代码部分讲解的内容 ...
ESP8266连接阿里云--MQTT协议
ESP8266连接阿里云–MQTT协议 MQTT(Message Queuing Telemetry Transport,消息队列遥测传输协议),是一种基于发布/订阅(Publish/Subscr ...
亿佰特串口服务器接入阿里云MQTT协议的软件配置教程
在之前的文章中我们了解到虚拟串口软件作为TCP客户端来结合串口服务器使用,这一期我们来看一下串口服务器怎样接入阿里云物模型. 步骤详尽,一文读懂. 1.阿里云MQTT环境配置 ③点击"创建产 ...
mqtt 发送消息过多_阿里云MQTT服务端注解式消息处理分发与同步调用实践小结
一.前言前段时间公司预研了设备app端与服务端的交互方案,出于多方面考量最终选用了阿里云的微服务队列MQTT方案,基于此方案,本人主要实践有: 1. 封装了RocketMQ实现MQTT订阅与发布的实 ...
做了一个阿里云MQTT单片机编程小工具
做了一个阿里云MQTT单片机编程小工具,点击测试http://www.norra.cn:9091/ 传感云是采集.传输.存储.可视化.接口.APP.微信一体的传感器与应用服务平台,支持多种模式 ...
移远BC35-G配置网络连接阿里云MQTT发送数据
移远BC35/BC26/BC28配置网络连接阿里云MQTT发送数据(一)精.防踩坑硬件准备接线部分软件准备烧录固件 QFlash 4.17烧录阿里云准备测试准备(AT指令) 连接阿里云第 ...
入住阿里云MQTT物联网平台
注册阿里云: 网址:阿里云-上云就上阿里云进入阿里云平台主页,点右上角"立即注册",你可以选择"扫码快速注册"或"账号密码注册"两种方式进 ...
1、esp32（arduino）接入阿里云MQTT及数据处理
esp32(arduino)接入阿里云MQTT服务器 1.遇到的问题和需求 2.解决方案 2.1.系统框图 2.2.待测产品 2.3.采集器 2.3.网关 2.4.服务器 2.5.数据库 2.6.客户 ...

STM32 阿里云MQTT esp8266 AT命令

STM32 阿里云MQTT esp8266 AT命令相关推荐

最新文章

热门文章