terrorsl / smqttbroker Goto Github PK

View Code? Open in Web Editor NEW

57.0 57.0 17.0 379 KB

Simple MQTT broker

License: MIT License

C++ 100.00%

arduino arduino-library esp32 esp8266 mqtt

smqttbroker's Introduction

Hi there 👋

smqttbroker's People

Contributors

Stargazers

Watchers

Forkers

antoniomoruno luocj slametgithub yangwc laszlotar sosandstrom cepr alessiosavelli linh-boo cyb3rcod3 andreteixeira1998 gabrielfast chrda81 muttaqui chenjou pbrunot lustiq

smqttbroker's Issues

Send Message from Broker

Is there a way to send a message from broker to the clients or a special client? if not can you implement such solution?
As far as i see there is not client as such in the library to can do it?

onPublish doesn't seem to work

Hi @terrorsl!
Faced some problem in the "advancebroker" example. I added one line to each of the event handlers:

class MyBroker: public sMQTTBroker
{
  public:
    bool onConnect (sMQTTClient * client, const std :: string & username, const std :: string & password)
    {
      // check username and password, if ok return true
      Serial.println ("Somebody connected");
      return true;
    };
    void onRemove (sMQTTClient *)
    {
      Serial.println ("Somebody disconnected");
    };
    void onPublish (const std :: string & topic, const std :: string & payload)
    {
      // client publish a message to the topic
      // you can parse the message, save it to a database, or whatever, based on your goals
      Serial.println ("Somebody posted");
    }
};

I tried to write something to topics using mqtt-explorer, everything is fine, but the output contains 2 of 3 added lines:

05: 39: 40.848 -> RAM: 270876
05: 39: 41.048 -> Somebody connected
05: 39: 41.845 -> RAM: 268700
05: 40: 17.880 -> RAM: 267124
05: 40: 18.876 -> RAM: 268700
05: 40: 33.172 -> Somebody disconnected
05: 40: 33.903 -> RAM: 271060

i try to compile it but get follow errors:
In file included from .pio\libdeps\m5stack-atom\sMQTTBroker\src/sMQTTBroker.h:5:0, from .pio\libdeps\m5stack-atom\sMQTTBroker\src\sMQTTClient.cpp:1: .pio\libdeps\m5stack-atom\sMQTTBroker\src/sMQTTClient.h: In constructor 'sMQTTClient::sMQTTClient(sMQTTBroker*, WiFiClient*)': .pio\libdeps\m5stack-atom\sMQTTBroker\src/sMQTTClient.h:44:15: error: 'sMQTTClient::_parent' will be initialized after [-Werror=reorder] sMQTTBroker *_parent; ^ .pio\libdeps\m5stack-atom\sMQTTBroker\src/sMQTTClient.h:39:7: error: 'bool sMQTTClient::mqtt_connected' [-Werror=reorder] bool mqtt_connected; ^ .pio\libdeps\m5stack-atom\sMQTTBroker\src\sMQTTClient.cpp:3:1: error: when initialized here [-Werror=reorder] sMQTTClient::sMQTTClient(sMQTTBroker *parent, TCPClient *client):_parent(parent), mqtt_connected(false) Compiling .pio\build\m5stack-atom\FrameworkArduino\MD5Builder.cpp.o ^ .pio\libdeps\m5stack-atom\sMQTTBroker\src\sMQTTClient.cpp: In member function 'void sMQTTClient::processMessage()': .pio\libdeps\m5stack-atom\sMQTTBroker\src\sMQTTClient.cpp:192:19: warning: unused variable 'msg_id' [-Wunused-variable] Compiling .pio\build\m5stack-atom\FrameworkArduino\Print.cpp.o unsigned short msg_id = (header[0] << 8) | header[1]; ^ .pio\libdeps\m5stack-atom\sMQTTBroker\src\sMQTTClient.cpp:236:19: warning: unused variable 'qos' [-Wunused-variable] unsigned char qos = *payload++; ^ .pio\libdeps\m5stack-atom\sMQTTBroker\src\sMQTTClient.cpp:223:19: warning: unused variable 'msg_id' [-Wunused-variable] unsigned short msg_id = (header[0] << 8) | header[1]; ^ .pio\libdeps\m5stack-atom\sMQTTBroker\src\sMQTTClient.cpp:45:9: warning: enumeration value 'Unknown' not handled in switch [-Wswitch] switch (message.type()) ^ .pio\libdeps\m5stack-atom\sMQTTBroker\src\sMQTTClient.cpp:45:9: warning: enumeration value 'ConnAck' not handled in switch [-Wswitch] .pio\libdeps\m5stack-atom\sMQTTBroker\src\sMQTTClient.cpp:45:9: warning: enumeration value 'PubAck' not handled in switch [-Wswitch] .pio\libdeps\m5stack-atom\sMQTTBroker\src\sMQTTClient.cpp:45:9: warning: enumeration value 'PubRec' not handled in switch [-Wswitch] .pio\libdeps\m5stack-atom\sMQTTBroker\src\sMQTTClient.cpp:45:9: warning: enumeration value 'PubComp' not handled in switch [-Wswitch] .pio\libdeps\m5stack-atom\sMQTTBroker\src\sMQTTClient.cpp:45:9: warning: enumeration value 'SubAck' not handled in switch [-Wswitch] .pio\libdeps\m5stack-atom\sMQTTBroker\src\sMQTTClient.cpp:45:9: warning: enumeration value 'UnSuback' not handled in switch [-Wswitch] .pio\libdeps\m5stack-atom\sMQTTBroker\src\sMQTTClient.cpp:45:9: warning: enumeration value 'PingResp' not handled in switch [-Wswitch] In file included from .pio\libdeps\m5stack-atom\sMQTTBroker\src/sMQTTClient.h:4:0, from .pio\libdeps\m5stack-atom\sMQTTBroker\src/sMQTTBroker.h:5, from .pio\libdeps\m5stack-atom\sMQTTBroker\src\sMQTTClient.cpp:1: .pio\libdeps\m5stack-atom\sMQTTBroker\src/sMQTTMessage.h:67:32: warning: 'packeteIdent[1]' may be used uninitialized in this function [-Wmaybe-uninitialized] void add(char byte) { incoming(byte); } ^ .pio\libdeps\m5stack-atom\sMQTTBroker\src\sMQTTClient.cpp:139:9: note: 'packeteIdent[1]' was declared here char packeteIdent[2]; ^ In file included from .pio\libdeps\m5stack-atom\sMQTTBroker\src/sMQTTClient.h:4:0, from .pio\libdeps\m5stack-atom\sMQTTBroker\src/sMQTTBroker.h:5, from .pio\libdeps\m5stack-atom\sMQTTBroker\src\sMQTTClient.cpp:1: .pio\libdeps\m5stack-atom\sMQTTBroker\src/sMQTTMessage.h:67:32: warning: 'packeteIdent[0]' may be used uninitialized in this function [-Wmaybe-uninitialized] void add(char byte) { incoming(byte); } ^ .pio\libdeps\m5stack-atom\sMQTTBroker\src\sMQTTClient.cpp:139:9: note: 'packeteIdent[0]' was declared here char packeteIdent[2]; ^ In file included from .pio\libdeps\m5stack-atom\sMQTTBroker\src/sMQTTBroker.h:4:0, from .pio\libdeps\m5stack-atom\sMQTTBroker\src\sMQTTClient.cpp:1: .pio\libdeps\m5stack-atom\sMQTTBroker\src/sMQTTplatform.h: At global scope: .pio\libdeps\m5stack-atom\sMQTTBroker\src/sMQTTplatform.h:34:20: warning: 'SMQTTTAG' defined but not used [-Wunused-variable] static const char *SMQTTTAG = "sMQTTBroker"; ^ In file included from .pio\libdeps\m5stack-atom\sMQTTBroker\src/sMQTTClient.h:4:0, from .pio\libdeps\m5stack-atom\sMQTTBroker\src/sMQTTBroker.h:5, from .pio\libdeps\m5stack-atom\sMQTTBroker\src\sMQTTClient.cpp:1: .pio\libdeps\m5stack-atom\sMQTTBroker\src/sMQTTMessage.h:14:20: warning: 'debugMessageType' defined but not used [-Wunused-variable] static const char *debugMessageType[] = { ^ cc1plus.exe: some warnings being treated as errors *** [.pio\build\m5stack-atom\lib737\sMQTTBroker\sMQTTClient.cpp.o] Error 1

Can not compile in Arduino IDE

Hi,
This Broker looks nice, but i am getting error on while compiling on Arduino.

error: 'class WiFiServer' has no member named 'end'
_server->end();
^
exit status 1
Error compiling for board Generic ESP8266 Module.
Any help is appreciable.
thanks

SSL Connection

Please make SSL connection possible for the broker

Broker address

Hi,
This is just a question not an issue.
Is it possible to use something like mqtt.mybroker.io instead of IP address 192.168.4.1
thanks

Broker continues to send messages to the unsubscribed client

Broker continues to send messages to the unsubscribed client and some times exception and reboot happend.

That is my code for esp32 board:

`#include"sMQTTBroker.h"

sMQTTBroker broker;
unsigned long timing;

void setup()
{
Serial.begin(115200);
const char* ssid = "My WiFi"; // The SSID (name) of the Wi-Fi network you want to connect to
const char* password = "12345678"; // The password of the Wi-Fi network
WiFi.begin(ssid, password);
while (WiFi.status() != WL_CONNECTED) { // Wait for the Wi-Fi to connect
delay(1000);
}
Serial.println("Connection established!");
Serial.print("IP address:\t");
Serial.println(WiFi.localIP());

const unsigned short mqttPort=1883;
broker.init(mqttPort);
// all done

}
void loop()
{
if (millis() - timing > 5000){
timing = millis();
broker.publish("broker/pressure", String(760).c_str() );
broker.publish("broker/temperature", String(25).c_str() );
broker.publish("broker/humidity", String(40).c_str() );
broker.publish("broker/time", (String(12) + ":0" + String(0)).c_str() );
}
broker.update();
//delay(1000);
}`

and this is LOG message:

Connection established!

IP address: 192.168.8.112

[D][sMQTTBroker.cpp:27] update(): New Client

[D][sMQTTClient.cpp:50] processMessage(): message type:Connect(0x10)

[D][sMQTTClient.cpp:84] processMessage(): message clientId:android

[D][sMQTTClient.cpp:85] processMessage(): message keepTime:30

[D][sMQTTClient.cpp:104] processMessage(): message user:admin

[D][sMQTTClient.cpp:113] processMessage(): message password:pass