PHP连接RabbitMQ需用php-amqplib库，执行composer require php-amqplib/php-amqplib；连接时须正确配置host、port、username、password、vhost，发送消息需声明持久化队列并设置delivery_mode=>2。
PHP怎么连接RabbitMQ并发送消息
PHP本身不内置RabbitMQ支持，必须用php-amqplib这类AMQP 0.9.1协议客户端库。别试ext-rabbitmq（已废弃多年），也别指望curl或file_get_contents能直接连——RabbitMQ不是HTTP服务。
安装方式是：composer require php-amqplib/php-amqplib。连接失败最常见的原因是：用户名密码错（默认guest/guest在3.3+版本只允许localhost访问）、vhost填成/但实际创建的是/myapp、端口写成5672却启用了TLS（该用5671）。
发送一条消息的最小可行代码：
use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;
<p>$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest', 'myapp');
$channel = $connection->channel();</p><p>$channel->queue_declare('task_queue', false, true, false, false);
$msg = new AMQPMessage('Hello World!', ['delivery_mode' => 2]); // 持久化
$channel->basic_publish($msg, '', 'task_queue');</p><p>$channel->close();
$connection->close();
-
delivery_mode => 2必须加，否则重启RabbitMQ后队列里没存住消息 - 队列名和交换器名不能含空格或特殊符号，建议全小写+下划线
- 如果用Docker部署RabbitMQ，宿主机PHP连不上时，优先检查
docker network是否隔离，而不是改bind_address
PHP怎么从RabbitMQ消费消息并确保不丢数据
消费端最容易出问题的是“消息被取走但没处理完就断了”，导致消息丢失。根本解法是关闭自动确认（no_ack=false），并在业务逻辑真正完成后再手动调用ack。
立即学习“PHP免费学习笔记（深入）”；
以下代码会卡住直到收到消息，适合常驻进程（如supervisor管理的worker）：
$channel->basic_qos(null, 1, null); // 限流：一次只给1条，处理完再给下一条
$channel->basic_consume('task_queue', '', false, false, false, false, function ($msg) {
echo "Received: ", $msg->body, "\n";
// 这里放你的业务逻辑，比如写数据库、调API
if (/* 处理成功 */) {
$msg->ack(); // 必须显式调用
} else {
$msg->nack(['requeue' => true]); // 失败则重新入队
}
});
- 漏掉
$channel->basic_qos会导致RabbitMQ疯狂推送消息，PHP进程OOM或MySQL被打挂 -
ack()必须在try/catch的finally块里调用，否则异常抛出时消息就丢了 - 不要在回调里做
sleep(10)之类长耗时操作，应该把任务拆成小步，或用pcntl_fork分进程（需注意信号处理）
为什么PHP consumer一启动就退出，或者收不到新消息
典型现象是脚本执行完立即结束，没报错也没输出。本质原因是basic_consume只是注册回调，不阻塞；必须手动进入监听循环。
- 缺
while ($channel->is_consuming()) { $channel->wait(); }，就会注册完立刻退出 - 用
php -f worker.php运行后Ctrl+C退出，RabbitMQ默认会把未ack消息重发给其他consumer——如果你只有一个consumer，它会不断重发，看起来像“重复消费” - 如果用
systemd或supervisor管理，要确认stdout没被重定向到/dev/null，否则echo看不到日志，误以为没运行 - 某些云厂商RabbitMQ服务（如阿里云AMQP版）强制要求TLS，但
AMQPStreamConnection默认不启用，得换AMQPSocketConnection并传入证书路径
PHP读写RabbitMQ时要注意哪些兼容性坑
不同RabbitMQ大版本对AMQP协议的支持有差异，PHP客户端版本也得匹配。3.8.x之后默认禁用AMQP 0.9.1的旧认证方式，而php-amqplib v2.x仍用PLAIN机制，可能被拒绝连接。
- 用RabbitMQ 3.11+时，必须升级
php-amqplib到v3.5+，否则connection.start阶段直接断连 - PHP 8.1+环境下，
php-amqplibv2.12以下会触发Deprecated: strlen(): Passing null to strlen()警告，得升级 - 队列声明时
durable=true但auto_delete=true是矛盾的，RabbitMQ会静默忽略durable，结果消息不持久——这两个参数不能同时为true - 消息体超过128KB时，部分RabbitMQ配置会截断，建议业务层自己分片或改用对象存储+发URL
最麻烦的不是连不上，而是连上了、发了、也消费了，但因为ack时机不对或qos没设，导致消息堆积或重复——这些都得靠日志+RabbitMQ Management Plugin界面交叉验证，光看PHP代码很难定位。
