rabbitmqctl list_queues name durable messages
# 发布端
channel.basic_publish(exchange='', routing_key='job',
  body=body, properties=pika.BasicProperties(delivery_mode=2))

RabbitMQ 重启 40 秒,恢复后 queues 里只剩 300 条,重启前是 1500 条,日志里没有任何报错。这类现象通常不是突然出现的,往前翻半天日志能看到苗头。

追下去是这么回事:队列声明时 durable 是 false,消息的 delivery_mode 也是 1,两者都只存在内存里。broker 进程退出,队列和消息一起没了。

这次卡住的地方就在「队列重启丢消息」这一环,单独把它拎出来验证,别和其他改动混在同一次发布里。同一份配置存在多处的,先确认改的是被加载的那一份。

新版本先放一台机器上跑一天再全量,问题一般在这段时间暴露。备份不是备了就行,恢复一次才算数,很多备份文件打开才发现是空的。

接口问题先分清是没发出去、发出去了没收到,还是收到了处理失败。

处理上按这个顺序:声明队列时把 durable 设为 true 并且不要自动删除;发布消息时设置 delivery_mode=2;确认交换机也是 durable 三者要一致;重启后对比消息数和发布数 确认没有缺口。

确认没问题再收工,重启 broker 后队列还在 消息条数与重启前一致 durable 列显示 true。

作者 9823189