制作自己的wifi开关 ESP8266 lua使用mqqt远程通信

一 . 在本地电脑上安装emqtt服务器:


1.首先安装补丁:把补丁拷贝到" C:\Windows\System32 "文件夹下


2. 控制台模式下启动:emqttd console

(1) 控制台下切换到emqtt的bin目录下。如：

快速切换方法：在此目录下按住“Shift”同时点击鼠标右键选择“在此处打开                命令窗口”

(2)启动mqtt服务器 “emqttd console”

3. 通过网页登陆查看链接信息

网址：http://localhost:18083/

   用户名：admin

密码：public

查看本机ip：

链接上一个客户端

我们再启动一个客户端让两个客户端通信

我们在查看下链接的客户端

客户端通信

此种方法会打开一个窗口，关掉窗口emqtt服务也关闭；

让emqtt服务器一直运行的

（1）控制台先定位到emqtt的bin目录下“D:\MqttServer\emqttd\bin”

    （2）emqttd install

（3）启动emqttd服务：emqttd start

（4）停止emqttd服务：emqttd stop

（5）卸载emqttd服务：emqttd uninstall

二. ESP8266 模块连接emqtt服务器进行远程控制

init.lua文件:

1. RELAY_Pin = 1
   
2. 
   
3. gpio.mode(RELAY_Pin, gpio.OUTPUT)
   
4. 
   
5. gpio.write(RELAY_Pin,0)
   
6. 
   
7. tmr.alarm(0,4000,0,function()
   
8. 
   
9.     dofile("mqtt.lua")
   
10. 
    
11. end)

复制代码

init.lua文件结束

mqtt.lua文件:

1. MqttServerIP="192.168.0.105"      
   
2. 
   
3. MqttServerPort=1883         
   
4. 
   
5. MqttUserName="admin"              
   
6. 
   
7. MqttUserPassword="public"      
   
8. 
   
9. MqttLinkStat = 0                  
   
10. 
    
11. UartReceData = ""               
    
12. 
    
13. UartReceCnt = 0                  
    
14. 
    
15. UartReceTempCnt = 0              
    
16. 
    
17. wifi.setmode(wifi.STATION)      
    
18. 
    
19. local stacfg={
    
20. 
    
21.     ssid="qqqqq",      
    
22. 
    
23.     pwd="11223344"  
    
24. 
    
25. }
    
26. 
    
27. wifi.sta.config(stacfg)        
    
28. 
    
29. wifi.sta.autoconnect(1)         
    
30. 
    
31. Clientid = wifi.sta.getmac()     
    
32. 
    
33. ClientSubscribeTopic = "AAA"   
    
34. 
    
35. ClientPublishTopic = "111"      
    
36. 
    
37. MqttClient=mqtt.Client(Clientid,3,MqttUserName,MqttUserPassword)
    
38. 
    
39. MqttClient:lwt(ClientPublishTopic,"offline",1,1)  
    
40. 
    
41. local function ConnectSuccess(client)  
    
42. 
    
43.     print("MqttServer connect sucess")
    
44. 
    
45.     client:subscribe(ClientSubscribeTopic,0,function(client)print("subscribe sucess")end)
    
46. 
    
47.     MqttLinkStat = 1
    
48. 
    
49.     tmr.stop(3)
    
50. 
    
51. end
    
52. 
    
53. local function ConnectFailed(client, reason)
    
54. 
    
55.     print("MqttServer connect fail"..reason)
    
56. 
    
57.     MqttLinkStat = 0
    
58. 
    
59.     tmr.start(3)
    
60. 
    
61.    
    
62. 
    
63. end
    
64. 
    
65. tmr.alarm(3, 2000, 1, function()
    
66. 
    
67.          MqttClient:connect(MqttServerIP, MqttServerPort, 0,ConnectSuccess,ConnectFailed)
    
68. 
    
69. end)
    
70. 
    
71. MqttClient:on("offline", function(client, topic, data) tmr.start(3) end)
    
72. 
    
73. MqttClient:on("message", function(client, topic, data)
    
74. 
    
75.         if data == "open" then
    
76. 
    
77.             gpio.write(RELAY_Pin,1)  
    
78. 
    
79.             if gpio.read(RELAY_Pin)==1 then
    
80. 
    
81.                 if MqttClient ~= nil then
    
82. 
    
83.                     MqttClient:publish(ClientPublishTopic,"ON-RELAY",1,1,function(client)  end)
    
84. 
    
85.                 end
    
86. 
    
87.             end  
    
88. 
    
89.         end
    
90. 
    
91.         if data == "close" then
    
92. 
    
93.             gpio.write(RELAY_Pin,0)
    
94. 
    
95.             if gpio.read(RELAY_Pin)==0 then
    
96. 
    
97.                 if MqttClient ~= nil then
    
98. 
    
99.                     MqttClient:publish(ClientPublishTopic,"OFF-RELAY",1,1,function(client)  end)
    
100. 
     
101.                 end
     
102. 
     
103.             end
     
104. 
     
105.         End
     
106. 
     
107. uart.write(0,data)
     
108. 
     
109. end)
     
110. 
     
111. tmr.alarm(2,10,1,function()
     
112. 
     
113.      if UartReceCnt ~= 0 then
     
114. 
     
115.         if UartReceTempCnt == UartReceCnt then
     
116. 
     
117.             UartReceTempCnt = 0
     
118. 
     
119.             UartReceCnt = 0  
     
120. 
     
121.             --send to-Mqtt
     
122. 
     
123.             if MqttClient ~= nil then
     
124. 
     
125.                 MqttClient:publish(ClientPublishTopic,UartReceData,1,1,function(client)  end)
     
126. 
     
127.             end
     
128. 
     
129.         else
     
130. 
     
131.             UartReceTempCnt = UartReceCnt
     
132. 
     
133.         end
     
134. 
     
135.      end
     
136. 
     
137. end)
     
138. 
     
139. uart.on("data",0,function(data)
     
140. 
     
141.             UartReceData = UartReceData..data
     
142. 
     
143.             UartReceCnt = UartReceCnt + 1   
     
144. 
     
145. end,0)   
     
146. 
     
147. printip = 0
     
148. 
     
149. wifi.eventmon.register(wifi.eventmon.STA_DISCONNECTED, function(T)
     
150. 
     
151.     printip = 0
     
152. 
     
153. end)
     
154. 
     
155. wifi.eventmon.register(wifi.eventmon.STA_GOT_IP, function(T)
     
156. 
     
157.    if printip == 0 then
     
158. 
     
159.       print("+IP "..T.IP)
     
160. 
     
161.    end
     
162. 
     
163.    printip = 1
     
164. 
     
165. end)
     
166. 
     

复制代码

mqtt.lua文件结束

模块通过串口发送数据

PC客户端发送”open”开继电器

PC客户端发送”close”关继电器

mqtt客户端.zip (118.4 KB, 下载次数: 34)

2018-11-7 11:52 上传

点击文件名下载附件
PC端mqtt测试软件                                                          
ESP8266 连接mqtt远程控制 lua源码.zip (700 Bytes, 下载次数: 30)

2018-11-7 12:52 上传

点击文件名下载附件
源码

emqtt安装包：https://pan.baidu.com/s/1EyPovGzNPAePmx4JT5urew提取码：za3g
交流QQ:1813763867   QQ群:607064330



ESP8266 制作自己的wifi开关资料汇总:
链接：https://pan.baidu.com/s/1wtIwd5csjieme7O-PfGhbA
提取码：71kt
连接失效请联系本人及时更改

谢谢发布，很详细!

好东西，谢谢楼主