Repository navigation
v0.1.0 — 首个公开版本
首个公开版本,面向 PHP 8.2+、ThinkPHP 8、Redis 6.2+。消费者需要 phpredis >=6.0 与 CLI pcntl。
功能:
- 即时/延迟投递、手动确认、主动重投、指数退避及随机抖动。
- Pending 超时接管、处理权校验、最终失败记录及重放。
- 消费端协议校验与坏消息隔离,缺失消息体不会阻塞正常任务。
- 原子活跃任务容量与消息字节限制。
- queue:stats、消费者心跳、记录清理预览及空消费者维护。
- EVALSHA/NOSCRIPT 回退、维护调度和连接初始化读取超时。
验证:PHP 8.2/8.3/8.4 × Redis 6.2/7.4 六组 CI 全部通过,每组 42 项测试、222 个断言。覆盖多进程竞争、SIGKILL 恢复、任务超时、ACK 响应丢失、坏消息及连接初始化异常。
安装:
composer require panda-men/think-queue-stream:^0.1若 Composer 仓库尚未收录该包,请按 README 添加 GitHub VCS 仓库后安装。
范围与约定:单消费组任务队列,按至少一次投递设计,业务操作需要幂等;默认单条消息上限 1 MiB,max_active_jobs 默认不限。当前不包含广播、多消费组、管理后台、RedisCluster 或自动续租,也不是 topthink/think-queue 的完全兼容替换。