嘿，刚好之前折腾过Paho和Mosquitto的保活场景，给你捋清楚怎么操作——其实你不用手动去实现PINGREQ/PINGACK的底层交互，Paho的Python客户端已经封装了成熟的心跳保活机制，不过要是你想手动控制或者验证这个流程，也有对应的方法。

一、优先用客户端内置的自动保活（推荐） #

Mosquitto要求每60秒有通信流量，Paho客户端的keepalive参数刚好能满足这个需求。当你把keepalive设为60时，客户端会自动每隔30秒左右发送一次PINGREQ报文，并且等待服务器返回的PINGACK，完全不用你手动处理。

示例代码如下：

import paho.mqtt.client as mqtt
import time

# 连接成功的回调
def on_connect(client, userdata, flags, rc):
    print("连接成功，返回码: "+str(rc))

# 收到PINGACK的回调（可选，用来确认服务器响应）
def on_pingresp(client, userdata):
    print("收到Broker的PINGACK响应")

# 创建客户端实例
client = mqtt.Client()
# 绑定回调函数
client.on_connect = on_connect
client.on_pingresp = on_pingresp

# 连接Mosquitto代理，设置keepalive为60秒
client.connect("你的代理地址", 1883, 60)

# 启动后台线程处理网络IO
client.loop_start()

try:
    # 保持程序运行，模拟业务逻辑
    while True:
        time.sleep(1)
except KeyboardInterrupt:
    # 中断时停止循环并断开连接
    client.loop_stop()
    client.disconnect()

这里的on_pingresp是可选的回调，加了之后可以在控制台看到服务器确实回复了PINGACK，方便调试。

二、手动发送PINGREQ报文（特殊场景用） #

如果你因为某些需求必须手动触发PINGREQ，可以调用客户端的ping()方法，这个方法会直接发送PINGREQ报文，然后等待服务器的PINGACK响应。

注意：如果用手动方式，建议把keepalive设为0（关闭自动保活），避免和自动机制冲突。示例代码：

import paho.mqtt.client as mqtt
import time

def on_connect(client, userdata, flags, rc):
    print("连接成功，返回码: "+str(rc))

def on_pingresp(client, userdata):
    print("手动发送PINGREQ后，收到Broker的PINGACK")

client = mqtt.Client()
client.on_connect = on_connect
client.on_pingresp = on_pingresp

# 设置keepalive为0，关闭自动保活
client.connect("你的代理地址", 1883, 0)
client.loop_start()

try:
    while True:
        print("手动发送PINGREQ")
        client.ping()
        # 每隔60秒发送一次，符合Mosquitto的要求
        time.sleep(60)
except KeyboardInterrupt:
    client.loop_stop()
    client.disconnect()

一些注意事项 #

• 确保你的Python 2.7安装了兼容版本的Paho客户端：执行pip install paho-mqtt==1.6.1，这个版本是支持Python2.7的最后几个稳定版本之一，更高版本只支持Python3。
• 不管用自动还是手动方式，都要确保通信间隔不超过60秒，否则Mosquitto会因为超时断开你的连接。
• 如果用loop_forever()代替loop_start()，需要把定时逻辑放到主线程里，避免阻塞网络IO处理。

内容的提问来源于stack exchange，提问作者buzzard51