Skip to content

配置文件处理

本文演示如何用 CyberGo JSON 处理典型的配置文件场景:加载、读取嵌套值、修改、保存,以及合并默认配置与用户配置。

配置文件的完整生命周期

加载配置 → 读取嵌套值 → 修改 → 保存回文件 → 重载验证。示例使用临时文件确保可独立运行。

go
package main

import (
    "fmt"
    "os"
    "path/filepath"

    "github.com/cybergodev/json"
)

func main() {
    // 使用临时目录确保示例可独立运行
    tmpDir, err := os.MkdirTemp("", "cybergo-config-*")
    if err != nil {
        panic(err)
    }
    defer os.RemoveAll(tmpDir)

    configPath := filepath.Join(tmpDir, "config.json")

    // 写入初始配置文件
    initial := `{
        "server": {"host": "0.0.0.0", "port": 8080},
        "database": {"host": "localhost", "port": 5432, "name": "appdb"},
        "logging": {"level": "info"}
    }`
    if err := os.WriteFile(configPath, []byte(initial), 0644); err != nil {
        panic(err)
    }

    // 1. 从文件加载配置
    data, err := json.LoadFromFile(configPath)
    if err != nil {
        panic(err)
    }

    // 2. 读取嵌套值(支持可选默认值参数)
    fmt.Printf("服务地址: %s:%d\n", json.GetString(data, "server.host"), json.GetInt(data, "server.port"))
    fmt.Printf("数据库: %s/%s\n", json.GetString(data, "database.host"), json.GetString(data, "database.name"))
    fmt.Printf("日志级别: %s\n", json.GetString(data, "logging.level", "info"))

    // 3. 修改配置(修改现有值)
    data, err = json.Set(data, "server.port", 9090)
    if err != nil {
        panic(err)
    }
    data, err = json.Set(data, "logging.level", "debug")
    if err != nil {
        panic(err)
    }

    // 4. 保存回文件(格式化输出)
    if err := json.SaveToFile(configPath, data, json.PrettyConfig()); err != nil {
        panic(err)
    }

    // 5. 重新加载验证修改已持久化
    reloaded, err := json.LoadFromFile(configPath)
    if err != nil {
        panic(err)
    }
    fmt.Printf("重启后端口: %d\n", json.GetInt(reloaded, "server.port"))
    fmt.Printf("重启后日志: %s\n", json.GetString(reloaded, "logging.level"))
}

合并默认配置与用户配置

实际应用中常需将用户配置覆盖到内置默认值上,再补全缺失的嵌套路径。MergeJSON 执行深度合并(用户值优先),SetCreate 会自动创建尚不存在的中间路径。

go
package main

import (
    "fmt"

    "github.com/cybergodev/json"
)

func main() {
    // 默认配置(内置)
    defaults := `{
        "server": {"host": "0.0.0.0", "port": 8080, "timeout": 30},
        "database": {"host": "localhost", "port": 5432, "pool": 10},
        "logging": {"level": "info", "format": "json"}
    }`

    // 用户配置(覆盖部分字段)
    userConfig := `{
        "server": {"port": 3000},
        "database": {"host": "db.prod.example.com"},
        "logging": {"level": "debug"}
    }`

    // 深度合并:用户配置覆盖默认值,默认值中未被覆盖的字段保留
    merged, err := json.MergeJSON(defaults, userConfig)
    if err != nil {
        panic(err)
    }
    fmt.Printf("端口: %d(用户覆盖)\n", json.GetInt(merged, "server.port"))
    fmt.Printf("超时: %d(默认保留)\n", json.GetInt(merged, "server.timeout"))
    fmt.Printf("数据库: %s:%d\n", json.GetString(merged, "database.host"), json.GetInt(merged, "database.port"))

    // 用 SetCreate 添加尚不存在的嵌套路径(自动创建中间对象)
    merged, err = json.SetCreate(merged, "features.metrics.enabled", true)
    if err != nil {
        panic(err)
    }
    merged, err = json.SetCreate(merged, "features.metrics.endpoint", "/metrics")
    if err != nil {
        panic(err)
    }

    fmt.Printf("指标开关: %v\n", json.GetBool(merged, "features.metrics.enabled"))
    fmt.Printf("指标端点: %s\n", json.GetString(merged, "features.metrics.endpoint"))
}
// 输出:
// 端口: 3000(用户覆盖)
// 超时: 30(默认保留)
// 数据库: db.prod.example.com:5432
// 指标开关: true
// 指标端点: /metrics

提示

MergeJSON 是深度递归合并:对象键逐层合并,数组和标量值直接替换。需要合并多个配置源时可用 MergeMany([]string{...}) 一次性合并。

下一步