![\"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/11\/20261103074917-6ae991fd4fd98.png\")
<\/p>\n<\/p>\n<\/p>\n<\/p>\n
![\"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/11\/20261103074920-6ae9920076484.png\")
![\"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/11\/20261103074920-6ae99200eb0d8.png\")
<\/p>\n
![\"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/11\/20261103074921-6ae9920196681.png\")
<\/p>\n
![\"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/11\/20261103074921-6ae99201e64a0.png\")
<\/p>\n
import<\/span> sys os.<\/span>environ[<\/span>"QT_QUICK_CONTROLS_STYLE"<\/span>]<\/span> =<\/span> "Fusion"<\/span><\/p>\n from<\/span> PyQt6.<\/span>QtWidgets import<\/span> QApplication class<\/span> MQTTBridge<\/span>(<\/span>QObject)<\/span>:<\/span> # \u4fe1\u53f7\u5b9a\u4e49<\/span> def<\/span> __init__<\/span>(<\/span>self)<\/span>:<\/span> # \u8ba2\u9605\u7684\u4e3b\u9898\u8bcd\u5217\u8868<\/span> @pyqtSlot<\/span>(<\/span>str<\/span>,<\/span> str<\/span>,<\/span> str<\/span>,<\/span> result=<\/span>bool<\/span>)<\/span> try<\/span>:<\/span> msg =<\/span> f"\u6b63\u5728\u8fde\u63a5\u5230 <\/span>{<\/span>host}<\/span><\/span>:<\/span>{<\/span>port}<\/span><\/span>…"<\/span><\/span> self.<\/span>client.<\/span>connect(<\/span>host,<\/span> int<\/span>(<\/span>port)<\/span>,<\/span> 60<\/span>)<\/span> # \u7b49\u5f85\u8fde\u63a5\u5b8c\u6210（\u6700\u591a3\u79d2）<\/span> # \u8d85\u65f6\u4f46\u672a\u8fde\u63a5<\/span>
\nimport<\/span> os<\/p>\n
\nfrom<\/span> PyQt6.<\/span>QtQml import<\/span> QQmlApplicationEngine
\nfrom<\/span> PyQt6.<\/span>QtCore import<\/span> QObject,<\/span> pyqtSlot,<\/span> pyqtSignal
\nfrom<\/span> datetime import<\/span> datetime
\nimport<\/span> paho.<\/span>mqtt.<\/span>client as<\/span> mqtt<\/p>\n
\n """MQTT \u6865\u63a5\u7c7b"""<\/span><\/p>\n
\n logMessage =<\/span> pyqtSignal(<\/span>str<\/span>,<\/span> str<\/span>)<\/span> # timestamp, message<\/span>
\n messageReceived =<\/span> pyqtSignal(<\/span>str<\/span>,<\/span> str<\/span>,<\/span> str<\/span>)<\/span> # topic, payload, timestamp<\/span>
\n clientStatusChanged =<\/span> pyqtSignal(<\/span>bool<\/span>,<\/span> str<\/span>)<\/span> # is_connected, status_text<\/span><\/p>\n
\n super<\/span>(<\/span>)<\/span>.<\/span>__init__(<\/span>)<\/span>
\n self.<\/span>client =<\/span> None<\/span>
\n self.<\/span>is_client_connected =<\/span> False<\/span><\/p>\n
\n self.<\/span>subscribed_topics =<\/span> [<\/span>]<\/span><\/p>\n
\n def<\/span> connect_client<\/span>(<\/span>self,<\/span> host,<\/span> port,<\/span> client_id)<\/span>:<\/span>
\n """\u8fde\u63a5 MQTT \u5ba2\u6237\u7aef"""<\/span>
\n if<\/span> self.<\/span>is_client_connected:<\/span>
\n self.<\/span>logMessage.<\/span>emit(<\/span>self.<\/span>_timestamp(<\/span>)<\/span>,<\/span> "\u5ba2\u6237\u7aef\u5df2\u8fde\u63a5"<\/span>)<\/span>
\n return<\/span> False<\/span><\/p>\n
\n # API v2 \u7528\u4e8e paho-mqtt 2.x<\/span>
\n try<\/span>:<\/span>
\n self.<\/span>client =<\/span> mqtt.<\/span>Client(<\/span>
\n callback_api_version=<\/span>mqtt.<\/span>CallbackAPIVersion.<\/span>VERSION2,<\/span>
\n client_id=<\/span>client_id if<\/span> client_id else<\/span> None<\/span>
\n )<\/span>
\n except<\/span> (<\/span>AttributeError,<\/span> TypeError)<\/span>:<\/span>
\n # \u56de\u9000\u5230\u65e7\u7248 API<\/span>
\n self.<\/span>client =<\/span> mqtt.<\/span>Client(<\/span>client_id=<\/span>client_id if<\/span> client_id else<\/span> None<\/span>)<\/span>
\n self.<\/span>client.<\/span>on_connect =<\/span> self.<\/span>_on_connect
\n self.<\/span>client.<\/span>on_disconnect =<\/span> self.<\/span>_on_disconnect
\n self.<\/span>client.<\/span>on_message =<\/span> self.<\/span>_on_message<\/p>\n
\n print<\/span>(<\/span>msg)<\/span>
\n self.<\/span>logMessage.<\/span>emit(<\/span>self.<\/span>_timestamp(<\/span>)<\/span>,<\/span> msg)<\/span><\/p>\n
\n self.<\/span>client.<\/span>loop_start(<\/span>)<\/span><\/p>\n
\n import<\/span> time
\n for<\/span> _ in<\/span> range<\/span>(<\/span>30<\/span>)<\/span>:<\/span>
\n time.<\/span>sleep(<\/span>0.1<\/span>)<\/span>
\n if<\/span> self.<\/span>is_client_connected:<\/span>
\n return<\/span> True<\/span><\/p>\n
\n if<\/span> not<\/span> self.<\/span>is_client_connected:<\/span>
\n msg =<\/span> "\u8fde\u63a5\u8d85\u65f6"<\/span>
\n print<\/span>(<\/span>msg)<\/span>
\n self.<\/span>logMessage.<\/span>emit(<\/span>self.<\/span>_timestamp(<\/span>)<\/span>,<\/span> msg)<\/span>
\n self.<\/span>clientStatusChanged.<\/span>emit(<\/span>False<\/span>,<\/span> "\u8fde\u63a5\u8d85\u65f6"<\/span>