bootstrap

Overview ¶

Package bootstrap 定义组件化启动编排。

本文件提供组件化 API，替代旧的硬编码 Run(Config, userFn)。 组件化 API 让 metrics、tracing、NNS 等启动步骤可插拔、可替换、可测试。

旧 API Run(Config, userFn) 保留为兼容入口，内部委托至组件化实现。

Package bootstrap 提供 ekit 微服务的启动编排。

统一管理：Prometheus 指标 → OpenTelemetry 追踪 → NNS 服务注册/发现 → 健康检查 → 优雅关闭。

快速接入 ¶

1. 定义配置结构（嵌入 nacos.Bootstrap）：

type AppConfig struct {
    Port    int             `yaml:"port"`
    Nacos   nacos.Bootstrap `yaml:"nacos"`
    Tracing tracing.Config  `yaml:"tracing"`
    // 业务配置...
}

2. 启动服务：

func main() {
    cfg, _ := config.LoadBootstrap[AppConfig]("dev")
    bootstrap.Run(bootstrap.Config{
        ServiceName: "my-service",
        Port:        cfg.Port,
        Nacos:       cfg.Nacos,
        Tracing:     &cfg.Tracing,
    }, func(app *bootstrap.App) error {
        h := server.New(server.WithHostPorts(fmt.Sprintf(":%d", cfg.Port)))
        app.AddResource("hertz", func(ctx context.Context) error { return h.Shutdown(ctx) })
        health.RegisterHealthRoutes(h)
        // 注册业务路由...
        return h.Run()
    })
}

多 Server 场景 ¶

启动多个 HTTP server，通过 AddResource 注册关闭函数（逆序执行）：

bootstrap.Run(bootstrap.Config{
    ServiceName: "gateway",
    Nacos:       cfg.Nacos,
    DepServices: []string{"user-service", "order-service"},
}, func(app *bootstrap.App) error {
    admin := server.New(server.WithHostPorts(":8081"))
    gw := server.New(server.WithHostPorts(":8080"))

    app.AddResource("gateway", func(ctx context.Context) error { return gw.Shutdown(ctx) })
    app.AddResource("admin", func(ctx context.Context) error { return admin.Shutdown(ctx) })

    go admin.Run()
    return gw.Run()
})

启动顺序 ¶

1. Prometheus 指标注册
2. OpenTelemetry 追踪初始化（可选）
3. NNS 客户端初始化 + 服务注册（可选）
4. 创建 App，执行 userFn(app)
5. 监听 SIGINT/SIGTERM 信号
6. 优雅关闭（App 资源 → 追踪 flush → NNS 注销）