需要安裝的python庫(kù)
專(zhuān)注于為中小企業(yè)提供成都做網(wǎng)站、網(wǎng)站建設(shè)服務(wù),電腦端+手機(jī)端+微信端的三站合一,更高效的管理,為中小企業(yè)小店免費(fèi)做網(wǎng)站提供優(yōu)質(zhì)的服務(wù)。我們立足成都,凝聚了一批互聯(lián)網(wǎng)行業(yè)人才,有力地推動(dòng)了上千多家企業(yè)的穩(wěn)健成長(zhǎng),幫助中小企業(yè)通過(guò)網(wǎng)站建設(shè)實(shí)現(xiàn)規(guī)模擴(kuò)充和轉(zhuǎn)變。使用python編寫(xiě)程序進(jìn)行測(cè)試MQTT的發(fā)布和訂閱功能。首先要安裝:pip install paho-mqtt
測(cè)試發(fā)布(pub)
我的MQTT部署在阿里云的服務(wù)器上面,所以我在本機(jī)上編寫(xiě)了python程序進(jìn)行測(cè)試。
然后在shell里面重新打開(kāi)一個(gè)終端,訂閱一個(gè)主題為“chat” mosquitto_sub -t chat
在本機(jī)上測(cè)試遠(yuǎn)程的MQTT的發(fā)布功能就是把自己作為一個(gè)發(fā)送信息的人,當(dāng)自己發(fā)送信息的時(shí)候,所有訂閱過(guò)該主題(topic)的對(duì)象都將收到自己發(fā)送的信息。
mqtt_client.py # encoding: utf-8 import paho.mqtt.client as mqtt HOST = "101.200.46.138" PORT = 1883 def test(): client = mqtt.Client() client.connect(HOST, PORT, 60) client.publish("chat","hello liefyuan",2) # 發(fā)布一個(gè)主題為'chat',內(nèi)容為‘hello liefyuan'的信息 client.loop_forever() if __name__ == '__main__': test()
另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)scvps.cn,海內(nèi)外云服務(wù)器15元起步,三天無(wú)理由+7*72小時(shí)售后在線,公司持有idc許可證,提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國(guó)服務(wù)器、虛擬主機(jī)、免備案服務(wù)器”等云主機(jī)租用服務(wù)以及企業(yè)上云的綜合解決方案,具有“安全穩(wěn)定、簡(jiǎn)單易用、服務(wù)可用性高、性價(jià)比高”等特點(diǎn)與優(yōu)勢(shì),專(zhuān)為企業(yè)上云打造定制,能夠滿足用戶豐富、多元化的應(yīng)用場(chǎng)景需求。