Phalcon 中需用 pda/pheanstalk 库替代已移除的官方 Beanstalk 驱动，通过封装服务、CLI 初始化连接、json 序列化任务、reserve/delete 保障可靠消费。
Phalcon 中怎么配 Beanstalkd 队列驱动
Phalcon 本身不内置 Beanstalkd 支持，Queue\Adapter\Beanstalk 是社区补丁或第三方扩展，官方 Phalcon\Queue\Adapter\Beanstalk 在 4.x+ 已移除。你实际要用，得自己封装或借助 pda/pheanstalk 库对接。
常见错误现象：Class 'Phalcon\Queue\Adapter\Beanstalk' not found —— 这不是你 autoload 没配好，是类根本不存在于现代 Phalcon 版本中。
- 用 Composer 装
pda/pheanstalk：composer require pda/pheanstalk - 别依赖 Phalcon 的 Queue 组件，直接 new
Pheanstalk\Pheanstalk实例 - 连接参数注意：默认端口是
11300，不是6379或3306；超时建议设5秒防卡死 - Phalcon 项目里推荐封装成服务（如
BeanstalkService），避免在控制器里直连
怎么往 Beanstalkd 里推一个后台任务
核心就两步：连接 + put。但容易漏掉序列化控制和优先级误设。
使用场景：发邮件、生成报表、清理日志等不需即时响应的操作。
立即学习“PHP免费学习笔记（深入）”；
-
put()第二个参数是$priority，默认1024，数值越小优先级越高 —— 别写成时间戳当 priority - 任务数据必须是字符串，
json_encode()最稳；别直接serialize()，PHP 版本不一致时可能反序列化失败 - 示例：
$pheanstalk->useTube('email')->put(json_encode(['to' => 'a@b.c', 'template' => 'welcome'])); - 如果任务体过大（>64KB），Beanstalkd 会拒绝，得先压缩或拆分逻辑
Worker 怎么从 Beanstalkd 拉任务并执行
关键不是“怎么取”，而是“取完怎么确保不丢”——Beanstalkd 是 at-least-once，没 delete() 就会重发。
常见错误现象：任务反复执行、日志里看到一堆 bury 或 release 记录。
- 必须用
reserve()（带超时），别用watch()+reserve()套娃，容易阻塞 - 执行成功后立刻
delete()；失败则根据情况bury()（永久下架）或release()（放回队尾，可设延迟） - 别在
try/catch外层包整个reserve循环，否则异常会导致进程退出，任务悬空 - worker 脚本建议加
pcntl_signal()捕获SIGTERM，优雅退出前处理完当前任务
Phalcon 项目里怎么让队列和 DI 容器协同
重点不是“能不能注入”，而是“什么时候初始化、谁负责销毁”。Beanstalk 连接不能复用跨请求，但也不能每次 new 都重连。
性能影响：每个 worker 进程启动时建立一次长连接即可，fork 后子进程继承 socket fd，不用重复 connect。
- 在 CLI 启动脚本里（比如
worker.php）newPheanstalk\Pheanstalk并 set 到 DI：$di->set('beanstalk', function() { return new \Pheanstalk\Pheanstalk('127.0.0.1'); }); - 别在 HTTP 请求生命周期里注册 Beanstalk 服务，Web 请求不该触发队列消费
- worker 进程里不要用
$application->getDI()获取 Web 环境 DI，CLI 和 Web 的 DI 是两套 - 如果用 Supervisor 管理 worker，确保
autostart=true和startsecs=5，避免启动太快没拉到配置
Beanstalkd 的 tube、job ID、reserve 超时这些细节，改错一个就可能让任务积压或静默丢失。调通第一单之前，先 telnet 手动 put 和 reserve 试一遍链路。
