80 lines
2.3 KiB
Arduino
80 lines
2.3 KiB
Arduino
|
/*
|
||
|
|
* Publishes "Hello" at regular intervals. The message can be subscribed and observed in HiveMQs
|
||
|
|
* Websockets client http://www.hivemq.com/demos/websocket-client/
|
||
|
|
*
|
||
|
|
* If the libraries Arduino Low Power and RTC Zero are included then Cooperative Multitasking
|
||
|
|
* uses LowPower.idle(...) instead of delay(...).
|
||
|
|
*
|
||
|
|
* Copyright (C) 2018 Andreas Motzek andreas-motzek@t-online.de
|
||
|
|
*
|
||
|
|
* You can use, redistribute and/or modify this file under the terms of the Modified Artistic License.
|
||
|
|
* See http://simplysomethings.de/open+source/modified+artistic+license.html for details.
|
||
|
|
*
|
||
|
|
* This file is distributed in the hope that it will be useful, but without any warranty; without even
|
||
|
|
* the implied warranty of merchantability or fitness for a particular purpose.
|
||
|
|
*/
|
||
|
|
|
||
|
|
#include <Client.h>
|
||
|
|
#include <WiFi101.h>
|
||
|
|
#include <ArduinoLowPower.h>
|
||
|
|
#include <CooperativeMultitasking.h>
|
||
|
|
#include <MQTTClient.h>
|
||
|
|
|
||
|
|
char ssid[] = "...";
|
||
|
|
char pass[] = "...";
|
||
|
|
char host[] = "broker.hivemq.com";
|
||
|
|
char clientid[] = " ";
|
||
|
|
char topicname[] = "amotzek/hello";
|
||
|
|
|
||
|
|
CooperativeMultitasking tasks;
|
||
|
|
WiFiClient wificlient;
|
||
|
|
MQTTClient mqttclient(&tasks, &wificlient, host, 1883, clientid, NULL, NULL);
|
||
|
|
MQTTTopic topic(&mqttclient, topicname);
|
||
|
|
|
||
|
|
void setup() {
|
||
|
|
Serial.begin(9600);
|
||
|
|
//
|
||
|
|
while (!Serial) {
|
||
|
|
delay(1000);
|
||
|
|
}
|
||
|
|
//
|
||
|
|
WiFi.begin(ssid, pass);
|
||
|
|
tasks.after(10000, checkWiFi); // after 10 seconds call checkWiFi()
|
||
|
|
tasks.after(10000, checkBroker); // after 10 seconds call checkBroker()
|
||
|
|
tasks.after(30000, publishHello); // after 30 seconds call publishHello()
|
||
|
|
}
|
||
|
|
|
||
|
|
void loop() {
|
||
|
|
tasks.run();
|
||
|
|
}
|
||
|
|
|
||
|
|
void checkWiFi() {
|
||
|
|
switch (WiFi.status()) {
|
||
|
|
case WL_CONNECT_FAILED:
|
||
|
|
case WL_CONNECTION_LOST:
|
||
|
|
case WL_DISCONNECTED:
|
||
|
|
Serial.println("wifi not connected");
|
||
|
|
WiFi.begin(ssid, pass);
|
||
|
|
tasks.after(10000, checkWiFi); // after 10 seconds call checkWiFi()
|
||
|
|
//
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
//
|
||
|
|
tasks.after(30000, checkWiFi); // after 30 seconds call checkWiFi()
|
||
|
|
}
|
||
|
|
|
||
|
|
void checkBroker() {
|
||
|
|
if (!mqttclient.connected()) {
|
||
|
|
Serial.println("mqtt client not connected");
|
||
|
|
mqttclient.connect();
|
||
|
|
}
|
||
|
|
//
|
||
|
|
tasks.after(30000, checkBroker); // after 30 seconds call checkBroker()
|
||
|
|
}
|
||
|
|
|
||
|
|
void publishHello() {
|
||
|
|
if (mqttclient.connected()) topic.publish("Hello");
|
||
|
|
//
|
||
|
|
tasks.after(30000, publishHello); // after 30 seconds call publishHello()
|
||
|
|
}
|