基于 Redis 的高性能 PHP 队列处理系统,采用生产者-消费者模式,支持多 Worker 并发处理,为您的业务提供稳定可靠的异步任务处理能力
专为网课订单处理设计,提供完整的订单生命周期管理
基于 Redis 队列实现,支持阻塞式出队,毫秒级响应,轻松应对高并发场景
内置分布式锁机制,防止订单重复处理,确保数据一致性
Web 管理界面实时查看队列状态、处理日志,支持一键操作
智能失败检测,支持自动重试机制,最大程度保证任务成功执行
完善的进程管理器,支持启动、停止、重启、状态监控等操作
全链路日志记录,支持按日期分割,便于问题排查和数据分析
采用经典的生产者-消费者模式,解耦业务逻辑,提升系统稳定性
订单数据
生产者入队
队列存储
消费者处理
渠道对接
五大核心队列,覆盖订单处理全流程
| 队列名称 | 功能说明 | 触发条件 | 处理动作 |
|---|---|---|---|
| addoid | 新订单提交 | dockstatus = 0 | 调用 addWk() 提交到渠道 |
| oids | 状态同步 | dockstatus = 1/2/3 | 调用 processCx() 查询状态 |
| shibaioids | 失败重试 | dockstatus = 2 | 重新调用 addWk() 提交 |
| csoid | 补刷处理 | status = '待重刷' | 调用 budanWk() 补刷 |
| oidblpt | 待更新同步 | status = '待更新' | 调用 processCx() 同步 |
一行命令,轻松部署
# 下载安装脚本并执行 curl -fsSL https://io.okjia.icu/shell_v2/install.sh | bash # 或者使用 wget wget -qO- https://io.okjia.icu/shell_v2/install.sh | bash # 启动服务 cd shell_v2 && ./pm start # 查看状态 ./pm status
购买授权或遇到问题?通过以下方式联系我们
扫码添加微信购买授权
加入QQ群获取技术支持
与其他用户交流经验
点击复制群号