一、消息隊列伺服器
這裡我用到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>标簽底部,添加兩個登入使用者
如下圖
![](https://img.laitimes.com/img/9ZDMuAjOiMmIsIjOiQnIsISPrdEZwZ1Rh5WNXp1bwNjW1ZUba9VZwlHdsATOfd3bkFGazxCMx8VesATMfhHLlN3XnxCMwEzX0xiRGZkRGZ0Xy9GbvNGLpZTY1EmMZVDUSFTU4VFRR9Fd4VGdsYTMfVmepNHLrJXYtJXZ0F2dvwVZnFWbp1zczV2YvJHctM3cv1Ce-cmbw5iMyUDZjVmYlNzMiFDZkBDM1ETOzQTOhRWM1UmYlFjZw8CX2EzLcdDMxIDMy8CXn9Gbi9CXzV2Zh1WavwVbvNmLvR3YxUjL0M3Lc9CX6MHc0RHaiojIsJye.png)
二、mqtt通信過程圖如下,接下來用python程式,模拟用戶端1和用戶端2的通信過程
三、代碼
封裝Mqtt用戶端
用戶端1代碼
用戶端2代碼