Связь Esp8266

[Vanesik22]

Подскажите как организовать связь между двумя модулями? Чтоб первый считывал температуру с датчика и отправлял второму, а второй выводил уже в веб сервер? (Надо подключить ко второму несколько модулей)

 

[nikolz]

Подскажите как организовать связь между двумя модулями? Чтоб первый считывал температуру с датчика и отправлял второму, а второй выводил уже в веб сервер? (Надо подключить ко второму несколько модулей)

проще всего по протоколу ESp-now (см документацию)

 

[Vanesik22]

проще всего по протоколу ESp-now (см документацию)

Спасибо, попробую

 

[Vanesik22]

проще всего по протоколу ESp-now (см документацию)

не нашёл ниодного примера в инете, этим протоколом никто не пользуется?

 

[nikolz]

не нашёл ниодного примера в инете, этим протоколом никто не пользуется?

я пользуюсь.
смотрите также mesh на ESP - этот протокол позволяет строить свои сети
Пример есть в документации по SDK и на сайте разработчика ESP
Там все очень просто по сравнению с TCP и даже с UDP но ограничение - короткие пакеты.

 

[CodeNameHawk]

Подскажите как организовать связь между двумя модулями?

Если автономно, то одну есп запускаете в режиме AP остальные есп подключаются к ней и передают данные.
Если все подключаются к роутеру, то проще всего одной или всем есп задать постоянный IP адрес.
На одной запускаете веб сервер, на остальных клиент.
Передавать разные типы данных (нп. byte, int) удобно преобразуя их при помощи JSON.

 

[Paul_B]

Вот мои примеры.
На обоих модулях организуется Web-сервер

void Server_ini()
{
  if (HTTP_Server == false)
  {
    server.on("/", []() {
      // если был запущен сервер настроек и идет обращение к нему,
      // то запускаем страницу настроек WiFi

      Send_Module = Module_ID;
      if (EEPROM_ini == true) Show_htm("/setting.htm");
      else {
        Read_State();
        Show_htm("/status.htm");
      }
    });
 
    server.on("/save", []() {
      InputHTTP();
      if (server.hasArg("first"))
       {
      //  Serial.println("\nFirst SSID="+ server.arg("ssid")+" PASS="+server.arg("pswd"));
        EEPROM_Save("first");
        }
      else {
        EEPROM_Save("");
      }
    });

 
    server.on("/clear", EEPROM_Clear);

    server.on("/rescanWiFi", []() {
      Show_htm("/setting.htm");
    });

    server.on("/memory", []() {

      EEPROM_Read(true);
      Show_htm("/setting.htm");
    });

    server.on("/spiffs", []() {
      InputHTTP();
      Spiffs_Files();  
    });


    server.on("/sms", Sms);


    server.on("/mailsetting", []() {
   
      InputHTTP();
      String S=String(server.arg("mailfrom"));
      S.trim();
      if(S=="" || (StringSymbol(S,"@")==1 && StringSymbol(S,".")>0))
        {
         String_to_Char(S,&smtpUser);
         if(smtpUser!=NULL)
           {
            byte i=String(smtpUser).indexOf("@");
            if(i<255) String_to_Char("smtp."+String(smtpUser).substring(i+1, String(smtpUser).length()),&smtpHost);
           }
        }

      if (server.hasArg("mailpass"))
       {
        if (server.arg("mailpass").indexOf("**") != 1)
           String_to_Char(server.arg("mailpass"),&smtpPass); 
       }
      S=server.arg("mailto");
      S.trim();
      if(S=="" || (StringSymbol(S,"@")==1 && StringSymbol(S,".")>0))
        String_to_Char(S,&mailTo);

      String_to_Char(server.arg("mailsubj"),&Mail_Subj);
   
      EEPROM_Mail_Save();
      Show_htm("/setting.htm");
    });
 
    server.on("/entertime", []() {
      Now_Time.GMT = server.arg("gmt").toInt();
      if (Now_Time.year + 1900 < 2000) AskNTPTime = false;
      else {
             
        unsigned long Tm=Date_to_Unix(server.arg("mydate"), server.arg("mytime"));
        secsUnix_delta = Tm - secsUnix;
            
        secsUnix = Tm;
        Unix_to_GMT(secsUnix, &Now_Time);
        Serial.println(Time_to_String("dwt"));
        AskNTPTime = true;
      }
      EEPROM_Time_Save();
      Show_htm("/setting.htm");
    });

    server.on("/boot", []() {
      // перезагрузка модуля
      InputHTTP();
      ESP_reset = true;

    });
    server.on("/onlyota", []() {
      // ввод в режим Arduino OTA
      InputHTTP();
      Only_OTA = true;
      if (Arduino_OTA) ArduinoOTA.begin();
      Time_to_Time = millis();

    });

    server.on("/reset", []() {
      // перезагрузка модуля
      InputHTTP();
      ESP.reset();
      delay(1000);
    });

    server.on("/root", []() {
      InputHTTP();
      Show_htm("/setting.htm");
    });

    server.on("/json", []() {
      InputHTTP();
      Make_json();
    });

    server.on("/status", []() {
      //  Serial.println("\n**************/status Send Module="+Send_Module);
      InputHTTP();
      Show_htm("/status.htm");
    });

    server.on("/status1", []() {
      InputHTTP();
      Show_htm("/message.htm");
    });
 

    server.on("/diagram", []() {
      InputHTTP();
      Show_htm("/temp_hum.htm");
      TF_file_All(0, 15);

    });

    server.on("/timer", []() {
      if (Send_Module != Module_ID || Module_GPIO != Module_ID)
      {
        Send_Module = Module_ID;
        Read_State();
      }
      Show_htm("/timer.htm");
    });

    server.on("/send_message", []() {
      byte i,j;
      InputHTTP();
      String_to_Char(server.arg("modul"), &Send_Message);
      Message_send = server.arg("message");
   //   Serial.println("/send_message Send_Module="+Send_Module+" server.arg(modul)="+server.arg("modul")+" Module_ID="+Module_ID+" Message="+Message_send);
      for (i = 0; i < 4; i++)
        ip_send[i] = server.arg("ip" + String(i)).toInt();
 
      Period_send = server.arg("periodsend").toInt();
   
      i = Message_send.indexOf("&from_ip");
      if (i >= 0) Message_send = Message_send.substring(0, i);
   
      if (Message_send.charAt(0)!='/') Message_send = "/" + Message_send;
      if (Message_send.indexOf("?") == -1) Message_send = Message_send + "?";
 
      Message_send.replace("?&", "?");
      if (ip_send[0] != 0)
        {
         Message_send.replace("^", "&");
         Write_Answer("Sended to IP: "+String(ip_send[0])+"." +String(ip_send[1])+"."+String(ip_send[2])+"."+String(ip_send[3])+" Message: "+ Message_send+" with period: "+String(Period_send));
        }
      else if (String(Send_Message) != "" && !Eq_module(String(Send_Message), Module_ID))
              Write_Answer("Sended to module: ["+String(Send_Message)+"] Message: " + Message_send);
        
       if(SendtoIP()==false) Write_Answer("Bad send. Message=" + Message_send);
       myDelete(&Send_Message);
    });

    server.on("/transit", Send_Transit);

    server.on("/OK", []() {

        InputHTTP();
        if(server.arg("func") == "transit")
          for(byte i=0;i<5;i++)
             if(For_Send[i]!=NULL)
                 if(String(For_Send[i]->Subj).indexOf("/transit") >= 0)
                    if(For_Send[i]->id == server.arg("from_id").toInt())
                      {
                       myDelete(&(For_Send[i]->Subj));   
                       delete For_Send[i];
                       For_Send[i]=NULL;
                      }
     
        if(server.arg("func") == "sendmail")
          {
            myDelete(&Mail_Message);
            Write_Answer(" e-Mail was sended from "+server.arg("module_begin"));
          }
 
    });

    server.on ("/gpio", []() {
      InputHTTP();
      byte i, On;
      int tm;
      String S = "", S1;

      if (Module_GPIO != Module_ID) Read_State();
      else Read_GPIO_State();
   
      for (i = 0; i < All_GPIO_OUT; i++)
          if (server.hasArg("g" + String(GPIO_OUT[i])))
            {
              S1=server.arg("g" + String(GPIO_OUT[i]));
              S += "GPIO" + String(GPIO_OUT[i]) + " label " + String(GPIO_Name[GPIO_OUT[i]]);
              if (S1 == "1")
              {
                Write_State(GPIO_OUT[i], 2, true);
                S +=  " set HIGH";
              }else if (S1 == "0")
                    {
                     Write_State(GPIO_OUT[i], 1, true);
                     S += " set LOW";
                    } else {
                            On=(S1.substring(0,1)).toInt()+1;
                            tm=(S1.substring(2,S1.length()-2)).toInt();  
                            if(tm<10 || HTA[i]!=NULL)
                              {
                               Write_State(GPIO_OUT[i], On, true);
                               myPause(tm+1);
                               Write_State(GPIO_OUT[i], GPIO_OUT_S[GPIO_OUT[i]]%2+1, true);
                              } else {          
                                     Init_HTA(i);
                                     HTA[i]->Timer_ON=On;
                                     HTA[i]->GPIO_NEXT=secsUnix;
                                     if(S1!="") HTA[i]->GPIO_LONG=tm;
                                     else HTA[i]->GPIO_LONG=1;
                                     S=" set in "+String(HTA[i]->Timer_ON==2?"HIGH":"LOW")+" for time "+String(HTA[i]->GPIO_LONG);
                                     }
                            }
           }

      Serial.println(S);

      if (server.hasArg("module_begin"))
        SendModule(server.arg("module_end"), server.arg("module_begin"), "/sms?func=gpio_ans&mod_set=" + Module_ID + "&gpio_data=" + S + "&from_id="+server.arg("id"), 0);
      else if (server.hasArg("from_module"))
        SendModule(Module_ID, server.arg("from_module"), "/sms?func=gpio_ans&mod_set=" + Module_ID + "&gpio_data=" + S + "&from_ip=" + IP_to_String(isSTA(String_to_IP(server.arg("from_ip"))) ? AP_ip : ip) + "&from_chip=" + Chip_id + "&from_module=" + Module_ID +"&from_id="+server.arg("id"), 0);
      else  server.send ( 200, "text/html", S);


    } );





    server.begin();
    Serial.println("HTTP server started");
    HTTP_Server = true;
  }

}

А передачу сообщений провожу так:

bool Send_Client(IPAddress ip, const String& Subj)
{
  bool rez=false;
  WiFiClient* client=new WiFiClient;
 
  client->setTimeout(3000);
  Serial.println("\nSend Client ip="+IP_to_String(ip)+" Subj="+Subj);
// Write_Answer("Send Client ip="+IP_to_String(ip)+" message="+Subj);
  if (client->connect(ip, 80))
     {
      client->print("POST " + Subj + " HTTP/1.1\r\nHost: " + IP_to_String(ip) + "\r\nConnection: close\r\n\r\n");
      client->flush();
      client->stop();
      rez=true;
     }  
   else Serial.println("Not Connect");  
   delete client;
   client=NULL;
   return(rez);
}

Вот непосредственно передача

Send_Client(in_ip, "/sms?func=time&secsUnix=" + String(secsUnix)+ "&from_id=" + id);

На самом деле все гораздо сложнее, потому что мои модули сами организуются в сеть и могут передавать сообщения из одной сетки в другую, т.е. не обязательно находясь в одной подсети. Один модуль, который подключен к одной сети и организует точку доступа может передавать сообщения из одной подсети в другую.