我有 2 个 esp8266 的问题,两者都通过 onewire 与 ds18b28 连接并使用 MQTT 发送数据。但是,如果我同时打开它们,只有其中一个传输数据,我单独测试它们没有问题,这是代码.两个 esp-s 使用相同的代码
#include <ESP8266WiFi.h>
#include <PubSubClient.h>
#include <OneWire.h>
#include <DallasTemperature.h>
#define ONE_WIRE_BUS 5
OneWire oneWire(ONE_WIRE_BUS);
DallasTemperature sensors(&oneWire);
const char* ssid = "PIREV-PC_NETWORK";
const char* password = "********";
const char* mqtt_server = "192.168.0.4";
WiFiClient espClient;
PubSubClient client(espClient);
long lastMsg = 0;
float temp = 0;
int inPin = 5;
void setup_wifi() {
delay(10);
Serial.println();
Serial.print("Connecting to ");
Serial.println(ssid);
WiFi.begin(ssid, password);
while (WiFi.status() != WL_CONNECTED)
{
delay(500);
Serial.print(".");
}
Serial.println("");
Serial.println("WiFi connected");
Serial.println("IP address: ");
Serial.println(WiFi.localIP());
}
void reconnect() {
while (!client.connected()) {
Serial.print("Attempting MQTT connection...");
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");
delay(5000);
}
}
}
void setup()
{
Serial.begin(115200);
setup_wifi();
client.setServer(mqtt_server, 1883);
pinMode(inPin, INPUT);
sensors.begin();
}
void loop()
{
if (!client.connected()) {
reconnect();
}
client.loop();
long now = millis();
if (now - lastMsg > 300) {
lastMsg = now;
sensors.setResolution(12);
sensors.requestTemperatures();
temp = sensors.getTempCByIndex(0);
Serial.println(temp);
if((temp > -20) && (temp <60))
{
client.publish("dev/test/temp2", String(temp).c_str(),TRUE);
}
}
}
每个客户端的客户端 ID 都需要不同。
在这种情况下,您似乎同时使用arduinoClient_temperature_sensor
了两个传感器,这将不起作用,因为当第二个传感器连接时,代理将始终断开第一个传感器的连接(反之亦然,当该传感器尝试重新连接时)
void reconnect() {
while (!client.connected()) {
Serial.print("Attempting MQTT connection...");
// The value passed to client.connect needs to be unique
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");
delay(5000);
}
}
}
本文收集自互联网,转载请注明来源。
如有侵权,请联系[email protected] 删除。
我来说两句