【米尔瑞萨RZ/G2L开发板-创新应用】使用MQTT协议+Python开发远程控制音频播放

根据之前大佬们的帖子，成功连接wifi+安装pip3

在安装paho-mqtt-1.6.1时出现

1. raise ValueError('ZIP does not support timestamps before 1980')
   
2. ValueError: ZIP does not support timestamps before 1980

复制代码

文件未设置时间，无法正确安装

1. tar -zxvf paho-mqtt-1.6.1.tar.gz
   
2. 
   
3. cd paho-mqtt-1.6.1
   
4. 
   
5. find ./ -type f
   
6. 
   
7. find ./ -type f -exec touch -d "2023-08-23" {} +

复制代码

对文件夹下所有时间进行修改，成功进行安装。

根据文档中的播放音频命令

1. import paho.mqtt.client as mqtt
   
2. import subprocess
   
3. 
   
4. 
   
5. # MQTT代理配置
   
6. broker_address = "broker.emqx.io"  # 请用您的MQTT代理地址替换
   
7. broker_port = 1883  # 默认MQTT端口
   
8. music_file = "/usr/share/myir/Music/The promise.mp3"
   
9. cmd = ["gst-play-1.0", music_file]
   
10. 
    
11. # 回调函数
    
12. def on_connect(client, userdata, flags, rc):
    
13.     if rc == 0:
    
14.         print("已连接到MQTT代理！")
    
15.         # 连接后订阅一个主题
    
16.         client.subscribe("xzknz321")
    
17.     else:
    
18.         print(f"连接失败，返回代码：{rc}")
    
19. 
    
20. def on_message(client, userdata, message):
    
21.     print(f"接收到主题 '{message.topic}' 的消息：{message.payload.decode()}")
    
22.     a = message.payload.decode()
    
23.     if a == "play_music":
    
24.         print(a)
    
25.         subprocess.Popen(cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
    
26. 
    
27. # 创建MQTT客户端实例
    
28. client = mqtt.Client()
    
29. 
    
30. # 设置回调函数
    
31. client.on_connect = on_connect
    
32. client.on_message = on_message
    
33. 
    
34. # 连接到MQTT代理
    
35. client.connect(broker_address, broker_port, keepalive=60)
    
36. 
    
37. # 启动循环，处理网络数据，回调和保持连接
    
38. client.loop_start()
    
39. 
    
40. try:
    
41.     # 发布一条消息到主题
    
42.     client.publish("xzknz321", "你好，MQTT！")
    
43. 
    
44.     # 让程序保持运行以接收消息
    
45.     while True:
    
46.         pass
    
47. 
    
48. except KeyboardInterrupt:
    
49.     # 在程序被中断时（Ctrl+C），优雅地断开MQTT客户端连接
    
50.     client.disconnect()
    
51.     client.loop_stop()
    
52.     print("已从MQTT代理断开连接。")
    

复制代码