本文主要是介绍golang实现nacos获取配置和服务注册-支持集群详解，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！
《golang实现nacos获取配置和服务注册-支持集群详解》文章介绍了如何在Go语言中使用Nacos获取配置和服务注册,支持集群初始化,客户端结构体中的IpAddresses可以配置多个地址,新客户...
golang nacos获取配置和服务注册-支持集群
初始化客户端
结构体中IpAddres 可以配置多个地址
package utils import ( "github.com/nacos-group/nacos-sdk-go/clients/config_client" "github.com/nacos-group/nacos-sdk-go/clients/naming_client" "github.com/nacos-group/nacos-sdk-go/vo" "time" ) type NacosConfigClient struct { //ConfigInput //"ip1,ip2,ip3" IpAddrs string Port int NaocesNameSpace string DataId string Group string NacosLogDir string NacosCacheDir string //NamingInput NamingServiceName string NamingServiceIP string NamingOwner string NamingPort int //Output ConfigClient config_client.IConfigClient NamingClient naming_client.INamingClient }
可选参数配置
type OptionNacos func(msg *NacosConfigClient)
//config naming
func OptionNacosConfigWithServiceName(serviceName string) OptionNacos {
return func(msg *NacosConfigClient) {
msg.NamingServiceName = serviceName
}
}
func OptionNacosConfigWithServiceIP(serviceIP string) OptionNacos {
return func(msg *NacosConfigClient) {
msg.NamingServiceIP = serviceIP
}
}
func OptionNacosConfigWithOwner(owner string) OptionNacos {
return func(msg *NacosConfigClient) {
msg.NamingOwner = owner
}
}
//config client
func OptionNacosConfigWithLogDir(logDir string) OptionNacos {
return func(msg *NacosConfigClient) {
msg.NacosLogDir = logDir
}
}
func OptionNacosConfigWithCacheDir(cacheDir string) OptionNacos {
return func(msg *NacosConfigClient) {
msg.NacosCacheDir = cacheDir
}
}
func OptionNacosConfigWithIpaddr(ipAddrr string) OptionNacos {
return func(msg *NacosConfigCliChina编程ent) {
msg.IpAddrs = ipAddrr
}
}
func OptionNacosConfigWithNameSpace(nameSpace string) OptionNacos {
return func(msg *NacosConfigClient) {
msg.NaocesNameSpace = nameSpace
}
}
func OptionNacosConfigWithPort(port int) OptionNacos {
return func(msg *NacosConfigClient) {
msg.Port = port
}
}
func OptionNacopythonsConfigDataId(dataId string) OptionNacos {
return func(msg *NacosConfigClient) {
msg.DataId = dataId
}
}
func OptionNacosConfigGroup(group string) OptionNacos {
return func(msg *NacosConfigClient) {
msg.Group = group
}
}
func OptionNacosWithNamingPort(port int) OptionNacos {
return func(msg *NacosConfigClient) {
msg.NamingPort = port
}
}
new一个客户端 支持集群配置
func NewNacosClient(ops ...OptionNacos) *NacosConfigClient{
nacosConfigClient := new(NacosConfigClient)
for _, o := range ops {
o(nacosConfigClient)
}
serverConfigs:=make([]constant.ServerConfig,0)
address:=strings.Split(nacosConfigClient.IpAddrs,",")
for i:=range address{
serverConfigs=append(serverConfigs,constant.ServerConfig{
IpAddr: address[i],
Port: uint64(nacosConfigClient.Port),
})
}
clientConfig := constant.ClientConfig{
NamespaceId: nacosConfigClient.NaocesNameSpace, //
NotLoadCacheAtStart: false,
TimeoutMs: 5 * 1000,
LogDir: nacosConfigClient.NacosLogDir,
CacheDir: nacosConfigClient.NacosCacheDir,
}
configClient, err := clients.NewConfigClient(
vo.NacosClientParam{
ClientConfig: &clientConfig,
ServerConfigs: serverConfigs,
},
)
if err != nil {
panic(err)
}
nacosConfigClient.ConfigClient = configClient
// Naming client
namingClient, err := clients.NewNamingClient(
vo.NacosClientParam{
ClientConfig: &clientConfig,
ServerConfigs: serverConfigs,
},
)
if err != nil {
panic(err)
}
nacosConfigClient.NamingClient = namingClient
return nacosConfigClient
}
获取配置信息
func (client *NacosConfigClient) GetConfig() (string, error) {
content, err := client.ConfigClient.GetConfig(vo.ConfigParam{
DataId: clijsent.DataId,
Group: client.Group,
})
return content, err
}
服务注册
func (client *NacosConfigClient) Registerwww.chinasem.cn() (bool, error) {
param := vo.RegisterInstanceParam{
Ip: client.NamingServiceIP,
Port: uint64(client.NamingPort),
ServiceName: client.NamingServiceName,
Weight: 10,
Enable: true,
Healthwww.chinasem.cny: true,
Ephemeral: true,
Metadata: map[string]string{"owenr": client.NamingOwner, "uptime": time.Now().Format("2006-01-02 15:04:05")},
}
success, err := client.NamingClient.RegisterInstance(param)
return success, err
}
获取配置后如何和项目中的vipper如何无缝对接？
func InitConfig() {
config = viper.New()
config.SetConfigType("yaml")
config.ReadConfig(bytes.NewReader([]byte(GetNacosConfig())))
}
func GetNacosConfig() string {
content,err:=GetNacosClient().GetConfig()
if err!=nil{
panic(err)
}
return content
}
这样就可以进行vipper正常操作了
总结
这篇关于golang实现nacos获取配置和服务注册-支持集群详解的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
