PHP通过STOMP扩展连接ActiveMQ收发消息：先安装stomp扩展并配置php.ini，再用new Stomp('tcp://host:61613')连接，调用send()发送、subscribe()订阅、readFrame()读取消息，注意ack模式与持久化header设置。
PHP怎么连接ActiveMQ收发消息
PHP本身不内置ActiveMQ支持，必须依赖第三方协议实现——最常用的是STOMP协议（Simple Text Oriented Messaging Protocol），ActiveMQ原生支持，PHP用stomp扩展或纯Socket+STOMP手动实现均可。优先选stomp扩展，它封装了连接、订阅、发送等逻辑，避免手写帧格式出错。
常见错误现象：Connection refused（没开STOMP端口）、Invalid frame（换行符用\r\n不对）、订阅后收不到消息（没调用readFrame()轮询或没设ack模式）。
- 确认ActiveMQ已启用STOMP：检查
conf/activemq.xml里<transportConnector name="stomp" uri="stomp://0.0.0.0:61613"/>是否开启 - PHP需安装
stomp扩展：pecl install stomp，并在php.ini中添加extension=stomp - 连接时用户名密码默认是
admin/admin，若改过需显式传入：new Stomp('tcp://localhost:61613', 'user', 'pass') - STOMP 1.2协议要求所有帧结尾用
\n，但PHP扩展内部已处理，不用手动拼接；若用cURL或fsockopen手写，必须严格用\n而非\r\n，否则ActiveMQ直接断连
PHP读取消息为什么收不到或重复消费
STOMP默认是auto应答模式，消息一送达就自动ACK，如果PHP处理中途崩溃，消息就丢了；而client模式需要显式调用ack()，否则消息会一直留在队列，下次重连还会收到——这是“重复消费”的根源。
- 订阅时必须指定
ack方式：$stomp->subscribe('/queue/test', ['ack' => 'client']) - 收到
StompFrame后，必须在业务逻辑成功执行完再调用$stomp->ack($frame)，且要传入原始帧对象（不能只传msg-id） - 若用
client-individual，每条消息需单独ack，适合严格顺序或幂等处理场景 - 注意超时：ActiveMQ默认
consumer.prefetchSize=1000，PHP客户端一次拉太多消息又不及时ack，会导致其他消费者饿死；生产环境建议调低，如['prefetch-size' => '1']
PHP发消息到ActiveMQ要注意哪些格式细节
ActiveMQ对STOMP消息体不做解析，但某些header会影响路由和持久化。PHP用$stomp->send()时，header传错一个字母就可能让消息进错队列或被丢弃。
立即学习“PHP免费学习笔记（深入）”；
- 目标地址必须带前缀：
/queue/name或/topic/name，漏掉/queue/会发到临时队列，没人能订 - 需要持久化必须加
persistent: trueheader，否则Broker重启消息全丢 - 消息体如果是JSON，建议显式声明
content-type: application/json，方便下游识别；但ActiveMQ不校验，只是约定 - 避免在body里放不可见字符（如BOM头），PHP读文件或
json_encode()后直接send容易带\u{feff}，导致消费者解析失败
有没有更轻量的替代方案，不用装扩展
如果无法安装stomp扩展（如共享主机），可用fsockopen手写STOMP客户端，但仅限简单场景。复杂逻辑（重连、心跳、事务）极易出错，不建议长期使用。
示例片段（发送一条消息）：
$fp = fsockopen('localhost', 61613, $errno, $errstr, 5);
if (!$fp) die("Connect failed: $errstr ($errno)");
fwrite($fp, "CONNECT\nlogin:admin\npasscode:admin\n\n\x00");
// 等待CONNECTED响应...
fwrite($fp, "SEND\ndestination:/queue/test\n\nHello World\x00");
fclose($fp);
关键点：每行结尾是\n，帧结束必须是\x00（ASCII NULL），不是字符串"\0"；CONNECT后必须读取CONNECTED帧才能发消息，否则会被拒绝。
真正麻烦的不是发消息，而是处理ERROR帧、心跳保活、连接断开重试——这些stomp扩展都做了，手写容易忽略。
