PHP用Redis Streams发消息前需确保连接正常，XADD自动创建stream但须检查返回值；ID用*自动生成时间戳序列，消息体为关联数组，消费组须先XGROUP CREATE，处理后必须XACK，定期XTRIM防膨胀，进程退出前应close连接。
PHP用redis->xadd()发消息前必须设好stream名和id
Redis Streams不是自动创建的，XADD命令执行时如果目标stream不存在，Redis会自动建，但PHP里得确保redis扩展已启用且连接正常。常见错误是直接调$redis->xadd('my_stream', '*', ['event' => 'login'])却没检查返回值——失败时它返回false，不是抛异常。
-
*作为id参数表示让Redis自动生成时间戳+序列ID（如1718234567890-0），手动指定需符合timestamp-ms-sequence格式，否则报错ERR Invalid stream ID specified as stream command argument - PHP Redis扩展v5.3.4+才完整支持Streams命令；旧版本调
xadd会提示Unknown command - 消息体必须是关联数组，键值都转为字符串；传
object或resource会导致serialize()失败，最终存入的是空字段
消费组模式下redis->xreadgroup()要先xgroup create
想用消费组（Consumer Group）做多实例负载均衡，不能跳过XGROUP CREATE。PHP里没有封装xgroup的独立方法，得用rawCommand()或升级到phpredis v6.0+（支持$redis->xgroup('CREATE', ...)）。
- 创建消费组示例：
$redis->rawCommand('XGROUP', 'CREATE', 'mystream', 'mygroup', '$', 'MKSTREAM')——$表示从最新消息开始，MKSTREAM确保stream存在 - 读取消息用
$redis->xreadgroup('mygroup', 'consumer1', ['mystream' => '>'], 1)，其中'>'代表只取未分配的新消息；若填0会重读所有待处理消息 - 忘记调
XACK会导致消息一直留在PENDING列表，下次XREADGROUP仍可能分发给同一消费者，造成重复处理
用redis->xtrim()防stream无限膨胀很关键
Streams默认不删老数据，DEL整个key又会丢掉消费组元信息。必须定期XTRIM，PHP里对应$redis->xtrim('mystream', 1000)表示最多保留1000条。
-
xtrim的第二个参数是maxlen，不是字节数；Redis 6.2+支持~近似修剪（如['MAXLEN', '~', 1000]），性能更好，但phpredis需v5.3.7+才识别该语法 - 不要在高并发写入时频繁调
xtrim，它会阻塞；建议用XLEN定时检查长度，超阈值再trim一次 - 消费组中已确认（
XACK）的消息，XTRIM不会动它们；只有未确认的老消息可能被裁掉，所以trim前要确保消费逻辑健壮
PHP进程退出前务必调redis->close()释放连接
长运行的worker（比如用pcntl_fork()启多个子进程消费）如果没显式关Redis连接，连接数会持续增长，最终触发Redis的maxclients限制，新请求卡住。
- CLI脚本建议用
register_shutdown_function()兜底：register_shutdown_function([$redis, 'close']) - 使用
phpredis的连接池（如predis/predis）时，close()行为不同——它只是归还连接，不是断开，这点和原生扩展有差异 - 消息处理中遇到致命错误（如
Fatal error: Out of memory），shutdown函数不触发，所以关键路径上最好在try/catch末尾也补一句$redis->close()
实际部署时，stream的id精度、消费组的pending状态清理、以及trim策略和业务吞吐量的匹配，比语法本身更花时间调优。
php免费学习视频：立即使用
踏上前端学习之旅，开启通往精通之路！从前端基础到项目实战，循序渐进，一步一个脚印，迈向巅峰！
