Void callback const mqtt publish pub ошибка

Hi Addi, first of all thanks for sharing i am starting with this awesome
world and your work is really something to start at.

I am getting this error when verifying the code with arduino ide. What´s
wrong? Might be a syntax issue with the new ide?

Thanks in advance

Javier

Arduino:1.6.9 (Windows 7), Tarjeta:»Generic ESP8266 Module, 80 MHz, 40MHz,
DIO, 115200, 512K (64K SPIFFS), ck, Disabled, None»

ESP8266_mqtt_relay_ADITYA:14: error: ‘MQTT’ does not name a type

void callback(const MQTT::Publish& pub) {

ESP8266_mqtt_relay_ADITYA:14: error: expected unqualified-id before ‘&’
token

void callback(const MQTT::Publish& pub) {

ESP8266_mqtt_relay_ADITYA:14: error: expected ‘)’ before ‘&’ token

ESP8266_mqtt_relay_ADITYA:14: error: expected initializer before ‘pub’

void callback(const MQTT::Publish& pub) {

ESP8266_mqtt_relay_ADITYA:14: error: ‘MQTT’ does not name a type

void callback(const MQTT::Publish& pub) {

ESP8266_mqtt_relay_ADITYA:14: error: expected unqualified-id before ‘&’
token

void callback(const MQTT::Publish& pub) {

ESP8266_mqtt_relay_ADITYA:14: error: expected ‘)’ before ‘&’ token

ESP8266_mqtt_relay_ADITYA:14: error: expected initializer before ‘pub’

void callback(const MQTT::Publish& pub) {

exit status 1
‘MQTT’ does not name a type

Este reporte podría tener más información con
«Mostrar salida detallada durante la compilación»
opción habilitada en Archivo -> Preferencias.

—
You are receiving this because you are subscribed to this thread.
Reply to this email directly, view it on GitHub
#1, or mute the thread
https://github.com/notifications/unsubscribe/AAtdagRaj50KL_jBHjxZxHniCVsVWj7Hks5qSnHcgaJpZM4JFNhf
.

Offline

Зарегистрирован: 25.12.2015

#include <SPI.h> // Ethernet shield
#include <Ethernet.h> // Ethernet shield
#include <PubSubClient.h> // MQTT 
#include <Servo.h>
#include <DHT.h>
#include <OneWire.h>
#include <DallasTemperature.h>
Servo servo;

byte mac[] = { 0xC1, 0x7C, 0x38, 0x41, 0x89, 0x12 };
byte server[] = { 192, 168, 1, 190 }; //IP Брокера
byte ip[] = { 192, 168, 1, 167 }; //IP Клиента (Arduino)


//EthernetClient ethClient; //ЗДЕСЬ КОМЕНТИРУЮ И КОПИРУЮ В ДРУГОЕ МЕСТО НИЖЕ
//PubSubClient client(server, 1883, callback, ethClient);
#define id_connect "myhome-kitchen"
#define Prefix_subscribe "myhome/Kitchen/"

///////////////Объявляем порты ввода-вывода
#define ServoPin 3 //Порт к которому подключен сервопривод

const int start_DI_pin [] = {2, 4, 5}; // Порты Ввода
int n_DI_pin = sizeof(start_DI_pin) / sizeof(start_DI_pin[0]) - 1; //Вычисляем длинну массива

const int start_DO_pin [] = {6, 7}; //Порты Вывода
int n_DO_pin = sizeof(start_DO_pin) / sizeof(start_DO_pin[0]) - 1; //Вычисляем длинну массива

int DI[] = {0, 0, 0};
int old_DI[] = {0, 0};

///////////////////////////Переменные для работы с освещением//////////////////////////////////////
int ServoAngle = 100; //Угол сервопривода при включении
int flag = 0;
int flag2 = 0;
int pause = 0;

//------------------------------------------- Sensors -------------------------------------------//
const int MQ7_Pin = A0; // Куда подключили MQ7
//int MQ7Value = 0;
int MQ7Value = analogRead(MQ7_Pin);


const int foto_Pin = A1; // устанавливаем входную ногу для Фоторезистора
//unsigned int fotoValue = 0; // цифровое значение фоторезистора
unsigned int fotoValue = analogRead(foto_Pin);

#define ONE_WIRE_BUS 8
OneWire oneWire(ONE_WIRE_BUS);
DallasTemperature DS_sensors(&oneWire);
// 28 FF F2 5C 53 15 2 97
DeviceAddress addr_T1 = { 0x28, 0xFF, 0xF2, 0x5C, 0x53, 0x15, 0x02, 0x97 };

float T1 = 0;

DHT DHT;
#define DHT22_PIN 9
float Hout = 0;
float Tout = 0;
//#define DHTPIN 2 // Номер пина, к которому подсоединен датчик
//#define DHTTYPE DHT22 // Задаём тип DHT датчика
//DHT dht(DHTPIN, DHTTYPE);


////////////////////////////////////////////////////////////////////////////
void callback(char* topic, byte* payload, unsigned int length) {
payload[length] = '';
// Serial.print(topic);
// Serial.print("=");
String strTopic = String(topic);
String strPayload = String((char*)payload);
// Serial.println(strPayload);
callback_iobroker(strTopic, strPayload);
}

EthernetClient ethClient; //ЗДЕСЬ КОМЕНТИРУЮ И КОПИРУЮ В ДРУГОЕ МЕСТО НИЖЕ
PubSubClient client(server, 1883, callback, ethClient);
////////////////////////////////////////////////////////////////////////////
void setup() {
//Serial.begin(57600);
// Serial.println("start");
//Объявляем порты Digital inputs/outputs
for (int i = 0 ; i <= n_DI_pin; i++) {
pinMode (start_DI_pin [i], INPUT);
}
digitalWrite(5, HIGH); //Окно
digitalWrite(4, HIGH); //Объемник
for (int i = 0 ; i <= n_DO_pin; i++) {
pinMode (start_DO_pin [i], OUTPUT);
}

Ethernet.begin(mac, ip);
if (client.connect(id_connect)) {
getSensors();
control();
// client.publish("myhome/Kitchen/Change_Counter", "0");
// client.publish("myhome/Kitchen/Temp_room", "0");
// client.publish("myhome/Kitchen/Humidity_room", "0");
// client.publish("myhome/Kitchen/Temp_radiator", "0");
// client.publish("myhome/Kitchen/Temp_in", "0");
// client.publish("myhome/Kitchen/Lux", "0");
// client.publish("myhome/Kitchen/Servo", "0");
// client.publish("myhome/Kitchen/MQ7", "0");

client.subscribe("myhome/Kitchen/#");
}
}
/////////////////////////////////////////////////////////////////////////
void loop() {
client.loop();
control();
getSensors();
if (!client.connected()) {
if (client.connect(id_connect)) {
control();
getSensors();
client.subscribe("myhome/Kitchen/#");
}
}
}

и отдельно Functions

/////////////////////////////////От Брокера//////////////////////////////////////////////
void callback_iobroker(String strTopic, String strPayload){
  if (strTopic == "myhome/Kitchen/Servo"){
        ServoAngle=strPayload.toInt();
    if (ServoAngle >= 0 && ServoAngle <= 255){
          servo.attach(ServoPin);
          //delay(200); //ждем 2 секунды
          servo.write(ServoAngle); //ставим вал под 0
          delay(1000); //ждем 2 секунды
          //client.publish("myhome/Kitchen/Servo", b); 
          servo.detach();
    }
  }
}

////////////////////////////////////Брокеру/////////////////////////////////////
void control(){
  
       if(digitalRead(5)==HIGH && flag==0) { //если окно открыто
          client.publish("myhome/Kitchen/Window", "1");
          flag=1; 
       } 
       if(digitalRead(5)==LOW && flag==1){//если окно закрыто  
        client.publish("myhome/Kitchen/Window", "0");       
        flag=0;//обнуляем переменную flag 
       }   
       
       if(digitalRead(4)==HIGH && flag2==0) { // Если есть движение
          client.publish("myhome/Kitchen/Motion", "1");
          flag2=1; 
       } 
       if(digitalRead(4)==LOW && flag2==1){// Если нет движения
        client.publish("myhome/Kitchen/Motion", "0");       
        flag2=0;//обнуляем переменную flag 
       }          
}
///////////////////////////////Данные сенсоров////////////////////////////////////

void getSensors () {

  MQ7Value = analogRead(MQ7_Pin); 
  fotoValue = analogRead(foto_Pin);  // считываем значение с фоторезистора
// ServoAngle = analogRead(2);

//Обработка данных датчика DHT22. Подключение к порту цифровому P9 Arduino
//Глобальные переменные Hout и Tout типа флоат - влажность (%) и температура (град. С)
  if (DHT.read22(DHT22_PIN)== DHTLIB_OK) {
    Hout = DHT.humidity;
    Tout = DHT.temperature;
  }
  if (Hout == 0 || Tout == 0){
    delay (1000);
    if (DHT.read22(DHT22_PIN)== DHTLIB_OK) {
    Hout = DHT.humidity;
    Tout = DHT.temperature;
  }
  }
  //Обработка данных цифровых датчиков температуры типа DS18B20.
  //Шина 1-Wire на цифровой пин P8 Arduino.
  //Подключено 2 датчика температуры, адреса задаются в секции глобальных констант "Sensors"
  //Три значение температуры T1, T2, типа float (град. С).
  DS_sensors.requestTemperatures();
  T1 = DS_sensors.getTempC(addr_T1);
  
///////////////////////Паблик данных сенсоров////////////////////////
 if (pause == 50 || pause == 0){ 
   
  char b[5]; 
    String char_Hout = String(Hout);
    char_Hout.toCharArray(b,5);
    client.publish("myhome/Kitchen/Humidity_room", b);
    
  String char_Tout = String(Tout);
  char_Tout.toCharArray(b,5);
  client.publish("myhome/Kitchen/Temp_room", b);
  
    String char_T1 = String(T1);
    char_T1.toCharArray(b,5);
    client.publish("myhome/Kitchen/Temp_radiator", b);
      
    String char_fotoValue = String(fotoValue);
    char_fotoValue.toCharArray(b,4);
    client.publish("myhome/Kitchen/Lux", b);
    
  String char_ServoAngle = String(ServoAngle);
  char_ServoAngle.toCharArray(b,4);
  client.publish("myhome/Kitchen/Servo", b);
  
    String char_MQ7Value = String(MQ7Value);
    char_MQ7Value.toCharArray(b,4);
    client.publish("myhome/Kitchen/MQ7", b);
  
    pause = 1;
 }
 else pause++;
}

а вот скетч целиком http://forum.iobroker.net/download/file.php?id=2951

Можете подсказать отчего у меня всё так получается.

Заранее всем спасибо за ответы жду ответов

I have an MQTT server (Mosquitto) running on a RPi3. I also have a sensor array on my bench that publishes readings to MQTT every 5 seconds. All of this is working great.

Tonight, I wired up an ESP8266-01 to an Arduino Mega using one of the Mega’s extra hardware serial ports (rx1, tx1). I’m using two libraries in my sketch: (1) WiFiEsp and (2) PubSubClient. I’ve tried both O’Leary’s PubSubClient and Imroy’s branch off O’Leary’s PubSubClient. I get the same result with each.

When I power up my Mega with it’s ESP8266 shield, it connects to WiFi and the MQTT broker fine. However, its not receiving any messages. It also drops the connection to the MQTT broker every minute or so. It immediately reconnects. The blue transmit LED on the ESP8266 is cycling extremely fast. Way too fast for the message traffic on my MQTT server.

I’m using proper level shifting between the devices. When I put a scope on the Mega’s rx1, I see a continuous trace of data that only stops upon disconnect.

In a similar post here, ankur posted just yesterday that there is a bug in the callback. I think he’s probably referring to the PubSubClient library. PubSubClient is a very popular library that a lot of people are using. Can anyone comment further on the nature of the bug that ankur alluded to? I’ll post my code below.

If anyone else runs into this issue, I also tested another variant of this configuration. I put my WiFi client code and my MQTT client code directly on the ESP8266’s micro and connected the ESP8266 to an Arduino Uno via SoftwareSerial at 19200 baud. The connection to my MQTT server is rock solid and all messages are coming through flawlessly.

My code on the Mega follows:

#include <WiFiEsp.h>
#include <PubSubClient.h>

const char *ssid = "********";
const char *pass = "********";
int status = WL_IDLE_STATUS;

#define BUFFER_SIZE 100

IPAddress server(10, 0, 1, 6);

// initialize WiFi client
WiFiEspClient espClient;

// connect to mqtt server
PubSubClient client(espClient);

void callback(const MQTT::Publish& pub) {
    if (pub.has_stream()) {
        uint8_t buf[BUFFER_SIZE];
        int read;
        while (read = pub.payload_stream()->read(buf, BUFFER_SIZE)) {
            Serial.write(buf, read);
        }
        pub.payload_stream()->stop();
        Serial.println("");
    } else
        Serial.println(pub.payload_string());
}

void setup() {
    
    pinMode(19, INPUT_PULLUP);  // pull rx1 high

    Serial.begin(9600);
    Serial1.begin(9600);

    WiFi.init(&Serial1);

    // check for the presence of the shield
    if (WiFi.status() == WL_NO_SHIELD) {
        Serial.println("WiFi shield not present");
        // don't continue
        while (true);
    }

    // attempt to connect to WiFi network
    while (status != WL_CONNECTED) {
        Serial.print("Attempting to connect to WPA SSID: ");
        Serial.println(ssid);
        // Connect to WPA/WPA2 network
        status = WiFi.begin(ssid, pass);
    }
    Serial.println("You're connected to the network");
}

void loop() {
    if (!client.connected()) {
        reconnect();
    }
    client.loop();
}

void reconnect() {
    if (!client.connected()) {
        client.set_server(server, 1883);
        client.connect("AVR101");
        client.subscribe("ishnalaIOT");
        client.set_callback(callback);
    }
}