Blinken mit MQTT in arduino

Question

Ich muss ein Prototyping-Szenario implementieren, die LED im Arduino mit MQTT-Protokoll blinken. Ich habe es bereits mit mehreren MQTT-Bibliotheken versucht, aber keine von ihnen funktioniert nicht perfekt. Verbindung zum MQTT-Broker funktioniert erfolgreich, aber wenn ich die Nachricht mit Thema veröffentlichen, die ich in Arduino festlegen, nicht blinken die LED. Arduno haben eine Nachricht zu veröffentlichen, wenn sie dieses Verlags Teil erfolgreich verbinden, aber auch nicht funktioniert

dies mein Code

#include <SPI.h> 
#include <Ethernet.h> 
#include <PubSubClient.h> 

// Set the MAC address 
byte mac[] = { 0xDE, 0xED, 0xBA, 0xFE, 0xFE, 0xED }; 
IPAddress ip(192, 168, 1, 100); 
IPAddress server(192, 168, 1, 20); 

// Set what PINs our Led's are connected to 
int redPin = 13;     
//int greenPin = 6; 
//int bluePin = 7; 

// Set a generic code that will trigger our Blue Led 
// think of this as a set of codes for automation you might write 
byte triggerRed[13] = "12345"; 

// handles messages that are returned from the broker on our subscribed channel 
void callback(char* topic, byte* payload, unsigned int length) { 

    Serial.print("New message from broker on topic:"); 
    Serial.println(topic); 

    Serial.print("Payload:"); 
    Serial.write(payload, length); 



    // Check and see if our payload matches our simple trigger test 
    if ((length == 5) & (memcmp(payload, triggerRed, 5) == 0)) 
    { 
    //blink(redPin); 

    } 

} 
EthernetClient ethClient; 
PubSubClient client(ethClient); 
// Fire up our PubSub client 
//PubSubClient client(server, 1883, callback); 

void setup() 
{ 

    // Open serial communications 
    Serial.begin(9600); 

    client.setServer(server, 1883); 
    client.setCallback(callback); 

    // Setup our Leds 
    pinMode(redPin, OUTPUT); 
// pinMode(greenPin, OUTPUT); 
// pinMode(bluePin, OUTPUT); 

    // attempt a DHCP connection 
    Serial.println("Attempting to get an IP address using DHCP:"); 
    if (!Ethernet.begin(mac)) 
    { 
    // if DHCP fails, start with a hard-coded address: 
    Serial.println("failed to get an IP address using DHCP, trying manually"); 
    Ethernet.begin(mac, ip); 
    } 

    Serial.print("My address:"); 
    Serial.println(Ethernet.localIP()); 

    // Connect to Broker, give it arduino as the name 
    if (client.connect("arduino")) { 

    // Good, we connected turn on the red led 
    digitalWrite(redPin, HIGH); 

    // Publish a message to the status topic 
    client.publish("status","Arduino is now online"); 

    // Listen for messages on the control topic 
    client.subscribe("ultra"); 
    } 

} 

void loop() 
{ 
    client.loop(); 
} 

// Anything with flashing lights. 
void blink(int targetLed) 
{ 
    digitalWrite(redPin, HIGH); 

} 

wie kann ich dieses Problem beheben?

Answer 1

Setzen Sie die Verbindungsroutine in eine Schleife und versuchen Sie es zuerst mit test.mosquitto.org. Hier ist Code, der für mich (Ethernet Schild Hardware) funktioniert:

Definitionen:

#define CLIENT_NAME "myclientname" 
#define TOPIC "mytopic" 
byte mac[] = { 0xDE, 0xED, 0xBA, 0xFE, 0xFE, 0xED }; 
IPAddress ip(192, 168, 1, 105); 
IPAddress server(85, 119, 83, 194);// test.mosquitto.org 
#define MQTT_PORT 1883 
IPAddress myDns(8, 8, 8, 8); 
EthernetClient ethClient; 
PubSubClient client(ethClient); 

Setup:

client.setServer(server, MQTT_PORT); 
client.setCallback(callback); 
Ethernet.begin(mac); 

Schleife:

if (!client.connected()) { 
      reconnect(); 
     } 
client.loop(); 

wieder Routine

void reconnect() { 
    if (millis() - reconnectionTimer >reconnection_period){// Loop until we're reconnected 
     reconnectionTimer = millis(); 
     if (!client.connected()) { 
      // Attempt to connect 
      if (client.connect(CLIENT_NAME)) { 
       client.subscribe(TOPIC); 
      } 
      else { 
       Serial.print(client.state()); 
       Serial3.print(client.state()); 
      } 
     } 
    } 
} 

---

Update für blink:

void blink(){ 
    digitalWrite(led, LOW); 
    delay(500); 
    digitalWrite(led, HIGH); 
}