不能直接 new AMQPConnection，因其在1.9.0+版本已弃用，且非线程安全、连接静默失效风险高；应使用AMQPStreamConnection并配合健康检查（如getServerProperties）实现按需重建的连接单例。
为什么不能直接 new AMQPConnection？
PHP 的 amqp 扩展（基于 librabbitmq）中，AMQPConnection 类在 1.9.0+ 版本已弃用，新版推荐用 AMQPStreamConnection；而更关键的是，它本身不是线程安全的，且连接对象不建议复用——尤其在 CLI 模式下长进程（如消费者）中，网络抖动或 broker 重启会导致连接静默失效，isConnected() 可能仍返回 true，但后续 channel 操作会抛出 AMQPConnectionException 或卡死。
所以“单例”重点不在“只实例化一次”，而在“按需重建 + 安全复用 + 显式健康检查”。
如何实现带自动重连的连接管理？
核心逻辑是：每次需要连接时，先检查当前连接是否可用（发一个轻量探测，比如 getServerProperties()），不可用则关闭旧连接并新建。不依赖 isConnected()，因为该方法不真正发包。
-
AMQPStreamConnection构造失败会直接抛AMQPConnectionException，必须 try/catch - 连接成功后立即调用
$conn->getServerProperties()做握手验证，这是最轻量的活跃性探测 - 把连接对象存在静态属性里，但每次
getInstance()都执行健康检查，不是无脑返回缓存 - CLI 场景下建议设置
'heartbeat' => 30并启用AMQP_AUTOACK外的 channel 级确认机制，避免心跳超时断连
class RabbitMQConnection
{
private static ?AMQPStreamConnection $instance = null;
private static array $config = [
'host' => 'localhost',
'port' => 5672,
'user' => 'guest',
'pass' => 'guest',
'vhost' => '/',
'heartbeat' => 30,
];
public static function getInstance(array $override = []): AMQPStreamConnection
{
$config = array_merge(self::$config, $override);
if (self::$instance && self::isAlive(self::$instance)) {
return self::$instance;
}
try {
$conn = new AMQPStreamConnection(
$config['host'],
$config['port'],
$config['user'],
$config['pass'],
$config['vhost'],
false,
AMQP_SECURE,
3,
3,
null,
'AMQPLAIN',
$config['heartbeat']
);
// 强制握手验证
$conn->getServerProperties();
self::$instance = $conn;
return $conn;
} catch (AMQPConnectionException $e) {
throw new RuntimeException('RabbitMQ connection failed: ' . $e->getMessage(), (int)$e->getCode(), $e);
}
}
private static function isAlive(AMQPStreamConnection $conn): bool
{
try {
$conn->getServerProperties();
return true;
} catch (Exception $e) {
return false;
}
}
}
CLI 消费者里怎么安全使用这个单例？
CLI 进程不能靠构造时一次性连接撑到底。每轮循环处理消息前，都应重新获取连接实例——因为上一轮可能已断开，而你持有的 $channel 对象已失效。
立即学习“PHP免费学习笔记（深入）”；
- 不要在类属性里存
$channel或$queue，它们依附于连接，连接断则全失效 - 每个工作单元（如单条消息处理）内，用
RabbitMQConnection::getInstance()获取连接，再新建AMQPChannel，用完不显式 close（PHP GC 会回收） - 若需手动控制 channel 生命周期，务必在
try...finally中确保$channel->close()，否则可能泄漏 socket - 注意
AMQPStreamConnection不支持并发 channel 复用，一个连接同一时刻只应被一个线程/协程使用
AMQP 扩展版本和配置容易踩哪些坑？
不同 PHP 版本 + amqp 扩展版本组合下行为差异很大，尤其是错误处理和默认行为：
- PHP 8.0+ 必须用 amqp >= 1.11.0，否则
AMQPStreamConnection构造器参数顺序不兼容 - 忘记传
$login_method = 'AMQPLAIN'在某些 RabbitMQ 3.12+ 配置下会静默认证失败 -
'heartbeat' => 0并非禁用心跳，而是交由 OS TCP keepalive 控制，实际更容易断连；生产环境建议设为 30～60 - 扩展编译时未启用
--with-amqp-ssl，但配置了AMQP_SECURE，会导致连接直接失败且错误信息模糊（只报 “connection refused”）
连接单例的真正难点不在写法，而在对 amqp 扩展底层行为的理解——它不像 PDO 那样有成熟的连接池抽象，每个连接都是裸 socket 封装，异常路径多且恢复逻辑得自己兜底。
