重连后必须新建Connection和Channel并重新声明Exchange、Queue及绑定，durable=True是必需的，且声明顺序不可颠倒；basic_consume须在声明之后调用，避免使用auto_delete或异步回调操作BlockingConnection。
连接断开后直接调用 exchange_declare 和 queue_declare 会失败
因为 RabbitMQ 的 channel 在网络中断后会进入关闭状态，后续任何方法调用（包括 exchange_declare、queue_declare）都会抛出 ChannelClosedByBroker 或 ConnectionClosed 异常。此时不能复用旧 channel，必须重建 connection 和 channel。
常见错误现象是脚本在重连后仍用原来的 channel 对象调用声明方法，结果报错：Channel is closed 或 Trying to call methods on a closed channel。
- 每次重连后必须新建
pika.BlockingConnection和新channel - 不要缓存或全局复用旧
channel实例 -
exchange_declare和queue_declare必须在新 channel 上执行
重连逻辑里要主动重新声明 Exchange/Queue 并绑定
RabbitMQ 不会自动恢复 exchange、queue 和 binding 关系，即使它们是 durable 的。断连期间 broker 可能重启，或者 client 侧 channel 失效导致元数据丢失，必须显式重申。
典型做法是在建立新 channel 后立刻执行声明和绑定：
立即学习“Python免费学习笔记（深入）”；
让 macOS 自动化像说话一样简单 —— 用代码控制你的 Mac，无需学习 AppleScript 系统要求 macOS 14+ (Sonoma) Python 3.9+ 需要开启：辅助功能 + 屏幕录制权限
channel.exchange_declare(exchange='my_exchange', exchange_type='direct', durable=True) channel.queue_declare(queue='my_queue', durable=True) channel.queue_bind(queue='my_queue', exchange='my_exchange', routing_key='my_key')
-
durable=True是必须的，否则断连后 queue/exchange 会被 broker 清除 -
queue_bind要在queue_declare之后调用，顺序不能反 - 如果使用
auto_delete=True，则无法重连复用，应避免
用 connection.add_callback_threadsafe 触发重声明不安全
有人试图在 connection 的 on_open 回调里直接调用声明逻辑，但这是错的：回调运行在 connection 线程中，而 BlockingConnection 的 channel 操作必须在主线程（或同一线程）执行，否则会卡死或报 ValueError: I/O operation on closed file。
正确方式是：检测到断连后，在主循环中重建 connection + channel，再执行声明。例如用带重试的 while 循环封装：
while True:
try:
conn = pika.BlockingConnection(params)
ch = conn.channel()
ch.exchange_declare(...)
ch.queue_declare(...)
ch.queue_bind(...)
break
except pika.exceptions.AMQPConnectionError:
time.sleep(2)
- 不要依赖 pika 自动重连（
retry_delay等参数只对初始连接生效） - 避免在 signal handler 或异步回调里操作
BlockingConnection的 channel - 如果用
ConnectionParameters，记得设socket_timeout=5防止 connect 卡住
消费者模式下 basic_consume 要在声明之后再注册
很多人把 basic_consume 放在重连外层，导致 channel 还没声明 queue 就开始消费，报错 NOT_FOUND - no queue 'xxx' in vhost '/'。
完整顺序只能是：新 connection → 新 channel → 声明 exchange → 声明 queue → 绑定 → basic_consume → start_consuming。
-
basic_consume中的queue参数必须与queue_declare的queue名完全一致（包括大小写和空格） - 如果 queue 名是空字符串（由 broker 自动生成），重连后会得到不同名字，无法绑定，应显式指定队列名
- 消费者退出前建议调用
channel.cancel()和connection.close()，减少 broker 端残留
重连不是只换掉 connection 对象就完事；Exchange、Queue、Binding、Consumer 这四层都要按顺序、在线程安全的前提下逐层重建。最容易被忽略的是 binding 步骤——它没有返回值，失败时也不报明显异常，但后续 publish 会静默丢消息。
