捕获Pika回调内的异常导致回调停止工作

你的问题出在异常发生时没有处理未确认的消息，加上auto_ack=False的设置，导致RabbitMQ认为这个消费者还在卡住处理那条失败的消息，所以不再投递新消息给它。

具体原因： #

• 当auto_ack=False，RabbitMQ要求你显式调用basic_ack（成功）、basic_nack/basic_reject（失败）来确认消息状态。
• 你的try块只在成功时做了basic_ack，异常时啥都没做，这条失败的消息会一直处于「未确认」状态。RabbitMQ不会给同一个消费者投递新消息，直到这条消息的状态被确认。
• 去掉try-except时，异常直接抛给Pika，Pika会自动处理这条消息（比如nack并放回队列），同时如果你的连接有自动恢复机制，消费者会重新正常接收后续消息。

修复代码： #

在except块里添加消息的失败确认逻辑，比如用basic_nack把消息放回队列（或者根据需求选择丢弃）：

def request_callback(channel, method, properties, body):
    try:
        readings = json_util.loads(body)
        location_updater.update_location(readings)
        channel.basic_ack(delivery_tag=method.delivery_tag)
    except Exception:
        logger.exception('EXCEPTION: ')
        # 处理失败的消息：nack表示不确认，requeue=True会把消息放回队列，False则丢弃
        channel.basic_nack(delivery_tag=method.delivery_tag, requeue=True)

注意事项： #

• 如果设置requeue=True，要小心消息循环失败的情况（比如消息本身格式有问题，会一直被重复投递），这种情况可以考虑requeue=False，或者添加重试次数限制。
• 也可以用basic_reject，它和basic_nack的区别是一次只能处理一条消息，而basic_nack可以批量处理。

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