Python基於mqtt異步編程主要用到asyncio及第三方庫hbmqtt，這里主要介紹mqtt的異步發布及遇到的一些問題。
hbmqtt安裝很簡單，pip hbmqtt install.
mqtt服務器我使用的是mosquitto.
1、主進程
主進程執行下面語句就實現了協程
1 loop = asyncio.get_event_loop() 2 loop.run_until_complete(run())
首先是connect,然后publish，整個過程是一個協程
1 run(): #協程主函數 2 await connect() 3 while True: 4 try: 5 await publish() 6 except Exception as ce: 7 logger.error("Sender Error: %s" % ce)
2、Connect
這里connect沒有使用自動重連機制connect()，而是單獨開一個協程執行掉線后自動重連_auto_reconnect
重連函數，每隔1s執行一次：
1 async def _auto_reconnect(client): 2 while True: 3 if not client.session.transitions.is_connected(): #如果已經連接上則不執行重連 4 try: 5 await client.reconnect() 6 except ConnectException: 7 pass 8 await asyncio.sleep(1)
連接函數，僅執行一次，並啟動重連函數協程
1 async def connect(): 2 client = MQTTClient(config={"auto_reconnect": False}) #False時關閉自動重連 3 try: 4 await client.connect(url) 5 except ConnectException: 6 pass 7 asyncio.ensure_future(_auto_reconnect(client))
3、Publish:
發布函數比較簡單，主要就是
1 await client.publish(topic, msg)
4、總結
這里重點講為什么協程時不要自動重連，因為如果publish過程中出現斷線，需要等待連接成功的event,如果允許自動重連"auto_reconnect": True,程序在publish程序等待信號不退出，無法進入connect程序執行reconnect，這樣就永遠等不到信號，造成程序死等，類似死機。
如果不允許自動重連，單開一個協程執行重連操作，即使publish協程等待事件，重連協程會使這個事件響應，這樣就可以繼續發布。
在hbmqtt庫自帶例子中多是先connect，然后publish,然后disconnect，以此循環，但主要考慮到連接后不主動斷開一提高程序效率，故沒有斷開操作。
這個問題的解決方式可能有點牽強，園友們有沒有遇到過類似的問題，在publish過程中關閉mqtt服務器，再重新打開服務器，發布任務能夠繼續正常執行，如果有好的解決方式，還望不吝賜教。