文章目錄

• 1 SIM7020建立MQTT連接和斷開MQTT連接的AT指令
• 2 SIM7020連接阿里云的流程
• 3 代碼實現

1 SIM7020建立MQTT連接和斷開MQTT連接的AT指令

首先看下相關AT指令：

//創建連接 [11-14 17:51:10:942]AT+CMQNEW="a1gPAyS0jai.iot-as-mqtt.cnshanghai.aliyuncs.com","1883",12000,1024 [11-14 17:51:12:058]+CMQNEW: 0 [11-14 17:51:12:058]OK//配置三元組 [11-1417:51:13:368]AT+CMQALICFG=0,"a1gPAyS0jai","s0001","abd7aff3aa5dd6a44d85ec03561c733c" [11-14 17:51:13:398]OK//建立連接 [11-14 17:51:16:006]AT+CMQALICON=0,600,1 [11-14 17:51:16:487]OK//訂閱主題 [11-14 17:51:18:125]AT+CMQSUB=0,"/sys/a1gPAyS0jai/s0001/thing/model/up_raw",1 [11-14 17:51:19:584]OK [11-14 17:51:20:262]AT+CMQSUB=0,"/sys/a1gPAyS0jai/s0001/thing/model/down_raw",1 [11-14 17:51:20:978]OK//發布主題 [11-1417:51:22:346]AT+CMQPUB=0,"/sys/a1gPAyS0jai/s0001/thing/model/up_raw",1,0,0,16,"3 132333435363738" [11-14 17:51:22:906]OK//接收到信息 [11-14 17:51:23:938]+CMQPUB:0,"/sys/a1gPAyS0jai/s0001/thing/model/up_raw",1,0,0,16,"3132333435363738"//取消訂閱 [11-14 17:51:24:885]AT+CMQUNSUB=0,"/sys/a1gPAyS0jai/s0001/thing/model/up_raw" [11-14 17:51:26:897]OK//斷開連接 [11-14 17:51:37:469]AT+CMQDISCON=0 [11-14 17:51:37:530]OK

---

2 SIM7020連接阿里云的流程

首先我們需要知道設備三元組，然后再確定服務器地址和端口號。

比如，設備三元組如下：

ProductKey: a1gPAyS0jai DeviceName: s0001 DeviceSecret: abd7aff3aa5dd6a44d85ec03561c733c

接入的域名如下：${YourProductKey}.iot-as-mqtt.${YourRegionId}.aliyuncs.com，替換后a1gPAyS0jai.iot-as-mqtt.cn-shanghai.aliyuncs.com。端口號為1833。

常用的TOPIC如下：

// 上報(發布) /sys/a1gPAyS0jai/s0001/thing/model/up_raw// 設備接收(訂閱) /sys/a1gPAyS0jai/s0001/thing/model/down_raw

SIM7020連接阿里云的AT指令如下：

// -創建連接 AT+CMQNEW="a1gPAyS0jai.iot-as-mqtt.cn-shanghai.aliyuncs.com","1883",12000,1024// -設置三元組 AT+CMQALICFG=0,"a1gPAyS0jai","s0001","abd7aff3aa5dd6a44d85ec03561c733c"// -建立建立 AT+CMQALICON=0,600,1// -訂閱topic AT+CMQSUB=0,"/sys/a1gPAyS0jai/s0001/thing/model/up_raw",1 AT+CMQSUB=0,"/sys/a1gPAyS0jai/s0001/thing/model/down_raw",1// -發布信息 AT+CMQPUB=0,"/sys/a1gPAyS0jai/s00001/thing/model/up_raw",1,0,0,16,"3132333435363738"// -取消訂閱 AT+CMQUNSUB=0,"/sys/a1gPAyS0jai/s00001/thing/model/up_raw"// -斷開連接 AT+CMQDISCON=0

---

3 代碼實現

建立MQTT連接流程如下：

斷開MQTT流程如下：

實現代碼如下：

#include <string.h> #include <stdio.h> #include "main.h" #include "at_parse.h" #include "app_debug.h" #include "at_net.h"#include "FreeRTOS.h" #include "task.h"#define AT_CMD_AT "AT" #define AT_CMD_ATE0 "ATE0" #define AT_CMD_GET_IMEI "AT+GSN" //get imei #define AT_CMD_GET_IMSI "AT+CIMI" //get imsi #define AT_CMD_SET_APN "AT*MCGDEFCONT=\"IP\",\"\"" //cmnbiot "AT*MCGDEFCONT=\"IP\",\"cmnbiot\"" #define AT_CMD_CFUN0 "AT+CFUN=0" #define AT_CMD_CFUN1 "AT+CFUN=1" #define AT_CMD_CPIN "AT+CPIN?" #define AT_CMD_CSQ "AT+CSQ" #define AT_CMD_CEREG "AT+CEREG?" #define AT_CMD_CGACT "AT+CGACT?" #define AT_CMD_CGCONTRDP "AT+CGCONTRDP" #define AT_CMD_PSM_REPORT "AT+CPSMSTATUS=1" #define AT_CMD_PSM_ON "AT+CPSMS=1,,,\"01001010\",\"00000000\"" #define AT_CMD_PSM_OFF "AT+CPSMS=0" #define AT_REPORT_PSM "+CPSMSTATUS:"#define AT_CMD_CMQNEW "AT+CMQNEW" #define AT_CMD_CMQTTSNEW "AT+CMQTTSNEW" #define AT_CMD_CMQCON "AT+CMQCON" #define AT_CMD_CMQSUB "AT+CMQSUB" #define AT_CMD_CMQUNSUB "AT+CMQUNSUB" #define AT_CMD_CMQDISCON "AT+CMQDISCON" #define AT_CMD_CMQPUB "AT+CMQPUB" #define AT_CMD_CMQALICFG "AT+CMQALICFG" #define AT_CMD_CMQALICON "AT+CMQALICON" #define AT_CMD_CREVHEX "AT+CREVHEX=1" //0-raw data 1-hex #define AT_RECV_MQTT "+CMQPUB:" #define AT_RECV_MQTT_DISCON "+CMQDISCON:"#define STATUS_IS_ON() (!HAL_GPIO_ReadPin(M_STA_GPIO_Port,M_STA_Pin)) #define STATUS_IS_OFF() (HAL_GPIO_ReadPin(M_STA_GPIO_Port,M_STA_Pin)) #define PWRKEY_HIGH() HAL_GPIO_WritePin(M_PWR_GPIO_Port,M_PWR_Pin,GPIO_PIN_RESET) #define PWRKEY_LOW() HAL_GPIO_WritePin(M_PWR_GPIO_Port,M_PWR_Pin,GPIO_PIN_SET)#define SIM_RECV_BUF_SIZE 150 #define SIM_SEND_BUF_SIZE 150struct sim7020_control_t {char recv_buf[SIM_RECV_BUF_SIZE];uint16_t recv_len;char send_buf[SIM_SEND_BUF_SIZE];uint8_t socket; }sim_ctl;static bool is_inited=false;bool sim7020_mqtt_connect(char *server,uint16_t port,char *prokey,char *devname,char *devsecret) {uint16_t err=0;if(is_inited==false)return false;while(err<3){err++;if(sim7020_pwr_on()!=true)continue;if(sim7020_check_net()!=true)continue;memset(sim_ctl.send_buf,0,SIM_SEND_BUF_SIZE);snprintf(sim_ctl.send_buf,SIM_SEND_BUF_SIZE,"%s=\"%s\",\"%d\",12000,1024",AT_CMD_CMQNEW,server,port);if(sim7020_send_atcmd(sim_ctl.send_buf,"+CMQNEW:",10000)!=true)continue;sim_ctl.socket=sim_ctl.recv_buf[9]-0x30;vTaskDelay(50);memset(sim_ctl.send_buf,0,SIM_SEND_BUF_SIZE);snprintf(sim_ctl.send_buf,SIM_SEND_BUF_SIZE,"%s=%d,\"%s\",\"%s\",\"%s\"",AT_CMD_CMQALICFG,sim_ctl.socket,prokey,devname,devsecret);if(sim7020_send_atcmd(sim_ctl.send_buf,"OK",10000)!=true)continue;memset(sim_ctl.send_buf,0,SIM_SEND_BUF_SIZE);snprintf(sim_ctl.send_buf,SIM_SEND_BUF_SIZE,"%s=%d,600,1",AT_CMD_CMQALICON,sim_ctl.socket);if(sim7020_send_atcmd(sim_ctl.send_buf,"OK",10000)!=true)continue;return true;}return false; }static bool sim7020_enter_psm() {uint16_t err=0;uint16_t counter=0;while(err<2){err++;if(sim7020_send_atcmd(AT_CMD_PSM_OFF,"OK",2000)!=true)continue;vTaskDelay(2000);if(sim7020_send_atcmd(AT_CMD_PSM_ON,"OK",2000)!=true)continue;counter=0;while (counter<15){counter++;DEBUG("wait enter psm ...");vTaskDelay(1000);if(STATUS_IS_OFF())return true;} }return sim7020_pwr_off(); }bool sim7020_mqtt_disconnect(void) {if(is_inited==false)return false;memset(sim_ctl.send_buf,0,SIM_SEND_BUF_SIZE);snprintf(sim_ctl.send_buf,SIM_SEND_BUF_SIZE,"%s=%d",AT_CMD_CMQDISCON,sim_ctl.socket);sim7020_send_atcmd(sim_ctl.send_buf,"OK",10000);return sim7020_enter_psm(); }at_net_dev_t dev_sim7020={.init=sim7020_init,.deinit=sim7020_deinit,.mqtt_connect=sim7020_mqtt_connect,.mqtt_disconnect=sim7020_mqtt_disconnect, };

測試代碼如下：

/* USER CODE BEGIN Header_StartDefaultTask */ /*** @brief Function implementing the defaultTask thread.* @param argument: Not used* @retval None*/ /* USER CODE END Header_StartDefaultTask */ void StartDefaultTask(void const * argument) {/* USER CODE BEGIN StartDefaultTask *//* Infinite loop */float temp,humi;uint8_t write_buf[]="1234567890";uint8_t read_buf[20];uint16_t read_len;#define TEST_NAME 0X0001uint8_t buf[5];char reply_buf[30];uint16_t reply_len;debug_init();led_init();key_init();led_blink(2,5);sht30_init();//at_parse_init();//at_register_callback("+MQTT",test_callback,NULL);#define SERVER "a1gPAyS0jai.iot-as-mqtt.cn-shanghai.aliyuncs.com"#define PRO_KEY "a1gPAyS0jai"#define DEV_NAME "s0001"#define DEV_SECRET "abd7aff3aa5dd6a44d85ec03561c733c"at_net_dev_register(&dev_sim7020);at_net_init();at_net_mqtt_connect(SERVER,1883,PRO_KEY,DEV_NAME,DEV_SECRET);vTaskDelay(10000);at_net_mqtt_disconnect();for(;;){ // memset(reply_buf,0,30);// reply_len=30;// if(at_send_wait_reply("AT+CSQ",true,"+CSQ","ERROR",reply_buf,&reply_len,1000))// {// DEBUG("-----recv %d,%s------",reply_len,reply_buf);// }//at_send_no_reply("AT",2,true,1000);//at_uart_send("12345\r\n",7,1000);// storage_write(TEST_NAME,sizeof(write_buf),write_buf);// memset(read_buf,0,20);// read_len=20;// if(storage_read(TEST_NAME,&read_len,read_buf))// {// DEBUG("------%s-----",read_buf);// }// if(sht30_get_temp_humi(&temp,&humi))// {// DEBUG("temp=%f,humi=%f",temp,humi);// }osDelay(1000);}/* USER CODE END StartDefaultTask */ }

總結

以上是生活随笔為你收集整理的NB驱动建立MQTT连接和断开MQTT连接的代码实现的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。