需显式调用config.NewFromYaml("machinery.yaml")初始化配置，确保broker和result_backend协议完整、default_queue无空格、Redis配置pool_size；任务函数签名必须为func(...interface{}) error；延迟任务用ETA时间戳，重试需手动设RetryCount与RetryTimeout；worker不消费多因broker连接或队列绑定失败。
怎么初始化 machinery 配置并加载 YAML 文件
machinery 不会自动读配置，必须显式调用 config.NewFromYaml 或 config.NewFromEnvironment。YAML 是最常用方式，但路径错误、字段名拼错、缩进不规范都会导致静默失败（比如 broker 为空却没报错，worker 启动后卡在 “waiting for tasks”）。
- 配置文件必须是
machinery.yaml（默认名），或传入完整路径；config.NewFromYaml("conf/machinery.yaml") - YAML 中的
broker和result_backend必须协议完整，redis://123456@localhost:6379✅，localhost:6379❌（machinery 不补协议） -
default_queue值不能含空格或特殊字符，否则 AMQP 模式下会报AMQP queue name invalid - 如果用了 Redis，建议同时配
redis子段（如redis: pool_size: 20），否则默认连接池仅 5，高并发时任务积压明显
如何注册和发送一个带参数的异步任务
任务函数签名必须严格为 func(...interface{}) error，返回值只能是 error；任何其他签名（比如返回 string 或多值）都会在 server.RegisterTask 时 panic，但错误信息模糊（只提示 “invalid task signature”）。
- 注册任务：先定义函数，再用
server.RegisterTask("send_email", sendEmail)；函数名字符串要和后续调用一致 - 发送任务：用
tasks.SendTaskWithContext，传入signature，参数必须是可序列化类型（string,int,map[string]interface{}等），struct{}要加jsontag 否则字段丢失 - 常见坑：
time.Time直接传会序列化失败，改用time.Unix()或字符串格式；nil切片会被转成null，worker 收到后得判空
延迟任务和重试逻辑怎么写才可靠
machinery 的延迟靠 ETA 字段（Unix 时间戳），不是“延后 N 秒”，容易误用成相对时间导致任务立刻执行或永远不触发；重试则依赖 RetryCount + RetryTimeout，但默认不开启，必须手动设。
Golang Uber Dig
下载
使用 uber-go/dig 在 Golang 中实现依赖注入——基于反射容器，提供 Provide/Invoke、dig.In/dig.Out 参数与结果对象，支持命名依赖等
- 延迟任务：用
&tasks.Signature{ETA: time.Now().Add(5 * time.Minute).Unix(), ...}；别用Delay方法（v1 不支持，那是 v2 的 API） - 重试：在
Signature中设置RetryCount: 3和RetryTimeout: 60（单位秒），否则即使任务 panic，也不会重试 - 注意：重试期间若 worker 重启，未完成重试的任务会丢失——因为 machinery 默认不持久化重试状态，只靠 broker 保活；如需强保障，得自己加幂等 key + Backend 查询
为什么 worker 启动后不消费任务？常见连通性陷阱
90% 的“worker 不干活”问题出在 broker 连接或队列绑定上，而不是代码逻辑。machinery 日志默认极简，不报连接失败细节，得手动开 debug 日志或抓网络包验证。
立即学习“go语言免费学习笔记（深入）”；
- 检查 Redis：用
redis-cli -a 123456 -p 6379 ping确认密码和端口；若用哨兵，broker必须写redis+sentinel://...，普通 redis 地址连不上 - 检查 AMQP：
binding_key和exchange必须与 producer、worker 完全一致；RabbitMQ 里对应 exchange 是否存在？权限是否允许 consumer 绑定队列？ - 启动命令必须指定
-c machinery.yaml（或环境变量），否则用的是空配置，broker为空，worker 会静默跳过所有逻辑
真正麻烦的不是语法，是 broker 和 backend 的权限、网络策略、TLS 设置这些外部依赖；本地跑通不等于上线可用，K8s 里 DNS 解析失败、Sidecar 拦截、Redis ACL 限制都可能让任务突然“消失”。
