天天看點

python實作mqtt釋出訂閱消息(windows)

一、消息隊列伺服器

這裡我用到activemq-5.16.2,可到官網下載下傳 http://activemq.apache.org/

1. 若遇到點選apache-activemq-5.16.2\bin\activemq.bat 出現閃退,64位系統請點選apache-activemq-5.16.2\bin\win64\activemq.bat,啟動mqtt伺服器

2. ActiveMQ mqtt預設端口為1883,測試伺服器ip為192.168.1.103

3.在apache-activemq-5.16.2\conf\activemq.xml中,在<broker>标簽底部,添加兩個登入使用者

如下圖

python實作mqtt釋出訂閱消息(windows)

二、mqtt通信過程圖如下,接下來用python程式,模拟用戶端1和用戶端2的通信過程

python實作mqtt釋出訂閱消息(windows)

 三、代碼

封裝Mqtt用戶端

用戶端1代碼

用戶端2代碼