用 map[string]func() Parser 实现协议解析器工厂，各协议包在 init() 中注册闭包以延迟初始化，NewParser 根据协议名查表并调用闭包创建实例，避免提前加载副作用；协议包仅依赖 registry 包，通过匿名导入触发注册，错误需分层处理。
怎么用 Go 实现协议解析器的简单工厂
直接上核心：用一个 map[string]func() Parser 做注册表，配合接口和构造函数，就能让不同协议（比如 http、mqtt、coap）的解析器按需加载，不耦合具体实现。
关键不是“写个工厂类”，而是控制「谁注册」「谁调用」「注册时机」——Go 没有类，但包级变量 + init() 函数就是天然注册点。
-
Parser接口定义统一输入输出，比如Parse([]byte) (interface{}, error) - 每个协议包在自己的
init()里往全局parserRegistrymap 里塞一个闭包，比如func() Parser { return &HTTPParser{} } - 工厂函数
NewParser(proto string)只查 map、调用闭包、返回实例，不 import 具体协议包
为什么必须用闭包注册，不能直接存结构体指针
因为要避免初始化时就触发协议解析器的副作用（比如加载证书、连接默认 broker、初始化缓冲池）。闭包延迟执行，真正 Parse() 前才 new 实例。
常见错误是写成 registry["http"] = &HTTPParser{}，结果所有协议包一导入就 panic：证书路径为空、DNS 解析失败、甚至阻塞在 TCP dial 上。
立即学习“go语言免费学习笔记（深入）”；
使用 uber-go/dig 在 Golang 中实现依赖注入——基于反射容器，提供 Provide/Invoke、dig.In/dig.Out 参数与结果对象，支持命名依赖等
- 闭包写法：
registry["http"] = func() Parser { return &HTTPParser{timeout: 5 * time.Second} } - 结构体直传会提前初始化，且无法传参定制，比如不同环境需要不同
timeout或maxBodySize - 如果解析器依赖 config，闭包里可以捕获当前包的配置变量，比传参更轻量
如何避免 init 循环和 import 冲突
协议包不能互相 import，否则 init() 顺序不确定，map 注册可能漏掉或 panic。必须靠主程序或中间 registry 包来协调。
典型坑：A 协议包 import B，B 又 import A，为共享某个 ErrInvalidHeader 错误；结果编译报 import cycle not allowed，或者运行时 parserRegistry 是 nil。
- 所有协议包只 import 主 registry 包（比如
github.com/your/app/parsers），不互相引用 - 错误类型、公共常量、基础结构体统一放在
parsers包里，协议包只实现逻辑 - 主程序的
main.go不 import 任何协议包——它们通过_ "xxx/http"方式匿名导入，触发init()即可
加载失败时该返回什么错误
别返回 nil 加 fmt.Errorf("unknown protocol %s", proto) 就完事。调用方需要区分「协议名错」和「协议已注册但构造失败」。
比如 mqtt 解析器依赖 go-mqtt 库，若其 NewClient() 失败，这个错误应该透出，而不是吞掉变成 “unknown protocol”。否则排查时永远卡在配置名拼写上。
- 工厂函数返回
(Parser, error)，error 类型建议用自定义ParserInitError包裹底层 err - 注册闭包里做最小初始化（如检查必要字段），失败就 panic —— 这属于启动期错误，必须暴露
- 运行时 Parse 阶段的错误（如 malformed JSON）和加载期错误（如 TLS config 缺失）必须分层，别混成一个
error
最麻烦的是调试时发现某个协议没注册上，但日志没报错——大概率是那个协议包没被匿名 import，或者 init() 里 panic 被 recover 了。这种地方没法自动检测，得靠测试覆盖注册表长度。
