Revision 0:63af4719467f, committed 2017-10-11

Comitter:

brainliang

Date:

Wed Oct 11 08:40:04 2017 +0000

Commit message:

esp8266

Changed in this revision

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/esp8266.cpp	Wed Oct 11 08:40:04 2017 +0000
@@ -0,0 +1,198 @@
+#include "esp8266.h"
+
+#include <cstdarg>
+#include <cstring>
+#include "mbed.h"
+
+// 连接模式
+// 修改为需要连接的 wifi 的 ssid
+const char wifi_ssid[] = "iotcar";
+// 修改为需要连接 wifi 的密码
+const char wifi_passwd[] = "iotcariotcar";
+
+// 选定与 esp8266 相连接的串口
+// 参数分别为 TX pin / RX pin
+Serial ser2esp8266(PC_10, PC_11);
+
+//#define DEBUG
+
+int ser_baud = 9600;
+
+//定义了一个调试的宏,C语言语法
+#define ESP_CMD(format, ...) do{\
+    ser2esp8266.printf("\r"); \
+    ser2esp8266.printf(format "\r", ##__VA_ARGS__);\
+    wait(0.3);\
+}while(0)
+
+
+#ifdef DEBUG
+void cb1() {                                                                    //将USB串口上得到的消息通过WIFI模块发出去
+    //ser2esp8266.putc(ser2usb.getc());
+}
+#endif
+
+void simple_callback() {                                                        //将WIFI模块得到的消息通过USB串口打印到电脑上
+    //ser2usb.putc(ser2esp8266.getc());
+}
+//#endif
+
+// 热点模式
+// 修改为需要建立的热点 ssid
+const char adhoc_ssid[] = "iotcar";
+
+// 此校园网登录账号无需修改
+const char net_id[] = "yangc12";
+const char net_passwd[] = "58a702fbc91f3e601de5188c6fb274ef";
+
+
+// 接收 esp8266 侧数据的回调函数, 每次仅接收一个8位字符
+static char esp_token[1024], esp_param[2048];
+static char esp_tokenBuf[1024], esp_paramBuf[2048];   // recv from esp8266
+static bool esp_buf_ready = false;
+// 数据格式约定: #token+data
+static void esp8266_rxCallback() {
+    char in = ser2esp8266.getc();
+    enum{STATE_WAIT, STATE_TOKEN, STATE_PARAM};
+    static uint8_t state = STATE_WAIT;
+    static int tokenLen, paramLen;
+    switch(state){
+    case STATE_WAIT:
+        if(in == '#'){
+            tokenLen = 0;
+            state = STATE_TOKEN;
+            //ser2usb.putc('w');
+        }
+        break;
+    case STATE_TOKEN:
+        //ser2usb.putc('t');
+        if(in == '+' || in == '\r' || in == '\n'){
+            esp_tokenBuf[tokenLen] = '\0';
+            if(in == '+'){
+                paramLen = 0;
+                state = STATE_PARAM;
+                //ser2usb.putc('!');
+            }else{
+                //gotResponse(tokenBuf, NULL);
+                //memcpy(esp_token, esp_tokenBuf, tokenLen);
+                //esp_token[tokenLen] = '\0';
+                esp_buf_ready = true;
+                state = STATE_WAIT;
+            }
+        }else if(tokenLen+1 < sizeof(esp_tokenBuf)){
+            esp_tokenBuf[tokenLen++] = in;
+        }
+        break;
+    case STATE_PARAM:
+        //ser2usb.putc('p');
+        if(in == '\r' || in == '\n'){
+            esp_paramBuf[paramLen] = '\0';
+            //gotResponse(tokenBuf, paramBuf);
+            //memcpy(esp_token, esp_tokenBuf, tokenLen);
+            //memcpy(esp_param, esp_paramBuf, paramLen);
+            //esp_token[tokenLen] = '\0';
+            //esp_param[paramLen] = '\0';
+            //ser2usb.putc('?');
+            esp_buf_ready = true;
+            state = STATE_WAIT;
+            return;
+        }else if(paramLen+1 < sizeof(esp_paramBuf)){
+            esp_paramBuf[paramLen++] = in;
+        }
+        break;
+    }
+}
+
+
+Esp8266::Esp8266(int mode)                                                      //定义类的函数
+    : network_start(false), mqtt_start(false) 
+{
+    // serial to esp8266 init
+    ser2esp8266.baud(ser_baud);
+#ifndef DEBUG
+    //ser2esp8266.attach(esp8266_rxCallback, Serial::RxIrq);    
+#endif
+    if (mode == 0) {                                                            // client mode 
+        this->reset();
+        this->connect_wifi();
+        this->weblogin();
+    } else {
+    
+    }
+}
+
+bool Esp8266::reset() {                                                         //定义类的函数
+    ESP_CMD("node.restart()");
+    wait(2);                                                                    // 延迟2s
+    return true;
+}   
+
+bool Esp8266::connect_wifi() {                                                  //定义类的函数
+    ESP_CMD("wifi.setmode(wifi.STATION)");
+    ESP_CMD("wifi.sta.config([[%s]],[[%s]])", wifi_ssid, wifi_passwd);
+    wait(2);
+    // set auto autoconnect
+    ESP_CMD("wifi.sta.autoconnect(1)");
+    ESP_CMD("print('\\035wifi+'..wifi.sta.status())");
+    network_start = true;
+    return true;
+}
+
+bool Esp8266::weblogin() {                                                      //定义类的函数
+    // not implemented yet
+    return true;
+}
+
+bool Esp8266::connect_mqtt_broker(char *ip) {                                   //定义类的函数
+    ESP_CMD("m = mqtt.Client('i_' .. node.chipid(), 120)");
+    ESP_CMD("m:connect(\"%s\")", ip);
+    wait(1);
+    // subscribe all the topic
+    mqtt_start = true;
+    return true;
+}
+    
+bool Esp8266::publish(char *topic, char *data, int size) {                      //定义类的函数
+    //if (mqtt_start) {
+        ESP_CMD("m:publish(\"%s\",\"%s\",0,0)", topic, data);
+    //}
+    wait(0.1);
+    return true;
+}
+
+bool Esp8266::subscribe_poll(char *topic, char *data, int size) {               //定义类的函数
+    //if (mqtt_start) {
+        ESP_CMD("m:subscribe(\"%s\", 0)", topic);
+        wait(0.1);
+    //}
+    ESP_CMD("m:on(\"message\", function(conn, topic, data)");
+    ESP_CMD("if topic == \"%s\" then", topic);
+    ESP_CMD("print(\"\\035\"..topic..\"+\"..data)");
+    ESP_CMD("end");
+    ESP_CMD("end)");
+     
+    ser2esp8266.attach(simple_callback, Serial::RxIrq);    
+    //ser2esp8266.attach(esp8266_rxCallback, Serial::RxIrq);    
+    
+    while (0) {
+        while(!esp_buf_ready);
+        esp_buf_ready = false; 
+        
+        //ser2usb.putc('x');
+        if (strcmp(topic, esp_tokenBuf) == 0) {
+    
+            if (size == -1) {
+                //uint8_t len = strlen(esp_param);
+                //memcpy(data, esp_param, len);
+                //data[len] = '\0';
+            } else {
+                //memcpy(data, esp_param, size);
+                //data[size] = '\0';
+            }
+            break;
+        }
+    }
+
+    ESP_CMD("m:unsubscribe(\"%s\")", topic);
+    return true;
+}
\ No newline at end of file

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/esp8266.h	Wed Oct 11 08:40:04 2017 +0000
@@ -0,0 +1,21 @@
+
+
+class Esp8266 {                                                                 //声明一个类
+    bool network_start;
+    bool mqtt_start;
+public:
+    // 0--client mode 1--host mode
+    Esp8266(int mode = 0);
+    
+    // 通用
+    bool reset();
+    
+    // 连接模式
+    bool connect_wifi();
+    bool weblogin();
+    bool connect_mqtt_broker(char *ip);
+    
+    bool publish(char *topic, char *data, int size = -1);
+    bool subscribe_poll(char *topic, char *data, int size = -1);
+    // 热点模式
+};
\ No newline at end of file

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/main.cpp	Wed Oct 11 08:40:04 2017 +0000
@@ -0,0 +1,33 @@
+/*-----------------------------------------------------
+ File Name : main.cpp
+ Purpose : For esp8266 mbed porting
+ Creation Date : 22-06-2017
+ Last Modified :
+ Created By : Jeasine Ma [jeasinema[at]gmail[dot]com]
+-----------------------------------------------------*/
+#include <cstdarg>
+#include <cstring>
+#include "mbed.h"
+#include "esp8266.h"
+
+
+Serial ser2usb(USBTX, USBRX);
+
+int main(void) {
+    Esp8266 client(0);
+    client.connect_mqtt_broker("tdxls-iot.xicp.net");
+    ser2usb.printf("Initialization done.\r\n");
+    
+    while(1) {
+        client.publish("/smartcar", "awesome smartcar!");
+        client.publish("/smartcar", "awesome smartcar!");
+        wait(1);
+        //char buf[32];    
+        //client.subscribe_poll("/icenter", buf, 32);
+        //ser2esp8266.attach(simple_callback, Serial::RxIrq);
+        //ser2usb.printf("%s\r\n", esp_paramBuf);
+        //ser2usb.printf("loop\r\n");
+        //ser2usb.printf("haha\n");
+        //while(1);
+    }
+}

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/mbed.bld	Wed Oct 11 08:40:04 2017 +0000
@@ -0,0 +1,1 @@
+https://mbed.org/users/mbed_official/code/mbed/builds/64910690c574
\ No newline at end of file