MQTT and Wifi handling for ESP8266

This library is intended to encapsulate the handling of WiFi and MQTT connections of an ESP8266. You just need to provide your credentials and it will manage the following things:

• Connecting to a WiFi network.
• Connecting to a MQTT broker.
• Automatically detecting connection lost either from the WiFi client or the MQTT broker and it will retry a connection automatically.
• Subscrubing/unsubscrubing to/from MQTT topics by a friendly callback system.
• Provide a callback handling to advise once everything is connected (Wifi and MQTT).
• Provide a function to enable an HTTP Update server secured by a password to allow remote update.
• Provide a function to enable printing of usefull debug informations related to MQTT and Wifi connections.
• Provide some other useful utilities for MQTT and Wifi management.

Dependency

The MQTT communication depends on the PubSubClient Library (https://github.com/knolleary/pubsubclient).

From PubSubClient: "The maximum message size, including header, is 128 bytes by default. This is configurable via MQTT_MAX_PACKET_SIZE in PubSubClient.h"

Documentation

Construction

  EspMQTTClient(
    const char* wifiSsid,
    const char* wifiPassword,
    const char* mqttServerIp,
    const char* mqttUsername,  // Omit this parameter to disable MQTT authentification
    const char* mqttPassword,  // Omit this parameter to disable MQTT authentification
    const char* mqttClientName = "ESP8266",
    const short mqttServerPort = 1883);

Functions

IMPORTANT : Must be called at each loop() of your sketch

void loop();

Basic functions for MQTT communications.

void publish(const String &topic, const String &payload, bool retain = false);
void subscribe(const String &topic, MessageReceivedCallback messageReceivedCallback);
void unsubscribe(const String &topic);

Enable the display of usefull debugging messages that will output to serial.

void enableDebuggingMessages(const bool enabled = true)

Enable the web updater. This will host a simple form that will allow firmware upgrade. Must be set before the first loop() call.

void enableHTTPWebUpdater(const char* username, const char* password, const char* address = "/");

// this one will set user and password equal to thoses set for the MQTT connection.
void enableHTTPWebUpdater(const char* address = "/");

Enable last will message. Must be set before the first loop() call.

void enableLastWillMessage(const char* topic, const char* message, const bool retain = false);

Return true if everything is connected.

bool isConnected() 

As ESP8366 does not like to be interrupted too long with the delay() function, this function will allow a delayed execution of a function without interrupting the sketch.

void executeDelayed(const long delay, DelayedExecutionCallback callback);

Connection established callback

To allow this library to work, you need to implement the onConnectionEstablished() function in your sketch.

void onConnectionEstablished()
{
  // Here you are sure that everything is connected.
}

Example

#include "EspMQTTClient.h"

EspMQTTClient client(
  "WifiSSID",
  "WifiPassword",
  "192.168.1.100",  // MQTT Broker server ip
  "MQTTUsername",   // Can be omitted if not needed
  "MQTTPassword",   // Can be omitted if not needed
  "TestClient"      // Client name that uniquely identify your device
);

void setup() {}

void onConnectionEstablished() {

  client.subscribe("mytopic/test", [] (const String &payload)  {
    Serial.println(payload);
  });

  client.publish("mytopic/test", "This is a message");
}

void loop() {
  client.loop();
}

See "Esp8266MQTTClient.ino" for the complete exemple.