arduino环境下eps32通过wifi发送数据给mqtt服务

要在Arduino环境中使用ESP32通过WiFi发送数据给MQTT服务，你可以使用ESP32内置的WiFi功能和`PubSubClient`库来实现。以下是一个示例代码：

首先，确保你已经安装了 `PubSubClient`库。在Arduino IDE中，选择 "工具" -> "管理库"，然后搜索并安装 "PubSubClient" 库。

然后，使用以下示例代码：

#include <WiFi.h>
#include <PubSubClient.h>

const char* ssid = "your_wifi_ssid";
const char* password = "your_wifi_password";
const char* mqtt_server = "mqtt_server_ip";
const int mqtt_port = 1883;
const char* mqtt_username = "your_mqtt_username";
const char* mqtt_password = "your_mqtt_password";
const char* mqtt_topic = "your_mqtt_topic";

WiFiClient espClient;
PubSubClient client(espClient);

void setup() {
  Serial.begin(115200);

  WiFi.begin(ssid, password);
  while (WiFi.status() != WL_CONNECTED) {
    delay(1000);
    Serial.println("Connecting to WiFi...");
  }

  Serial.println("Connected to WiFi");

  client.setServer(mqtt_server, mqtt_port);
  client.setCallback(callback);

  while (!client.connected()) {
    if (client.connect("ESP32Client", mqtt_username, mqtt_password)) {
      Serial.println("Connected to MQTT Broker");
      client.subscribe(mqtt_topic);
    } else {
      Serial.print("Failed to connect to MQTT Broker, rc=");
      Serial.print(client.state());
      Serial.println(" Retrying in 5 seconds...");
      delay(5000);
    }
  }
}

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

  // Publish data to MQTT topic
  String message = "Hello, MQTT!";
  client.publish(mqtt_topic, message.c_str());
  delay(5000);
}

void callback(char* topic, byte* payload, unsigned int length) {
  // Handle received MQTT message
  Serial.print("Received message on topic: ");
  Serial.println(topic);
  Serial.print("Message: ");
  for (int i = 0; i < length; i++) {
    Serial.print((char)payload[i]);
  }
  Serial.println();
}

void reconnect() {
  while (!client.connected()) {
    Serial.println("Attempting MQTT connection...");
    if (client.connect("ESP32Client", mqtt_username, mqtt_password)) {
      Serial.println("Connected to MQTT Broker");
      client.subscribe(mqtt_topic);
    } else {
      Serial.print("Failed to connect to MQTT Broker, rc=");
      Serial.print(client.state());
      Serial.println(" Retrying in 5 seconds...");
      delay(5000);
    }
  }
}

在此代码中，我们使用了`WiFi`库连接到WiFi网络，使用`PubSubClient`库连接到MQTT服务。

在`setup()`函数中，我们连接到WiFi网络，并设置MQTT服务器的地址、端口、用户名和密码。然后，通过调用`client.setServer()`和`client.setCallback()`来配置MQTT客户端。

在 `loop()`函数中，我们检查MQTT连接状态，并在断开连接时重新连接。然后，我们通过调用 `client.publish()`发布数据到MQTT主题。

在 `callback()`函数中，我们处理接收到的MQTT消息。当有消息到达时，该函数将被调用。

最后，通过调用 `client.loop()` 在 `loop()` 函数中处理MQTT客户端的消息。

请记得替换示例代码中的 WiFi SSID、密码、MQTT服务器地址、端口、用户名、密码和主题，以适应你的实际情况。

运行代码后，ESP32将连接到WiFi网络并发送数据到MQTT服务。同时，它还会订阅相应的MQTT主题，并在收到消息时进行处理。请确保你的设备能够连接到正确的WiFi网络和MQTT服务，并具有正确的权限和配置。