如何在pynsq中避免消息超时问题

看起来你碰到了NSQ里长任务处理的典型超时问题，我之前也踩过类似的坑，结合你的代码和报错信息，给你几个针对性的解决思路：

1. 给Reader配置关键的超时参数 #

你的Reader初始化里缺了几个核心参数，这是导致超时的主要原因之一。NSQ默认的消息超时是60秒，而你的任务要sleep100秒，哪怕后面调用了touch()，也已经来不及了。赶紧加上这些参数：

r_check = nsq.Reader(
    message_handler=process_message,
    nsqd_tcp_addresses=['127.0.0.1:4150'],
    topic='hello',
    channel='channel',
    lookupd_poll_interval=15,
    lookupd_connect_timeout=100000,
    lookupd_request_timeout=100000,
    max_tries=10,
    # 新增的关键配置，按需调整数值
    message_timeout=300000,  # 把消息超时设为300秒（5分钟），覆盖默认的60秒
    max_in_flight=1,  # 如果都是长任务，建议设为1，避免并发处理导致多个超时
    heartbeat_interval=15000  # 缩短心跳间隔到15秒，确保连接不会被误判为断开
)

2. 把message.touch()的调用时机提前！ #

你现在是在time.sleep(100)之后才调用touch()，这时候NSQ服务端早已经判定消息超时，把连接关了。正确的做法是在处理过程中定期调用touch()，每隔一段时间就告诉NSQ：“我还在处理这个消息，别着急回收”。修改你的处理函数：

import time

def process_message(message):
    print(message)
    # 模拟长任务，分阶段调用touch
    total_sleep = 100
    interval = 30  # 每30秒touch一次
    for _ in range(total_sleep // interval):
        time.sleep(interval)
        message.touch()  # 每次休眠后重置超时计时器
    # 处理剩余的时间
    time.sleep(total_sleep % interval)
    return True

3. 检查NSQD服务端的配置 #

如果客户端配置完还是有问题，那可能是NSQD服务端的全局限制在作怪。启动nsqd的时候，需要调整这两个参数：

nsqd --msg-timeout 300s --heartbeat-interval 15s

• --msg-timeout：设置全局的消息超时时间，要和客户端的message_timeout保持一致或者更大
• --heartbeat-interval：服务端的心跳间隔，和客户端配置匹配即可

为啥之前的touch()没用？ #

核心原因是时机不对！NSQ的默认消息超时是60秒，你的任务sleep100秒，等你调用touch()的时候，服务端已经因为消息超时关闭了连接，这个调用根本没机会被服务端接收到。必须在超时窗口内重复调用touch()，才能持续重置超时计时器。

按照这几步调整下来，你的长任务应该就能正常处理，不会再出现ConnectionClosedError了。

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