热门标签
热门文章
- 1（二）docker-compose使用——1 安装与命令介绍_docker-compose up -d未找到命令
- 2WDS+MDT网络部署操作系统
- 3添加多个yum源并自动选择最快的源_多个yum源哪个生效
- 4vscode 安装golang 插件 因为网络问题失败解决方案:_go安装器您的网络出现问题,请检查后重试
- 5ABP VNext学习日记8_abp fullauditedaggregateroot
- 6国产操作系统_银河麒麟桌面版和服务器版区别
- 7安装Linux系统时，需要哪些分区?_linux请先选择根分区
- 8搜索和数据库查询到底有什么区别
- 9python二级公共基础知识_python计算机二级公共基础知识
- 10TensorFlow + GPU配置_tensorflow gpu
当前位置: article > 正文
物联网esp32、micropython、mosquitto、websocket、nginx、html、js、python实现wifi外网点灯（非局域网）阿里云服务器,保姆级教程——猪猪侠方丈_wifi websocket
作者：小丑西瓜9 | 2024-03-04 20:31:04
赞
踩
wifi websocket
物联网esp32、micropython、mosquitto、websocket、nginx、html、js、python实现wifi外网点灯（非局域网）阿里云服务器,保姆级教程
1、esp32的micropython连接wifi及mosquitto服务器
猪不喜欢多说废话（除非是母猪），上代码
import time #点灯模块 from machine import Pin #网络连接模块 WiFi模块 import network import esp esp.osdebug(None) #连接mosquitto模块，这个要在esp32板子中安装，命令两条 #命令1：import upip #命令2：upip.install('micropython-umqtt.simple') from lib.umqtt.simple2 import MQTTClient #垃圾回收 import gc gc.collect() #连接wifi ssid=你的wifi名称 password=你的wifi密码 要修改 ssid = '?????????' password = '********' #wlan网络模式 station = network.WLAN(network.STA_IF) station.active(True) #连接wifi station.connect(ssid, password) while station.isconnected() == False: pass #连接成功后打印成功及板子连接的IP信息 print('Connection successful') print(station.ifconfig()) #定义板载led led = Pin(22, Pin.OUT) #收到消息后执行的函数 def sub_cb(topic, msg, retain, dup): print((topic, msg, retain, dup)) #收到消息后将bytes转为str 此处decode的参数模式和python不一样，注意容易出错 rsmsg =str(msg.decode('UTF-8','strict')) #修改灯的状态 value值 0 开 1 关 if rsmsg=='开': print('准备打开led灯') led.value(0) print('灯已开') elif rsmsg=='关': print('准备关闭led灯') led.value(1) print('灯已关') else: print('消息无效无操作') #连接mosquitto的函数 def main(server="localhost", blocking_method=False): #MQTTClient 第一个参数，你以名：zhutou连接mosquitto，麻烦自己修改名 #MQTTClient 第二个参数，阿里云服务器的IP：13.14.52.02 麻烦自己修改IP #另外记得阿里云安全组打开mosquitto1883默认端口 ，8080和9001 websocket端口，不然你连不上 c = MQTTClient("zhutou", '13.14.52.02') c.set_callback(sub_cb) c.connect() #订阅消息b"paho/test/single" c.subscribe(b"paho/test/single") #保持一直等着收订阅的消息 while True: if blocking_method: # Blocking wait for message c.wait_msg() else: # Non-blocking wait for message c.check_msg() # Then need to sleep to avoid 100% CPU usage (in a real # app other useful actions would be performed instead) time.sleep(1) c.disconnect() #调用连接函数main main() #下面这句话是废话我测试时候用的 print(cs.px)
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
- 23
- 24
- 25
- 26
- 27
- 28
- 29
- 30
- 31
- 32
- 33
- 34
- 35
- 36
- 37
- 38
- 39
- 40
- 41
- 42
- 43
- 44
- 45
- 46
- 47
- 48
- 49
- 50
- 51
- 52
- 53
- 54
- 55
- 56
- 57
- 58
- 59
- 60
- 61
- 62
- 63
- 64
- 65
- 66
- 67
- 68
- 69
- 70
- 71
- 72
- 73
- 74
- 75
- 76
- 77
- 78
2、网页端代码html+js
下不到paho-mqtt.js再找我
<!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <title>pxLED</title> <!--paho-mqtt.js文件不好下，有时候网站打不开找我过墙好找一些github上有https://github.com/eclipse/paho.mqtt.javascript/blob/master/src/paho-mqtt.js这个网站下的不行的话M我--> <script src="./2021-8-16/paho-mqtt.js" type="text/javascript"></script> <!--<script type = "text/javascript" src = "./jquery-3.2.1min.js"></script>--> </head> <body> <button onclick="changeio()">改变开关状态</button> </body> <script> var io ='开'; //连接mosquitto xxxxxxx为你的服务器ip yyyyyy为端口 此处建议开mosquitto.conf中开8080 9001 websocket 阿里云安全组也开放此2个端口 以及默认的1883端口。还有个坑有些paho-mqtt.js不是不能用，是要改成clientmsq= new Paho.Client('xxxxxxx',yyyyyy,"/mqtt",'webclient-px');和 var sendmsg = new Paho.Message(io); clientmsq= new Paho.MQTT.Client('xxxxxxx',yyyyyy,"/mqtt",'webclient-px'); //心跳包10秒，按需求修改 clientmsq.connect({keepAliveInterval:10}); //按钮改变等状态功能 function changeio() { if (io =='关'){ io='开' }else if(io=='开'){ io='关' } //请把连接代码放在外面，或者先执行连接延时一段时间后再发送消息，不让速度太快，还没连上你就发消息了，会报错。 // clientmsq= new Paho.MQTT.Client('39.106.39.98',8080,"/mqtt",'webclient-px'); // clientmsq.connect({ // invocationContext: { // host: '13.14.52.02',//IP地址 // port: 8080,//端口号 // // path: client.path, // clientId: 'webclient-px'//标识 // }}); // clientmsq.subscribe('paho/test/single'); // console.log(clientmsq.send); //发送消息代码io为具体消息 var sendmsg = new Paho.MQTT.Message(io); //发送的订阅频道'paho/test/single'自己修改 保证和你的板子订阅频道一致就好了 sendmsg.destinationName = 'paho/test/single'; sendmsg.retained = true ; // clientmsq.send(topic='paho/test/single',payload=io,0,true); //发送 clientmsq.send(sendmsg); // clientmsq.disconnect(); } </script> </html>
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
- 23
- 24
- 25
- 26
- 27
- 28
- 29
- 30
- 31
- 32
- 33
- 34
- 35
- 36
- 37
- 38
- 39
- 40
- 41
- 42
- 43
- 44
- 45
- 46
- 47
- 48
- 49
- 50
- 51
3、mosquitto主持人（broker）在centos 7上安装配置
安装这一步太久了有点忘了
我好像直接yum install mosquitto
具体你们还是自己探索吧
启动：
1.默认启动（好像是只开了1883端口）进入主持人模式窗口、可以看见谁连进来了订阅了什么、谁出去了、地址什么的，ctrl+c退出并关闭mosquitto、想让他在后台运行你就把shell窗口关了，另开一个窗口，服务器本地连也是再开shell窗口。
mosquitto -v
2.按指定配置启动(一般路径是这个：/etc/mosquitto/mosquitto.conf)这个.conf 文件默认里面是没有内容的都是注释、开启端口模式见下面。
mosquitto -c /etc/mosquitto/mosquitto.conf -v
2.1mosquitto.conf开启端口（以下开启两个端口8080、9001并且都是websockets协议，每一个都要加，不然默认mqtt协议，你前端就连不上）
listener 8080
protocol websockets
listener 9001
protocol websockets
3其它-d什么的命令、用户名密码自己探究（实际应用你肯定得用上）
4、赠送py测试端发送和接收消息（都是东拼西凑的，仅仅能用而已）
4.1python 订阅端
import paho.mqtt.client as mqtt # 一旦连接成功，回调此方法 def on_connect(mqttc, obj, flags, rc): print("rc: " + str(rc)+'连接成功') # 一旦订阅到消息，回调此方法 def on_message(mqttc, obj, msg): print(msg.topic + " " + str(msg.qos) + " " + str(msg.payload)+'已收到消息') print('\nmsg\n') print(str(msg.payload.decode(encoding='UTF-8'))) # 一旦订阅成功，回调此方法 def on_subscribe(mqttc, obj, mid, granted_qos): print("Subscribed: " + str(mid) + " " + str(granted_qos)+'订阅成功') # 一旦有log，回调此方法 def on_log(mqttc, obj, level, string): print(string+'log') # 新建mqtt客户端，默认没有clientid，clean_session=True, transport="tcp" mqttc = mqtt.Client(client_id='PX') mqttc.on_message = on_message mqttc.on_connect = on_connect mqttc.on_subscribe = on_subscribe mqttc.on_log = on_log # 连接broker，心跳时间为60s a=mqttc.connect("39.106.39.98", 1883, 60) print(a) # 订阅该主题，QoS=0 这个是最低的发送标准 参数为1.2时会确认收到消息 mqttc.subscribe("paho/test/single", 0) #保持持续连接 mqttc.loop_forever()
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
- 23
- 24
- 25
- 26
- 27
- 28
- 29
- 30
- 31
- 32
- 33
- 34
- 35
4.2python发送端
#!/usr/bin/env python
# -*- coding: utf-8 -*-
import paho.mqtt.publish as publish
import time
t=time.localtime()
#这个是发送当前时间的被我注释了nowtime
# nowtime=str(t.tm_year) +'-'+ str(t.tm_mon)+'-'+str(t.tm_mday)+','+str(t.tm_hour)+':'+ str(t.tm_min)+':'+ str(t.tm_sec)
#给ESP32板子发送开灯指令 nowtime
nowtime='开'
#四个参数依次为1发布主题、2消息、3服务器地址（外网的）、4什么名字连接
publish.single("paho/test/single", nowtime, hostname="13.14.52.02",client_id='PXFB')
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
代码为东拼西凑修改的，实现了功能，感谢各位博客大佬
声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/小丑西瓜9/article/detail/188562
推荐阅读
相关标签
