讲师中心 微信公众号
AI工具推荐 视频效率加速

Hyperf 3.0 异步队列延迟任务实现指南【技巧】

胖涛吖_9458

胖涛吖_9458

发布时间:2026-08-09 14:58:05

|

997人浏览过

|

来源于php中文网

原创

Hyperf 3.0中实现延迟任务需严格配置Redis ZSet驱动、毫秒级score_precision、原子Lua脚本扫描及独立进程,否则多Worker下必重复消费。

hyperf 3.0 异步队列延迟任务实现指南【技巧】

在Hyperf 3.0中实现订单超时自动关闭、短信延后发送等延迟任务,不能只靠配置文件改个参数就完事——ZSet的score必须是整型绝对时间戳,member必须可反序列化且带唯一标识,扫描逻辑必须用Lua脚本原子执行“取+删”,否则多Worker下必然重复消费。

确认异步队列组件已安装并启用

执行composer require hyperf/async-queue安装组件。若项目未生成配置文件,运行php bin/hyperf.php vendor:publish hyperf/async-queue生成config/autoload/async_queue.php

检查config/autoload/processes.php是否已注册消费者进程:Hyperf\AsyncQueue\Process\ConsumerProcess::class。没加这行,任务永远不消费。

配置延迟队列驱动为Redis ZSet

修改config/autoload/async_queue.php,将driver替换为Hyperf\DelayQueue\Driver\RedisDriver::class

新增delay队列配置块,注意score_precision必须设为0.001(毫秒级精度),否则$delay参数单位会错乱:【$delay传入秒数时,score_precision=0.001才对应毫秒级写入】

示例配置:

'delay' => [
  'driver' => Hyperf\DelayQueue\Driver\RedisDriver::class,
  'queue_name' => 'order:delay:close',
  'score_precision' => 0.001,
  'retry_seconds' => 60,
  'max_attempts' => 3,
],

Hyperframes Creative
Hyperframes Creative

HyperFrames视频非动画创意指导,包括设计规范(frame.md/design.md)处理、配色、字体设计、旁白及节奏规划等。

下载

创建延迟任务类并投递

新建app/Job/OrderCloseJob.php,继承Hyperf\DelayQueue\Job而非普通AsyncQueue\Job。

在handle()方法里写实际业务逻辑,比如查订单状态、调关单接口、发通知。

投递时调用$this->container->get(DelayQueue::class)->push(new OrderCloseJob($orderId), $delay),其中$delay单位为,但底层会乘以1000转成毫秒写入ZSet——前提是score_precision=0.001已生效。

启动独立扫描进程避免多Worker争抢

第一步:禁用默认ConsumerProcess对delay队列的监听,防止它错误消费ZSet数据。

第二步:新建app/Process/DelayQueueScanProcess.php,使用Swoole定时器每5秒触发一次扫描。

第三步:在scan逻辑中,先用setnx delay_queue:scan_lock 1加分布式锁,设置过期时间10秒;抢到锁后,执行Lua脚本eval($luaScript, 1, $key, $nowMs)完成原子取删;完成后del锁。

第四步:Lua脚本必须严格按规范写——zRangeByScore的min设为0而非-inf,避免Redis解析开销;返回值为空时立即return,不要空跑。

热门AI工具

更多
豆包大模型

豆包大模型是一款由字节跳动推出的企业级大语言模型服务平台。

VibeKnow
VibeKnow Hot

一款AI视频创作工具,主要用于全球首个AI知识视频创作平台,文档、文章、网页,一键生成视频,适合需要提升相关任务效率的用户。

讯飞绘文

讯飞绘文是一款由科大讯飞推出的一站式 AIGC 内容运营平台。

音述AI
音述AI Hot

一款AI音频处理工具,主要用于音述AI是一个以“用声音述说故事”为核心的 AI 音乐创作与声音分享社区,适合需要提升相关任务效率的用户。

DeepSeek

DeepSeek是一款面向对话、写作、编程和推理场景的AI大模型工具。

Loomy
Loomy Hot

一款AI工具,主要用于科大讯飞发布的桌面级 AI 助理,比 OpenClaw 更易用、更安全!,适合需要提升相关任务效率的用户。

蛙蛙写作

一款AI论文写作工具,主要用于超级AI智能写作助手,适合需要提升相关任务效率的用户。

讯飞智作

讯飞智作是一款AI视频创作工具,AI文本配音工具,数字人课程、营销视频制作。

WorkBuddy

一款AI办公效率工具,主要用于腾讯云推出的AI原生桌面智能体工作台,适合需要提升相关任务效率的用户。

相关专题

更多
Hyperf协程并发编程实操指南
Hyperf协程并发编程实操指南

本专题深度解析 Hyperf 协程底层机制,解决协程环境下全局变量污染、Context 上下文丢失等核心痛点,提供规范化的 PHP 高并发编程实战代码建议。

160

2026.05.19

深入理解Hyperf AOP切面与注解使用
深入理解Hyperf AOP切面与注解使用

详尽介绍 Hyperf 依赖注入容器与 AOP 面向切面编程的使用技巧,包含自定义注解开发流程及注解不生效的排查方案,助力开发者掌握框架核心架构。

404

2026.05.19

Hyperf 数据库操作与连接池优化方案
Hyperf 数据库操作与连接池优化方案

针对 Hyperf Eloquent 模型在大数据量下的表现进行深度优化,讲解连接池断线重连、超时设置及事务处理等生产环境常见技术疑难。

184

2026.05.19

基于 Hyperf 的微服务架构集成实战
基于 Hyperf 的微服务架构集成实战

本专题涵盖 Hyperf 微服务全栈解决方案,包括服务注册与发现、配置中心集成、JsonRPC 调用以及分布式限流熔断的落地实践。

196

2026.05.19

Hyperf 高并发缓存与分布式系统应用
Hyperf 高并发缓存与分布式系统应用

讲解在协程模式下如何高效操作 Redis,实现高性能分布式锁、处理缓存击穿/雪崩问题,并提供基于 Hyperf 的分布式事务处理思路。

388

2026.05.19

Hyperf 项目部署运维与性能调优手册
Hyperf 项目部署运维与性能调优手册

聚焦 Hyperf 在生产环境的落地,包含 Docker 高效打包、Swoole 配置优化、常见的内存溢出(OOM)问题排查方法以及热更新方案。

365

2026.05.19

Hyperf PHP 微服务框架高性能开发实战
Hyperf PHP 微服务框架高性能开发实战

本专题围绕 Hyperf 框架展开,讲解微服务架构设计、协程异步处理、服务注册与发现、RPC 通信及性能优化策略。通过完整项目示例,帮助开发者构建高效、稳定、可扩展的 PHP 分布式服务系统。

156

2026.06.08

Aionclaw智能助手介绍
Aionclaw智能助手介绍

本专题汇总了AionClaw(AI龙虾助手)的功能介绍与在线使用入口。AionClaw是杭州趣猿人工智能有限公司推出的桌面级AI智能体,能直接在电脑上读写文件、运行脚本、操作浏览器,自动交付Word、PPT、Excel等成品。

20

2026.09.20

AionClaw AI智能体与电脑自动化任务执行功能使用教程
AionClaw AI智能体与电脑自动化任务执行功能使用教程

AionClaw专题整理AI智能体与电脑自动化相关功能使用教程,涵盖安装部署、AI任务执行、Skills技能、文件处理、浏览器控制、电脑操作、持久记忆、聊天工具连接以及办公、编程和内容创作等功能,帮助用户快速掌握AionClaw的实际使用方法。

0

2026.09.20

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Hyperf官方中文手册(3.1)
Hyperf官方中文手册(3.1)

共0课时 | 0人学习

Swoole系列-从0到1-新手进阶
Swoole系列-从0到1-新手进阶

共29课时 | 2.2万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn