PHP 8.5需通过php-amqplib库连接RabbitMQ，分三步：确认服务可用（本地Docker/云服务/自建）、Composer安装v3.0+客户端、编写生产者与消费者脚本，注意使用严格类型、异常捕获，避免amqp.so扩展。
确认 RabbitMQ 服务可用
你的 PHP 应用要连得上 RabbitMQ 服务端。常见方式有：
- 本地开发：用 Docker 启一个 RabbitMQ（含管理界面），命令示例：
docker run -d --name rabbitmq -p 5672:5672 -p 15672:15672 -e RABBITMQ_DEFAULT_USER=admin -e RABBITMQ_DEFAULT_PASS=123456 rabbitmq:3-management - 云服务（如阿里云 MQ for RabbitMQ）：从控制台获取接入点（host）、端口（通常 5672）、VHost、用户名/密码
- 自建服务器：确保防火墙放行 5672 端口，且 RabbitMQ 已启用
amqp插件（默认开启）
安装 php-amqplib 客户端
PHP 8.5 兼容 php-amqplib v3.0+（v4.x 也支持）。推荐用 Composer 管理：
- 项目根目录执行：
composer require php-amqplib/php-amqplib:^3.0 - 自动加载已包含，无需手动 extension 配置（注意：这不是 PHP 的
amqp.so扩展，不用 PECL 安装，也不用改 php.ini） - 验证是否加载成功：运行
php -r "require 'vendor/autoload.php'; echo class_exists('PhpAmqpLib\Connection\AMQPStreamConnection') ? 'OK' : 'FAIL';"，输出 OK 即可
写一个最简生产者和消费者
以直连模式（direct exchange）为例，两段脚本可独立运行：
-
生产者（send.php）：
require_once 'vendor/autoload.php';
use PhpAmqpLibConnectionAMQPStreamConnection;
use PhpAmqpLibMessageAMQPMessage;
$connection = new AMQPStreamConnection('localhost', 5672, 'admin', '123456', '/');
$channel = $connection->channel();
$channel->queue_declare('test_queue', false, true, false, false); // 持久化队列
$msg = new AMQPMessage('Hello from PHP 8.5!', ['delivery_mode' => 2]); // 持久化消息
$channel->basic_publish($msg, '', 'test_queue');
echo "Sent. ";
$channel->close();
$connection->close(); -
消费者（receive.php）：
require_once 'vendor/autoload.php';
use PhpAmqpLibConnectionAMQPStreamConnection;
$connection = new AMQPStreamConnection('localhost', 5672, 'admin', '123456', '/');
$channel = $connection->channel();
$channel->queue_declare('test_queue', false, true, false, false);
$callback = function ($msg) {
echo 'Received: ', $msg->body, " ";
$msg->ack(); // 手动确认，防止丢失
};
$channel->basic_consume('test_queue', '', false, false, true, false, $callback);
while ($channel->is_consuming()) {
$channel->wait();
}
PHP 8.5 特别注意事项
相比老版本，需留意以下几点：
立即学习“PHP免费学习笔记（深入）”；
- 严格类型提示：
php-amqplibv3+ 已全面支持 PHP 7.4+ 类型声明，PHP 8.5 下无兼容问题，但你自己封装类时建议补全返回类型（如function connect(): AMQPStreamConnection） - 弃用警告：避免使用已被 PHP 8.5 标记为废弃的函数（如
create_function），php-amqplib已处理干净 - 错误处理更严格：建议用
try/catch包裹连接和 channel 操作，捕获AMQPRuntimeException等异常 - 不推荐用
amqp.so扩展：该扩展对 PHP 8.5 支持滞后，且配置复杂（需编译、启 extension），php-amqplib纯 PHP 实现更稳、更易调试
