Aclaración: trabajo MQTT con microPython, por lo que no tengo mayor experiencia con C++. Tengo algunos controladores corriendo que envían mensajes mqtt cada minuto y también reciben ordenes por el mismo medio. Eso funciona 100% por meses.
Trate de trabajar con el código, pero tienes entremezclado el MQTT con accesos a un servidor HTTP y ya se me hizo difícil tratar de modificarlo para poder probar solo el MQTT. Te recomiendo refactorizar para que el MQTT y HTTP sean independientes entre si.
Observo, pero no puedo comprabar que sea la causa del error que nunca haces un mqtt.connect()
, lo que debes corregir.
Tome el ejemplo que viene con PubSubClient (mqtt basic), lo arregle para mi red y funciona más o menos. Tienes problemas, pero logra conectarse, enviar y recibir. Me suena a algún problema con la librería, ya que mientras tanto, mi MQTT sigue procesando los mensajes de mis otros controladores.
Este es el ejemplo, arreglado para usar Wifi
/*
Basic MQTT example
This sketch demonstrates the basic capabilities of the library.
It connects to an MQTT server then:
- publishes "hello world" to the topic "outTopic"
- subscribes to the topic "inTopic", printing out any messages
it receives. NB - it assumes the received payloads are strings not binary
It will reconnect to the server if the connection is lost using a blocking
reconnect function. See the 'mqtt_reconnect_nonblocking' example for how to
achieve the same result without blocking the main loop.
*/
#include <WiFi.h>
#include <PubSubClient.h>
// Update these with values suitable for your network.
#define WiFi_SSID "ChaosManor"
#define WiFi_PASS "belalugosi"
IPAddress server(192, 168, 0, 1);
void callback(char* topic, byte* payload, unsigned int length) {
Serial.print("Message arrived [");
Serial.print(topic);
Serial.print("] ");
for (int i=0;i<length;i++) {
Serial.print((char)payload[i]);
}
Serial.println();
}
WiFiClient wifiClient;
PubSubClient client(wifiClient);
void reconnect() {
// Loop until we're reconnected
while (!client.connected()) {
Serial.print("Attempting MQTT connection...");
// Attempt to connect
if (client.connect("arduinoClient")) {
Serial.println("connected");
// Once connected, publish an announcement...
client.publish("outTopic","hello world");
// ... and resubscribe
client.subscribe("inTopic");
} else {
Serial.print("failed, rc=");
Serial.print(client.state());
Serial.println(" try again in 5 seconds");
// Wait 5 seconds before retrying
delay(15000);
}
}
}
void setupWifi() {
delay(10);
// Nos conectamos al wifi
Serial.println("WiFi Setup");
Serial.print("Conectando a SSID: ");
Serial.print(WiFi_SSID);
WiFi.begin(WiFi_SSID, WiFi_PASS);
while (WiFi.status() != WL_CONNECTED)
{
Serial.print(".");
delay(500);
}
Serial.println("");
Serial.println("Conectado a red WiFI!!!");
Serial.print("Direccion Ip: ");
Serial.println(WiFi.localIP());
}
void setup()
{
Serial.begin(115200);
setupWifi();
client.setServer(server, 1883);
client.setCallback(callback);
// Allow the hardware to sort itself out
delay(1500);
}
void loop()
{
if (!client.connected()) {
reconnect();
}
client.loop();
}
Produce
17:42:08.536 -> WiFi Setup
17:42:08.536 -> Conectando a SSID: ChaosManor.
17:42:09.115 -> Conectado a red WiFI!!!
17:51:27.663 -> Direccion Ip: 192.168.0.197
17:51:29.139 -> Attempting MQTT connection...failed, rc=-2 try again in 5 seconds
17:51:47.149 -> Attempting MQTT connection...failed, rc=-2 try again in 5 seconds
17:52:05.165 -> Attempting MQTT connection...failed, rc=-2 try again in 5 seconds
17:52:23.154 -> Attempting MQTT connection...failed, rc=-2 try again in 5 seconds
17:52:41.175 -> Attempting MQTT connection...connected
17:53:46.668 -> Attempting MQTT connection...failed, rc=-2 try again in 5 seconds
17:53:54.669 -> Attempting MQTT connection...failed, rc=-2 try again in 5 seconds
17:54:02.675 -> Attempting MQTT connection...failed, rc=-2 try again in 5 seconds
17:54:10.677 -> Attempting MQTT connection...failed, rc=-2 try again in 5 seconds
17:54:18.679 -> Attempting MQTT connection...connected
17:54:23.306 -> Message arrived [inTopic] Candid Moe
17:54:38.447 -> Message arrived [inTopic] Candid Moe 2
17:54:52.938 -> Message arrived [inTopic] Candid Moe 3
17:54:52.938 -> Message arrived [inTopic] Candid Moe 3
Como vez, envia mensajes y también los recibe, con un montón de desconexiones entre medio.