摘要：mqtt客户端可以有很多种，本文介绍一种使用arduino d1（esp8266）制作的客户端，连接emqx服务器的方法。

 首先需要配置开发环境，配置方法可以参考文章

(1条消息) 使用arduino开发esp8266和esp32时首选项设置方法（附国内开发板管理网址）_TMS320VC5257H的博客-CSDN博客_esp32开发板管理器网址https://blog.csdn.net/youngwah292/article/details/125820767?ops_request_misc=%257B%2522request%255Fid%2522%253A%2522166926413816782425673674%2522%252C%2522scm%2522%253A%252220140713.130102334.pc%255Fblog.%2522%257D&request_id=166926413816782425673674&biz_id=0&utm_medium=distribute.pc_search_result.none-task-blog-2~blog~first_rank_ecpm_v1~rank_v31_ecpm-3-125820767-null-null.nonecase&utm_term=arduino&spm=1018.2226.3001.4450本文介绍的是使用d1模块连接本地的MQTT服务器，假如需要了解如何连接阿里云物联网平台，可以参考文章

(1条消息) 从arduino板开始做到阿里云app控制--WeMos D1或ESP8266连接阿里云文章合集及源代码_TMS320VC5257H的博客-CSDN博客https://blog.csdn.net/youngwah292/article/details/105855714?ops_request_misc=%257B%2522request%255Fid%2522%253A%2522166926413816782425673674%2522%252C%2522scm%2522%253A%252220140713.130102334.pc%255Fblog.%2522%257D&request_id=166926413816782425673674&biz_id=0&utm_medium=distribute.pc_search_result.none-task-blog-2~blog~first_rank_ecpm_v1~rank_v31_ecpm-15-105855714-null-null.nonecase&utm_term=arduino&spm=1018.2226.3001.4450

源代码如下：编译之前请确定板级支持包和mqtt库是否正确加载。下面这个源代码经过测试是没问题的，如果遇到编译不通过的问题，请仔细查找环境配置方面的问题。

#include 
#include const char* ssid = "TP-LINK_XXXX";//在此输入WIFI的名称
const char* password = "XXXXXXXXX";//在此输入WIFI的密码
const char* mqtt_server = "192.168.1.3";//这个是MQTT服务器的IP地址，以实际为准WiFiClient espClient;
PubSubClient client(espClient);
unsigned long lastMsg = 0;
#define MSG_BUFFER_SIZE	(50)
char msg[MSG_BUFFER_SIZE];
int value = 0;void setup_wifi() {delay(10);Serial.println();Serial.print("Connecting to ");Serial.println(ssid);WiFi.mode(WIFI_STA);WiFi.begin(ssid, password);while (WiFi.status() != WL_CONNECTED) {delay(500);Serial.print(".");}randomSeed(micros());Serial.println("");Serial.println("WiFi connected");Serial.println("IP address: ");Serial.println(WiFi.localIP());
}void callback(char* topic, byte* payload, unsigned int length) {Serial.print("Message arrived [");Serial.print(topic);Serial.print("] ");for (int i = 0; i < length; i++) {Serial.print((char)payload[i]);}Serial.println();// 如果订阅的主题，第一个字符是1，那么就拉低LED引脚，此时LED就点亮了，具体以实际电路为准，也可能拉高才是点亮if ((char)payload[0] == '1') {digitalWrite(BUILTIN_LED, LOW);   } else {digitalWrite(BUILTIN_LED, HIGH);  }}void reconnect() {while (!client.connected()) {Serial.print("Attempting MQTT connection...");// 创建一个随机数后缀的客户端名字String clientId = "ESP8266Client-";clientId += String(random(0xffff), HEX);// if (client.connect(clientId.c_str())) {Serial.println("connected");// 一旦连接上了，就发布一个主题，这个主题是自定义的，您可以在自己的MQTT服务器进行查看client.publish("testtopic/2", "hello world");// subscribe是订阅的意思，MQTT通信的核心就是“订阅+发布”client.subscribe("testtopic/#");} else {Serial.print("failed, rc=");Serial.print(client.state());Serial.println(" try again in 5 seconds");delay(5000);}}
}void setup() {pinMode(BUILTIN_LED, OUTPUT);   Serial.begin(115200);setup_wifi();client.setServer(mqtt_server, 1883);//端口号是1883，这个不用动，一般都是它client.setCallback(callback);
}void loop() {if (!client.connected()) {reconnect();}client.loop();unsigned long now = millis();if (now - lastMsg > 2000) {lastMsg = now;value = random(1,50);//生成一个随机数snprintf (msg, MSG_BUFFER_SIZE, "%ld", value);//将随机数转变成为字符串Serial.print("Publish message: ");Serial.println(msg);client.publish("testtopic/2", msg);//发布这个随机数}
}

烧录成功后，使用arduino自带的串口终端观察数据可以看到数据。

 登录EMQX服务器，查看当前连接的客户端列表，当出现下图红框所示的客户端ID时，就证明已经成功连接。当PC端的服务器连接到路由器的有线部分，而D1连接的是无线，二者尽管不在同一个网段（大多数家用的路由器都是这样的），但是他们仍然可以互相访问。所以可以看到连接成功了。

 然后登录websocket客户端，连接服务器，并订阅testtopic/#主题，就可以实时看到D1发送的数据了。