Websockets support

[PeeJay]

There is another library based on this one (https://github.com/hideakitai/MQTTPubSubClient) that has websockets support, but I prefer using this library so I have ported over the websockets part.

https://github.com/PeeJay/arduino-mqtt/tree/websockets

At the moment I have used the same #define WEBSOCKETS approach to enable it, but I'm sure there is a better way if I thought about it like some sort of abstract class. If this is something you are interested in I can keep working on it.

[Samtropic]

Hi, I'm just trying to find an arduino library managing mqtt over websockets as my broker is set like that.

I already tried the hideakitai lib and yours but I can't connect to the broker on port 443. I'm stuck in the loop attempting connection client.connect() and an my debug reveals that this error is thrown : LWMQTT_MISSING_OR_WRONG_PACKET

I'm using M5stack core2. Could you provide a working example with one of the library you mentioned ?

[PeeJay]

Is it definitely websockets, and not just MQTT over SSL?. This is for an ESP32

#include <Arduino.h>

#include <WiFi.h>
#include <WiFiMulti.h>
#include <WebSocketsClient.h>
#include <MQTT.h>

WebSocketsClient client;
MQTTClient mqtt;
WiFiMulti wiFiMulti;

void connect()
{
    if (wiFiMulti.run() != WL_CONNECTED)
    {
        while (wiFiMulti.run() != WL_CONNECTED)
        {
            delay(500);
            Serial.print(".");
        }

        Serial.print("IP address: ");
        Serial.println(WiFi.localIP());
    }

    // connect to host with MQTT over WebSocket securely
    Serial.print("Connecting to mqtt server as ");
    String devId = "Arduino-" + String(ESP.getEfuseMac() >> 32, HEX);
    Serial.println(devId);
    client.beginSSL("server.com", 443, "/", "", "mqtt");
    while (!client.isConnected())
    {
        client.loop();
        delay(10);
    }

    // initialize mqtt client
    mqtt.connect(devId.c_str(), "username", "password");

    if (mqtt.connected())
    {
        Serial.println("Connected.");
    }
    else
    {
        Serial.println("Fail - retrying in 1 seconds]");
        delay(1000);
    }
}

void setup()
{
    Serial.begin(115200);

    wiFiMulti.addAP("wifiuser", "wifipass");
    mqtt.begin(client);
    connect();
}

void loop()
{
    static unsigned long lastMeasure = 0;
    static unsigned long measureTime = 1000 * 60;

    if ((millis() - lastMeasure) > measureTime)
    {
        lastMeasure = millis();

        // Check WiFi connection status
        if (WiFi.status() != WL_CONNECTED || !mqtt.connected())
        {
            Serial.println("Reconnecting...");
            connect();
        }

        // Send data on last sample
        mqtt.publish("hello/world", "data goes here");
    }

    mqtt.loop();
    delay(10);
}

Which gives the output

rst:0x1 (POWERON_RESET),boot:0x13 (SPI_FAST_FLASH_BOOT)
configsip: 0, SPIWP:0xee
clk_drv:0x00,q_drv:0x00,d_drv:0x00,cs0_drv:0x00,hd_drv:0x00,wp_drv:0x00
mode:DIO, clock div:2
load:0x3fff0030,len:1184
load:0x40078000,len:13192
load:0x40080400,len:3028
entry 0x400805e4
Connecting to mqtt server as Arduino-3cab
Fail - retrying in 1 seconds]
Reconnecting...
Connecting to mqtt server as Arduino-3cab
Connected.

I've noticed that both libraries don't always connect on the first go, occasionally it takes a few retries. I'm not sure why.

[Samtropic]

Thank you very much, I finally managed to connect to my broker but using hideakitai library.

With yours, along with the example you provided, I wasn't able to compile because when invoking mqtt.begin(client) the code behind is waiting for a Client instance and not a WebSocketsClient 's one.

though i'm not sure about my headers management. Anyway you helped me a lot with your example ! And yes me too, the connection is failing at least once before establishing.