This repository has been archived by the owner on Jan 31, 2024. It is now read-only.
-
Notifications
You must be signed in to change notification settings - Fork 6
/
MQTTClient_Basic.ino
189 lines (147 loc) · 4.76 KB
/
MQTTClient_Basic.ino
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
/****************************************************************************************************************************
MQTTClient_Basic.ino - Dead simple AsyncWebServer for Teensy41 QNEthernet
For Teensy41 with QNEthernet
AsyncWebServer_Teensy41 is a library for the Teensy41 with QNEthernet
Based on and modified from ESPAsyncWebServer (https://github.com/me-no-dev/ESPAsyncWebServer)
Built by Khoi Hoang https://github.com/khoih-prog/AsyncWebServer_Teensy41
Licensed under GPLv3 license
*****************************************************************************************************************************/
/*
Basic MQTT example (without SSL!) with Authentication
This sketch demonstrates the basic capabilities of the library.
It connects to an MQTT server then:
- providing username and password
- publishes "hello world" to the topic "outTopic"
- subscribes to the topic "inTopic", printing out any messages
it receives. NB - it assumes the received payloads are strings not binary
It will reconnect to the server if the connection is lost using a blocking
reconnect function. See the 'mqtt_reconnect_nonblocking' example for how to
achieve the same result without blocking the main loop.
*/
// To remove boolean warnings caused by PubSubClient library
#define boolean bool
#include "defines.h"
#include <PubSubClient.h>
// Update these with values suitable for your network.
const char* mqttServer = "broker.emqx.io"; // Broker address
const char *ID = "MQTTClient_SSL-Client"; // Name of our device, must be unique
const char *TOPIC = "MQTT_Pub"; // Topic to subcribe to
const char *subTopic = "MQTT_Sub"; // Topic to subcribe to
//IPAddress mqttServer(172, 16, 0, 2);
void callback(char* topic, byte* payload, unsigned int length)
{
Serial.print("Message arrived [");
Serial.print(topic);
Serial.print("] ");
for (unsigned int i = 0; i < length; i++)
{
Serial.print((char)payload[i]);
}
Serial.println();
}
EthernetClient ethClient;
PubSubClient client(mqttServer, 1883, callback, ethClient);
String data = "Hello from MQTTClient_Basic on " + String(BOARD_NAME) + " with " + String(SHIELD_TYPE);
const char *pubData = data.c_str();
void reconnect()
{
// Loop until we're reconnected
while (!client.connected())
{
Serial.print("Attempting MQTT connection to ");
Serial.print(mqttServer);
// Attempt to connect
if (client.connect(ID, "try", "try"))
{
Serial.println("...connected");
// Once connected, publish an announcement...
client.publish(TOPIC, data.c_str());
//Serial.println("Published connection message successfully!");
//Serial.print("Subcribed to: ");
//Serial.println(subTopic);
client.subscribe(subTopic);
// for loopback testing
client.subscribe(TOPIC);
}
else
{
Serial.print("...failed, rc=");
Serial.print(client.state());
Serial.println(" try again in 5 seconds");
// Wait 5 seconds before retrying
delay(5000);
}
}
}
void setup()
{
// Open serial communications and wait for port to open:
Serial.begin(115200);
while (!Serial && millis() < 5000);
Serial.print("\nStart MQTTClient_Basic on ");
Serial.print(BOARD_NAME);
Serial.print(" with ");
Serial.println(SHIELD_TYPE);
Serial.println(ASYNC_WEBSERVER_TEENSY41_VERSION);
delay(500);
#if USING_DHCP
// Start the Ethernet connection, using DHCP
Serial.print("Initialize Ethernet using DHCP => ");
Ethernet.begin();
#else
// Start the Ethernet connection, using static IP
Serial.print("Initialize Ethernet using static IP => ");
Ethernet.begin(myIP, myNetmask, myGW);
Ethernet.setDNSServerIP(mydnsServer);
#endif
if (!Ethernet.waitForLocalIP(5000))
{
Serial.println(F("Failed to configure Ethernet"));
if (!Ethernet.linkStatus())
{
Serial.println(F("Ethernet cable is not connected."));
}
// Stay here forever
while (true)
{
delay(1);
}
}
else
{
Serial.print(F("Connected! IP address:"));
Serial.println(Ethernet.localIP());
}
#if USING_DHCP
delay(1000);
#else
delay(2000);
#endif
client.setServer(mqttServer, 1883);
client.setCallback(callback);
// Allow the hardware to sort itself out
delay(1500);
}
#define MQTT_PUBLISH_INTERVAL_MS 5000L
unsigned long lastMsg = 0;
void loop()
{
static unsigned long now;
if (!client.connected())
{
reconnect();
}
// Sending Data
now = millis();
if (now - lastMsg > MQTT_PUBLISH_INTERVAL_MS)
{
lastMsg = now;
if (!client.publish(TOPIC, pubData))
{
Serial.println("Message failed to send.");
}
Serial.print("Message Send : " + String(TOPIC) + " => ");
Serial.println(data);
}
client.loop();
}