823 一个mqtt案例

admin

1. #  -*- coding: UTF-8 -*-
   
2. 
   
3. import siot
   
4. 
   
5. # 自定义函数
   
6. def DIS(NaRong):#显示内容
   
7.     print(NaRong)
   
8. 
   
9. 
   
10. def initZhuTi():#初始化主题（为列表类型）
    
11.     ZhuTi = ['37ck/m']
    
12.     ZhuTi.clear()
    
13.     ZhuTi.extend(['37ck/m'])
    
14.     ZhuTi.extend(['37ck/821'])
    
15.     ZhuTi.extend(['230525/525'])
    
16.     return ZhuTi
    
17. 
    
18. 
    
19. def DingYue(ZhuTi):#订阅主题（多主题订阅）
    
20.     ShuLiang = 0
    
21.     for index in range(len(ZhuTi)):
    
22.         DIS(len(ZhuTi))
    
23.         siot.getsubscribe(topic=(ZhuTi[ShuLiang]))
    
24.         ShuLiang = (ShuLiang + 1)
    
25.     return '订阅完成'
    
26. 
    
27. 
    
28. def MQTT(U):
    
29.     DingYue(initZhuTi())
    
30. 
    
31. 
    
32. def FaSong_topic(ZhuTi, XiaoXi):
    
33.     siot.publish(topic=ZhuTi, data=XiaoXi)
    
34.     return (str(ZhuTi) + str((str("  主题发送消息  ") + str(XiaoXi))))
    
35. 
    
36. 
    
37. # 事件回调函数
    
38. def on_message_callback(client, userdata, msg):
    
39.     DIS((str(msg.topic) + str((str("：（接收）") + str(msg.payload.decode())))))
    
40. 
    
41. #这部分内容填写自己的MQTT服务器配置信息
    
42. siot.init(client_id="", server="服务器IP地址", port=端口, user="用户", password="密码")
    
43. siot.set_callback(on_message_callback)
    
44. siot.connect()
    
45. siot.loop()
    
46. MQTT('37创客')
    
47. 
    
48. while True:
    
49.     FaSong_topic('37ck/m', input("37ck/m输入消息："))
    

复制代码