PHP需安装stomp扩展（非内置），连接STOMP服务器后用subscribe()监听队列/主题，hasFrame()轮询读取消息并ack；发送时须带content-type等headers，destination路径需含/queue/或/topic/前缀。
PHP怎么用stomp扩展读取STOMP消息
PHP本身不内置STOMP支持，必须依赖stomp扩展（C扩展），不是纯PHP库。没装扩展就调用new Stomp()会直接报错Fatal error: Class 'Stomp' not found。
确认已启用扩展：php -m | grep stomp；若无输出，需编译安装或启用extension=stomp.so（Linux/macOS）或extension=php_stomp.dll（Windows）。
连接 ActiveMQ 或 RabbitMQ 的 STOMP 端口（如tcp://localhost:61613）后，用subscribe()监听队列或主题：
$stomp = new Stomp('tcp://localhost:61613');
$stomp->subscribe('/queue/test');
while ($stomp->hasFrame()) {
$frame = $stomp->readFrame();
echo $frame->body . "\n";
$stomp->ack($frame); // 若启用了 client ack
}
- 注意
hasFrame()是阻塞式轮询，实际项目中建议加usleep(10000)防CPU空转 - 若服务端发送的是 JSON，
$frame->body是原始字符串，需手动json_decode() - 使用 topic 时路径为
/topic/news，且默认不支持持久订阅（需服务端配置+设置activemq.subscriptionName头）
PHP怎么用stomp扩展发送STOMP消息
发送比接收简单，但容易忽略头部控制。最简写法：$stomp->send('/queue/test', 'hello')，但这样发出去的消息没有content-type，某些服务端（如 ActiveMQ 5.16+）会拒绝或降级处理。
立即学习“PHP免费学习笔记（深入）”；
推荐显式传入headers数组，尤其当 payload 是 JSON 时：
$headers = [
'content-type' => 'application/json',
'persistent' => 'true'
];
$stomp->send('/queue/test', json_encode(['id' => 123]), $headers);
-
destination必须带前缀：/queue/xxx或/topic/xxx，漏掉斜杠会连错目标 - 若要让消息被持久化（重启 Broker 后仍存在），必须加
persistent => true头，且 Broker 需开启持久化策略 - 大消息（>1MB）可能触发 Broker 限制，RabbitMQ 默认
frame_max=131072，需同步调大客户端stomp.max_frame_size配置（PHP INI）
为什么stomp扩展收不到消息或连接超时
常见原因不是代码写错，而是网络或 Broker 配置层面卡住。先排除Connection refused类错误——它往往意味着 STOMP 端口根本没开，或防火墙拦截。
ActiveMQ 默认只启用 OpenWire 协议，STOMP 需在conf/activemq.xml里显式打开：<transportConnector name="stomp" uri="stomp://0.0.0.0:61613"/>；RabbitMQ 则需启用stomp插件：rabbitmq-plugins enable rabbitmq_stomp。
- PHP 连接时若用
localhost而 Broker 绑定127.0.0.1，在某些 Docker 场景下会失败，改用127.0.0.1更稳 - Broker 日志（如
data/activemq.log）里搜STOMP或connect能快速定位握手是否成功 -
stomp扩展不支持 TLS/SSL 直连（如stomp+ssl://），必须走代理或换用stomp-php等纯 PHP 库
不用stomp扩展，有没有更轻量的替代方案
有，但得接受 trade-off。stomp-php（composer require stomp-php/stomp-php）是纯 PHP 实现，支持 SSL、异步（配合 ReactPHP）、自动重连，但性能弱于 C 扩展，且对复杂 header 处理稍繁琐。
最小可用示例：
$client = new \Stomp\Client('tcp://localhost:61613');
$client->connect();
$client->send('/queue/test', 'hello', ['content-type' => 'text/plain']);
- 它把
ack/nack封装成方法，不用手动构造 frame，适合快速原型 - 不依赖系统扩展，Docker 多环境部署更省心，但要注意 Composer 自动加载和 PSR-4 兼容性
- 遇到
Broken pipe或Connection reset时，它默认不重试，需自己 wraptry/catch+ 重连逻辑
真正难的从来不是“怎么发”，而是消息体编码一致性、ACK 时机控制、以及 Broker 端 queue TTL 和死信队列联动——这些细节不贴着生产环境调，光看文档永远踩坑。
