携程apollo-go客户端

背景

最近在用携程的apollo配置中心, 使用的是go语言客户端，官方推荐的agollo，由于apollo的properties格式的配置文件，返回的都是string类型，所以当配置了一个非string类型的时候，是在获取动态配置的时候，才解析，这对于动态配置，读多写少的场景，显然是不太合适的，所以就萌生了重新写一个apollo-go客户端的想法，也就诞生了apollo-go这个项目

架构

所有apollo-server的接口，都是通过transport获取返回，同时允许用户自己实现transport，给用户提供的api负责定时任务和请求分发，

功能

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

Demo

具体可以参考apollo-go-demo

这里给出简单用法的代码，可以直接Watch相关namespace的结构体，使用的是，通过DC()

package main

import (
	"fmt"
	"sync/atomic"
	"time"
	"unsafe"

	"github.com/xnzone/apollo-go"
)

var (
	app = &apollo.Application{
		Addr:    "http://81.68.181.139:8080",
		AppId:   "apollo-go",
		Secret:  "",
		Cluster: "DEV",
	}
	mDef = &DConfig{}
	mPtr unsafe.Pointer
)

type DConfig 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"`
	Age     int64             `json:"age"`
	Ages    []int64           `json:"ages"`
}

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

// DC get dynamic config if you want
func DC() *DConfig {
	p := atomic.LoadPointer(&mPtr)
	if p != nil {
		return (*DConfig)(p)
	}
	return mDef
}

func main() {
	c, err := apollo.NewClient(app)
	if err != nil {
		fmt.Println(err)
		return
	}
	err = c.Watch("application", mDef, &mPtr)
	if err != nil {
		fmt.Println(err)
		return
	}
	// loop and sleep for test
	for i := 0; i < 100; i++ {
		fmt.Printf("dconf:%+v", DC())
		time.Sleep(1 * time.Second)
	}
}