### Python 中 `client.on_connect=on_connect` 的含义和用法 在 Python 的 MQTT 客户端库（如 `paho-mqtt`）中，`client.on_connect=on_connect` 是设置连接回调函数的一种方式。具体来说，`on_connect` 是一个用户定义的函数，当客户端成功连接到 MQTT 代理时，该函数会被调用[^1]。 #### 含义 - `client.on_connect` 是 `paho.mqtt.client.Client` 类的一个属性，用于指定连接成功时的回调函数。 - 将自定义函数赋值给 `client.on_connect`，使得在客户端与 MQTT 代理建立连接后，能够触发该函数执行特定操作[^2]。 #### 参数说明 `on_connect` 回调函数的标准参数列表为 `(client, userdata, flags, rc)`： - `client`：MQTT 客户端实例。 - `userdata`：用户定义的数据，在创建客户端时可以通过 `user_data_set()` 方法设置。 - `flags`：字典类型，包含会话标志信息。例如，`flags['session present']` 表示当前会话是否已经存在。 - `rc`：连接返回码，表示连接结果。常见的返回码包括： - `0`：连接成功。 - `1`：连接被拒绝 - 协议版本不正确。 - `2`：连接被拒绝 - 标识符无效。 - `3`：连接被拒绝 - 服务器不可用。 - `4`：连接被拒绝 - 用户名或密码错误。 - `5`：连接被拒绝 - 未授权[^3]。 #### 示例代码 以下是一个完整的示例，展示如何使用 `client.on_connect=on_connect` 设置连接回调函数： ```python import paho.mqtt.client as mqtt # 定义连接回调函数 def on_connect(client, userdata, flags, rc): if rc == 0: print("Connected successfully with result code " + str(rc)) # 连接成功后订阅主题 client.subscribe("test/topic") else: print(f"Failed to connect, return code {rc}") # 创建客户端实例 client = mqtt.Client() # 设置连接回调函数 client.on_connect = on_connect # 配置用户名和密码 client.username_pw_set("username", "password") # 连接到 MQTT 代理 client.connect("broker.example.com", 1883, 60) # 启动网络循环以保持连接 client.loop_forever() ``` #### 作用 - 在连接成功后，可以执行一系列初始化操作，例如订阅主题、发布消息等。 - 检查连接返回码 `rc`，以判断连接是否成功，并根据返回码采取相应措施[^4]。 #### 注意事项 - 如果需要持久会话，可以在创建客户端时将 `clean_session` 参数设置为 `False`。 - 确保在网络循环启动前完成所有回调函数的设置，否则可能会导致回调无法正常触发[^5]。