apollo

介绍

基于携程apollo的go客户端

功能

• 动态实时更新通知 通过Watch订阅对应的namespace变更，当有变更时，保证推送一次给业务
• 支持默认值 当配置值无法获取时，支持业务配置的默认值
• 支持灰度发布 自动获取业务本地ip，当apollo配置中心配置了灰度，会获取灰度配置
• 支持自定义认证和自定义http请求参数
• 支持多namespace 支持watch多个namespace
• 支持多格式 支持properties,yaml,json等格式
• 支持本地文件备份 当配置中心出现问题时，通过备份文件加载
• 支持notification方式更新
• 支持自定义日志组件

TODO

• 支持负载均衡
• 支持获取单个key

使用

• Init 初始化apollo配置
• Watch 监听namespace结构体

具体使用可以参考apollo-go-demo

看下面例子

package main


type TestConfig struct {
	Map     map[string]string `json:"map"`
	Struct  Person            `json:"struct"`
	Strings []string          `json:"strings"`
	Ints    []int32           `json:"ints"`
	String  string            `json:"string"`
	Int     int64             `json:"int"`
	Float   float32           `json:"float"`
}

type Person struct {
	Name string `json:"name"`
	Age  int64  `json:"age"`
}

var (
	apolloApp = &Application{
		Addr:    "http://81.68.181.139:8080",
		AppId:   "apollo-go",
		Secret:  "",
		Cluster: "DEV",
	}
	mPtr  unsafe.Pointer
    // 默认值配置，配置获取不到时，会用默认值
	mDeft = &TestConfig{
		Float: 0.12,
		Ints:  []int32{2, 3},
	}
)

// DC 返回动态配置，在需要的时候用这个函数获取配置结构体
func DC() *TestConfig {
	p := atomic.LoadPointer(&mPtr)
	if nil != p {
		return (*TestConfig)(p)
	}
	return mDeft
}

func main() {
    c, _ := apollo.NewClient(apolloApp)
	err := c.Watch("application", mDeft, &mPtr)
    for i := 0; i < 100; i++ {
        fmt.Printf("dconf:%+v", DC())
        time.Sleep(1 * time.Second)
    }
}