d5430228e5
Added echo on|off for later vt100 terminal Added rnd(min,max) function Simplied every function Better parsing for getword (accept strings) Fix for blink command
105 lines
3.1 KiB
C++
105 lines
3.1 KiB
C++
#include <TinyMqtt.h> // https://github.com/hsaturn/TinyMqtt
|
|
|
|
/**
|
|
* Local broker that accept connections and two local clients
|
|
*
|
|
*
|
|
* +-----------------------------+
|
|
* | ESP |
|
|
* | +--------+ | 1883 <--- External client/s
|
|
* | +-------->| broker | | 1883 <--- External client/s
|
|
* | | +--------+ |
|
|
* | | ^ |
|
|
* | | | |
|
|
* | | | | -----
|
|
* | v v | ---
|
|
* | +----------+ +----------+ | -
|
|
* | | internal | | internal | +-------* Wifi
|
|
* | | client | | client | |
|
|
* | +----------+ +----------+ |
|
|
* | |
|
|
* +-----------------------------+
|
|
*
|
|
* pros - Reduces internal latency (when publish is received by the same ESP)
|
|
* - Reduces wifi traffic
|
|
* - No need to have an external broker
|
|
* - can still report to a 'main' broker (TODO see documentation that have to be written)
|
|
* - accepts external clients
|
|
*
|
|
* cons - Takes more memory
|
|
* - a bit hard to understand
|
|
*
|
|
*/
|
|
|
|
const char *ssid = "";
|
|
const char *password = "";
|
|
|
|
std::string topic="sensor/temperature";
|
|
|
|
MqttBroker broker(1883);
|
|
|
|
MqttClient mqtt_a(&broker);
|
|
MqttClient mqtt_b(&broker);
|
|
|
|
void onPublishA(const MqttClient* /* source */, const Topic& topic, const char* payload, size_t /* length */)
|
|
{ Serial << "--> client A received " << topic.c_str() << ", " << payload << endl; }
|
|
|
|
void onPublishB(const MqttClient* /* source */, const Topic& topic, const char* payload, size_t /* length */)
|
|
{ Serial << "--> client B Received " << topic.c_str() << ", " << payload << endl; }
|
|
|
|
void setup()
|
|
{
|
|
Serial.begin(115200);
|
|
delay(500);
|
|
Serial << "Clients with wifi " << endl;
|
|
|
|
if (strlen(ssid)==0)
|
|
Serial << "****** PLEASE EDIT THE EXAMPLE AND MODIFY ssid/password *************" << endl;
|
|
|
|
WiFi.mode(WIFI_STA);
|
|
WiFi.begin(ssid, password);
|
|
|
|
while (WiFi.status() != WL_CONNECTED) { Serial << '-'; delay(500); }
|
|
|
|
Serial << "Connected to " << ssid << "IP address: " << WiFi.localIP() << endl;
|
|
|
|
broker.begin();
|
|
|
|
mqtt_a.setCallback(onPublishA);
|
|
mqtt_a.subscribe(topic);
|
|
|
|
mqtt_b.setCallback(onPublishB);
|
|
mqtt_b.subscribe(topic);
|
|
}
|
|
|
|
void loop()
|
|
{
|
|
broker.loop(); // Don't forget to add loop for every broker and clients
|
|
|
|
mqtt_a.loop();
|
|
mqtt_b.loop();
|
|
|
|
// ============= client A publish ================
|
|
static const int intervalA = 5000; // publishes every 5s (please avoid usage of delay())
|
|
static uint32_t timerA = millis() + intervalA;
|
|
|
|
if (millis() > timerA)
|
|
{
|
|
Serial << "A is publishing " << topic.c_str() << endl;
|
|
timerA += intervalA;
|
|
mqtt_a.publish(topic, " sent by A");
|
|
}
|
|
|
|
// ============= client B publish ================
|
|
static const int intervalB = 7000; // will send topic each 7s
|
|
static uint32_t timerB = millis() + intervalB;
|
|
|
|
if (millis() > timerB)
|
|
{
|
|
static int temperature;
|
|
Serial << "B is publishing " << topic.c_str() << endl;
|
|
timerB += intervalB;
|
|
mqtt_b.publish(topic, " sent by B: "+std::string(String(16+temperature++%6).c_str()));
|
|
}
|
|
}
|