2017-03-08 186 views
0

我不是一个编码器,所以我问你们,如果你知道我怎么能解决我的问题。 在arduino中,我用DS18B20传感器编写了第一个程序,该程序通过MQTT网络程序在openHAB中显示温度。 第二个程序是同样的东西(openhab,mqtt)只是开关灯,这意味着当我按下开关时,灯或LED通过Arduino中的回调函数打开或关闭。 另外这两个程序工作得很好,但是当我试图将它们连接在一起时,它不起作用,因为我想。在我看来,问题在于循环功能。当我按下开关ON或OFF时,有时(很少)我可以打开或关闭指示灯。所以我的问题是...什么是错的?循环是否有问题,因为arduino不能同时在循环中处理两件事情?它可以解决,我真的不知道下一步该怎么做。请帮助我,并提前致谢!arduino循环不能使用两个进程

#include <OneWire.h> 
#include <DallasTemperature.h> 
#include <SPI.h> 
#include <PubSubClient.h> 
#include "WiFiEsp.h" 

// Emulate Serial1 on pins 3/2 if not present 
#ifndef HAVE_HWSERIAL1 
#include "SoftwareSerial.h" 
SoftwareSerial Serial1(3, 2); // RX, TX 
#endif 

char ssid[] = "SSID;  // your network SSID (name) 
char pwd[] = "password"; // your network password 

float temp = 0; 

byte server[] = { 192, 168, 1, 71 }; // IP Address of your MQTT Server 
WiFiEspClient espClient; 
PubSubClient client(espClient); 


#define ONE_WIRE_BUS 4 
// Setup a oneWire instance to communicate with any OneWire devices (not just Maxim/Dallas temperature ICs) 
OneWire oneWire(ONE_WIRE_BUS); 
// Pass our oneWire reference to Dallas Temperature. 
DallasTemperature sensors(&oneWire); 



void callback(char* topic, byte* payload, unsigned int length) { 
Serial.println("Callback"); 

Serial.println(topic); 
Serial.println(length); 
Serial.write(payload,length); 
Serial.println(); 

if (strcmp(topic,"home/luc")==0) { 
    if (payload[0] == '0') 
    { 
    digitalWrite(7, LOW); 
    delay(100); 
    client.publish("home/luc/state","OFF"); 
    } 
    else if (payload[0] == '1') 
    { 

    digitalWrite(7, HIGH); 
    delay(100); 
    client.publish("home/luc/state","ON"); 
    } 

} 
} 



void temperaturni_senzor() 
{ 
    sensors.requestTemperatures(); 
    temp = sensors.getTempCByIndex(0); 
    Serial.print("Temperatura je: "); 
    Serial.println(temp); // Why "byIndex"? You can have more than one IC on the same bus. 0 refers to the first IC on the wire 
    //Update value every 1 sec. 


    client.publish("home/temperature", String(temp).c_str(),TRUE); 
    delay(50); 
    } 
void reconnect() { 
// Loop until we're reconnected 
while (!client.connected()) { 
Serial.print("connecting to mqtt..."); 
// Attempt to connect 
if (client.connect("ESP8266 client")) { 
    Serial.println("connection good"); 
    // ... and subscribe to topic 
    client.subscribe("home/luc"); 
} 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() 
{ 
    Serial1.begin(9600); 
    Serial.begin(9600); //Begin serial communication 
    WiFi.init(&Serial1); 
    WiFi.begin(ssid, pwd); 
    client.setServer(server, 1883); 
    client.setCallback(callback); 

if (client.connect("arduinoClient")) 
    { 
    Serial.println ("mqqt is connected"); 
    client.publish("outTopic","hsubscribello world"); 
     client.subscribe("home/luc"); // Subscribe to all messages for this device 
     client.subscribe("home/temperature"); 
     } 
    pinMode(7, OUTPUT); 
    digitalWrite(7, LOW); 
    sensors.begin(); 

} 

void loop() 
{ 
client.loop(); 

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

    temperaturni_senzor(); 

    } 

} 
+0

编辑的问题,包括你的代码,所以我们不必猜测 – hardillb

+0

有没有** **过程中的Arduino。 *你的意思是“arduino不能在同一时间在循环中处理两件事情”*? Arduino按照您指定的顺序依次执行每个事件**。 –

回答

0

您是否有串口输出示例?

此外,为了您的reconnect()功能,我认为串口应该是您的ESP8266输出的Serial1,因为您在设置中使用了WiFi.init(& Serial1)。

在循环中,你有

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

它循环,看看客户端连接,如果不是那么它会尝试重新连接。重新连接时会尝试连接,如果不能连接,则每次无法连接时会等待5秒。这可能是你的问题。

你有两个分开的程序的代码?

+0

tnx回答奥马尔,但正如我测试重新连接没有任何影响。问题是无论我在循环函数中写入“client.loop();”在呈现中,它停止工作。那么,当client.loop在那里时,我可能没有任何其他的东西了? –

0

这是DS18B20的代码和它的作品

#include <OneWire.h> 
    #include <DallasTemperature.h> 
    #include <SPI.h> 
    #include <PubSubClient.h> 
    #include "WiFiEsp.h" 
    #ifndef HAVE_HWSERIAL1 
    #include "SoftwareSerial.h" 
    SoftwareSerial Serial1(3, 2); // RX, TX 
    #endif 


    byte server[] = { 192, 168, 1, 71 }; // IP Address of your MQTT Server 



    WiFiEspClient espClient; 
    PubSubClient client(espClient); 


    float temp = 0; 
    char ssid[] = "SSID";  // your network SSID (name) 
    char pwd[] = "password"; // your network password 




    #define ONE_WIRE_BUS 4 
    // Setup a oneWire instance to communicate with any OneWire devices (not just Maxim/Dallas temperature ICs) 
    OneWire oneWire(ONE_WIRE_BUS); 
    // Pass our oneWire reference to Dallas Temperature. 
    DallasTemperature sensors(&oneWire); 


    void reconnect() { 
     // Loop until we're reconnected 
     while (!client.connected()) { 
     Serial.print("Attempting MQTT connection..."); 
     // Attempt to connect 
     if (client.connect("arduinoClient_temperature_sensor")) { 
      Serial.println("connected"); 
     } 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() 
    { 
    Serial1.begin(9600); 
    Serial.begin(9600); //Begin serial communication 
    WiFi.init(&Serial1); 
    WiFi.begin(ssid, pwd); 
    client.setServer(server, 1883); 
    sensors.begin(); 
    } 

    void temp_senz() 
    { 
    sensors.requestTemperatures(); 
     temp = sensors.getTempCByIndex(0); 
     Serial.print("Temperatura je: "); 
     Serial.println(temp); 
     client.publish("home/temperature", String(temp).c_str(),TRUE); 
     delay(1000); 
    } 
    void loop() 
    { 
     { 
     if (!client.connected()) { 
     reconnect(); 
     } 
     client.loop(); 
    temp_senz(); 

     } 
    } 

这是灯,它也工作。

#include <OneWire.h> 
#include <DallasTemperature.h> 
#include <SPI.h> 
#include <PubSubClient.h> 
#include "WiFiEsp.h" 

// Emulate Serial1 on pins 7/6 if not present 
#ifndef HAVE_HWSERIAL1 
#include "SoftwareSerial.h" 
SoftwareSerial Serial1(3, 2); // RX, TX 
#endif 

char ssid[] = "SSID";  // your network SSID (name) 
char pwd[] = "password"; // your network password 


byte server[] = { 192, 168, 1, 71 }; // IP Address of your MQTT Server 



WiFiEspClient espClient; 
PubSubClient client(espClient); 


void callback(char* topic, byte* payload, unsigned int length) { 
Serial.println("Callback"); 

Serial.println(topic); 
Serial.println(length); 
Serial.write(payload,length); 
Serial.println(); 

if (strcmp(topic,"home/luc")==0) { 
    if (payload[0] == '0') 
    { 
    digitalWrite(7, LOW); 
    delay(100); 
    client.publish("home/luc/state","OFF"); 
    } 
    else if (payload[0] == '1') 
    { 

    digitalWrite(7, HIGH); 
    delay(100); 
    client.publish("home/luc/state","ON"); 
    } 

} 
} 


void setup() 
{ 
    Serial1.begin(9600); 
    Serial.begin(9600); //Begin serial communication 
    WiFi.init(&Serial1); 
    WiFi.begin(ssid, pwd); 
    client.setServer(server, 1883); 
    client.setCallback(callback); 

if (client.connect("arduinoClient")) 
    { 
    Serial.println ("mqqt je konektan"); 
    client.publish("outTopic","hsubscribello world"); 
     client.subscribe("home/luc"); // Subscribe to all messages for this device 
     } 

    pinMode(7, OUTPUT); 
    digitalWrite(7, LOW); 

} 



void loop() { 

client.loop(); 

} 

Picture of serial monitor for both examples joined together