我想实现paho-mqtt，它应该异步处理传入的消息。
我已经实现了gmqtt与pagencio，运行完美，但据我所知，paho-mqtt是更好地使用，而不是gmqtt（链接：https://www.emqx.io/blog/comparision-of-python-mqtt-client）。
gmqtt w/callcio：

def assign_callbacks_to_client(self, client):
    """ Helper function which sets up client's callbacks. """
    client.on_connect = self.on_connect
    client.on_message = self.on_message
    client.on_disconnect = self.on_disconnect
    client.on_subscribe = self.on_subscribe

async def subscriber(self, mqtt_name):
    """ Connect to mqtt-broker. """
    sub_client = MQTTClient(mqtt_name)
    self.assign_callbacks_to_client(sub_client)
    logging.info("connecting")
    await sub_client.connect(host=config.MQTT_HOST, port=int(config.MQTT_PORT))
    return sub_client

字符串
你能让我知道，如何实现paho与paho库？将使用loop_start异步，因为我知道每次执行它启动一个新的线程在后台。