mqtt异步publish方法

Python基于mqtt异步编程主要用到asyncio及第三方库hbmqtt，这里主要介绍mqtt的异步发布及遇到的一些问题。

hbmqtt安装很简单，pip hbmqtt install.

mqtt服务器我使用的是mosquitto.

1、主进程

主进程执行下面语句就实现了协程

loop = asyncio.get_event_loop()
loop.run_until_complete(run())

首先是connect,然后publish，整个过程是一个协程

run():               #协程主函数
    await connect()
    while True:
        try:
            await publish()
        except Exception as ce:
            logger.error("Sender Error: %s" % ce)

2、Connect

这里connect没有使用自动重连机制connect()，而是单独开一个协程执行掉线后自动重连_auto_reconnect

重连函数，每隔1s执行一次：

async def _auto_reconnect(client):    
    while True:
        if not client.session.transitions.is_connected():   #如果已经连接上则不执行重连
            try:
                await client.reconnect()
            except ConnectException:
                pass
        await asyncio.sleep(1)

连接函数，仅执行一次，并启动重连函数协程

async def connect():    
    client = MQTTClient(config={"auto_reconnect": False})       #False时关闭自动重连
    try:
        await client.connect(url)
    except ConnectException:
        pass
    asyncio.ensure_future(_auto_reconnect(client))

3、Publish:

发布函数比较简单，主要就是

 await client.publish(topic, msg)

4、总结

这里重点讲为什么协程时不要自动重连，因为如果publish过程中出现断线，需要等待连接成功的event,如果允许自动重连"auto_reconnect": True,程序在publish程序等待信号不退出，无法进入connect程序执行reconnect，这样就永远等不到信号，造成程序死等，类似死机。

如果不允许自动重连，单开一个协程执行重连操作，即使publish协程等待事件，重连协程会使这个事件响应，这样就可以继续发布。

在hbmqtt库自带例子中多是先connect，然后publish,然后disconnect，以此循环，但主要考虑到连接后不主动断开一提高程序效率，故没有断开操作。

这个问题的解决方式可能有点牵强，园友们有没有遇到过类似的问题，在publish过程中关闭mqtt服务器，再重新打开服务器，发布任务能够继续正常执行，如果有好的解决方式，还望不吝赐教。