martin-ger
commented
4 years ago Do you use lwip 1.4 or 2.0?
Am 4. Dezember 2019 00:31:35 schrieb philippesikora notifications@github.com:
The program defines a custom broker class with callbacks, I connect from a remote client and publish as below. After 6 iterations, I have the following message "Error: The connection was lost"MQTT client: root@MT300N-V2: mosquitto_pub -h 192.168.7.237 -p 1883 -t "MQTT_ref" -m "400" After 1st iteration, program works well root@MT300N-V2: mosquitto_pub -h 192.168.7.237 -p 1883 -t "MQTT_ref" -m "400" root@MT300N-V2: mosquitto_pub -h 192.168.7.237 -p 1883 -t "MQTT_ref" -m "400" root@MT300N-V2: mosquitto_pub -h 192.168.7.237 -p 1883 -t "MQTT_ref" -m "400" root@MT300N-V2: mosquitto_pub -h 192.168.7.237 -p 1883 -t "MQTT_ref" -m "400" root@MT300N-V2: mosquitto_pub -h 192.168.7.237 -p 1883 -t "MQTT_ref" -m "400" after 6 iteration, MQTT broker is down with the following message Error: The connection was lost.MQTT broker running on ESP8266:
include "uMQTTBroker.h"
include
include
int ref_index=0; char ssid[] = "your SSID"; // your network SSID (name) char password[] = "your password"; // your network passwordclass myMQTTBroker: public uMQTTBroker { public: virtual bool onConnect(IPAddress addr, uint16_t client_count) { Serial.println(addr.toString()+" connected"); return true; }virtual bool onAuth(String username, String password) { Serial.println("Username/Password: "+username+"/"+password); return true; } virtual void onData(String topic, const char *data, uint32_t length) { String temp; char data_str[length+1]; os_memcpy(data_str, data, length); data_str[length] = '\0'; Serial.println("received topic '"+topic+"' with data '"+(String)data_str+"'"); if (topic == "MQTT_ref") { temp = String(data_str); ref_index= temp.toInt(); Serial.println("MQTT OK"); } }
}; myMQTTBroker myBroker; void setup() { Serial.begin(9600); WiFi.begin ( ssid, password ); // Attente de la connexion au réseau WiFi / Wait for connection while ( WiFi.status() != WL_CONNECTED ) { delay ( 500 ); // Connexion WiFi établie / WiFi connexion is OK }Serial.println("Starting MQTT broker"); //// Start the broker myBroker.init();myBroker.subscribe("#"); //Subscribe to anything } void loop() { Serial.println("loop"); delay ( 3000 ); }— You are receiving this because you are subscribed to this thread. Reply to this email directly, view it on GitHub, or unsubscribe.
philippesikora
fostiras
3gyptian
The program defines a custom broker class with callbacks, I connect from a remote client and publish as below. After 6 iterations, I have the following message "Error: The connection was lost"
MQTT client: root@MT300N-V2: mosquitto_pub -h 192.168.7.237 -p 1883 -t "MQTT_ref" -m "400"
After 1st iteration, program works well root@MT300N-V2: mosquitto_pub -h 192.168.7.237 -p 1883 -t "MQTT_ref" -m "400" root@MT300N-V2: mosquitto_pub -h 192.168.7.237 -p 1883 -t "MQTT_ref" -m "400" root@MT300N-V2: mosquitto_pub -h 192.168.7.237 -p 1883 -t "MQTT_ref" -m "400" root@MT300N-V2: mosquitto_pub -h 192.168.7.237 -p 1883 -t "MQTT_ref" -m "400" root@MT300N-V2: mosquitto_pub -h 192.168.7.237 -p 1883 -t "MQTT_ref" -m "400" after 6 iteration, MQTT broker is down with the following message Error: The connection was lost.
MQTT broker running on ESP8266:
include "uMQTTBroker.h"
include
include
int ref_index=0; char ssid[] = "your SSID"; // your network SSID (name) char password[] = "your password"; // your network password
class myMQTTBroker: public uMQTTBroker { public: virtual bool onConnect(IPAddress addr, uint16_t client_count) { Serial.println(addr.toString()+" connected"); return true; }
};
myMQTTBroker myBroker;
void setup() { Serial.begin(9600); WiFi.begin ( ssid, password ); // Attente de la connexion au réseau WiFi / Wait for connection while ( WiFi.status() != WL_CONNECTED ) { delay ( 500 ); // Connexion WiFi établie / WiFi connexion is OK }
Serial.println("Starting MQTT broker"); //// Start the broker myBroker.init();
myBroker.subscribe("#"); //Subscribe to anything
}
void loop() { Serial.println("loop"); delay ( 3000 ); }