go注册服务到nacos-乄珍惜

先引入nacos的sdk包到项目中,目前最新的是1.0.7版本

github.com/nacos-group/nacos-sdk-go v1.0.7

经过无数次的尝试,发现魔改后的nacos-spring 用go注册会提示重试三次都失败，失败内容如下:

call domain error:<request return error code 400> , result:<caused: Param 'serviceName' is required.;>

后来采用nacos docker搭建nacos注册中心可正常与spring项目通讯,至于加密通讯方面可能需要自己动手，先上go代码

nacos工具类:

package client

import (
	"fmt"
	"github.com/nacos-group/nacos-sdk-go/clients"
	"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/common/constant"
	"github.com/nacos-group/nacos-sdk-go/model"
	"github.com/nacos-group/nacos-sdk-go/vo"

	"strings"
)

type NacosClient struct {
	Client config_client.IConfigClient
	NamingClient naming_client.INamingClient
}
//创建nacos客户端
func NewNacos(option *Options,isJwt bool) *NacosClient {
	var clientConfig constant.ClientConfig
	if isJwt {
		clientConfig = constant.ClientConfig{
			TimeoutMs:      option.TimeoutMs,
			BeatInterval:   option.BeatInterval,
			LogDir:"/tmp/nacos/log",
			CacheDir:"/tmp/nacos/cache",
			LogLevel:"debug",
			//NamespaceId:"public",
			//AppName:"unknown",
			//OpenKMS:true,
			//Username:"nacos",
			//Password:"$2a$10$EuWPZHzz32dJN7jexM34MOeYirDdFAZm2kuWj7VEOJhhZkDrxfvUu",
			//AccessKey:"pigx",
			//SecretKey:"PBEWithMD5AndDES",
		}
	}else {
		clientConfig = constant.ClientConfig{
			TimeoutMs:      option.TimeoutMs,
			BeatInterval:   option.BeatInterval,
			LogDir:"/tmp/nacos/log",
			CacheDir:"/tmp/nacos/cache",
			LogLevel:"debug",
		}
	}


	serverConfigs := []constant.ServerConfig{
		*constant.NewServerConfig(
			option.Address,
			option.Port,
			constant.WithContextPath("/nacos")),
	}
	// Create Config Center
	client, err := clients.NewConfigClient(vo.NacosClientParam{
		ClientConfig:  &clientConfig,
		ServerConfigs: serverConfigs,
	})
	if err != nil {
		panic(err)
	}
	// Create Register Center
	namingClient,err:=clients.NewNamingClient(vo.NacosClientParam{
		ClientConfig:  &clientConfig,
		ServerConfigs: serverConfigs,
	})
	if err!=nil{
		panic(err)
	}
	return &NacosClient{Client: client,NamingClient: namingClient}
}
//项目公有配置
func (c *NacosClient) Publish(dataId, group, content string) bool {
	ok, err := c.Client.PublishConfig(vo.ConfigParam{
		DataId:  dataId,
		Group:   group,
		Content: content,
	})
	if err != nil {
		return false
	}
	return ok
}
//获取配置文件
func (c *NacosClient) Get(dataId, group string) string {
	s, err := c.Client.GetConfig(vo.ConfigParam{
		DataId: dataId,
		Group:  group,
	})
	if err != nil {
		return ""
	}
	return s
}
//删除nacos配置
func (c *NacosClient) Delete(dataId, group string) bool {
	ok,err:=c.Client.DeleteConfig(vo.ConfigParam{
		DataId:   dataId,
		Group:    group,
	})
	if err!=nil{
		return false
	}
	return ok
}
//监听nacos配置文件变动
func (c *NacosClient) Listen(dataId, group string,OnChange func(namespace, group, dataId, data string)) error {
	return c.Client.ListenConfig(vo.ConfigParam{
		DataId:   dataId,
		Group:    group,
		OnChange: OnChange,
	})
}
//注册到nacos服务
func (c *NacosClient) Register(ip string,port uint64,name string) bool {
	ok,err:=c.NamingClient.RegisterInstance(vo.RegisterInstanceParam{
		Ip:          ip,
		Port:        port,
		ServiceName: name,
		Weight:      1.0,
		//Metadata:	,
		GroupName:	"",
		Enable:      true,
		Healthy:     true,
		Ephemeral:   true,
	})
	if err!=nil{
		fmt.Printf("注册失败:%v",err)
		return false
	}
	return ok
}
//注销nacos服务
func (c *NacosClient) Deregister(ip string,port uint64,name string) bool {
	ok ,err:=c.NamingClient.DeregisterInstance(vo.DeregisterInstanceParam{
		Ip:          ip,
		Port:        port,
		ServiceName: name,
		//Cluster:     "a",
		Ephemeral:   true,
	})
	if err!=nil{
		return false
	}
	return ok
}
//获取nacos服务信息
func (c *NacosClient) GetService(name string) (model.Service,error) {
	return c.NamingClient.GetService(vo.GetServiceParam{
		//Clusters:    []string{"a"},
		ServiceName: name,
	})
}
//获取一个健康的实例（加权随机轮询）
func (c *NacosClient) SelectOneHealthyInstance(name string) (*model.Instance,error) {
	return c.NamingClient.SelectOneHealthyInstance(vo.SelectOneHealthInstanceParam{
		ServiceName: name,
		//Clusters:    []string{"a"},
	})
}

实体

package client

type Options struct {
	TimeoutMs      uint64 //请求Nacos服务端的超时时间，默认是10000ms
	BeatInterval   int64  //发送到服务的心跳时间 默认5000ms
	Address        string //注册中心地址
	Port           uint64 //注册中心端口
}
func deafultOptions() *Options {
	return &Options{
		TimeoutMs:      10*1000,
		ListenInterval: 3*1000,
		BeatInterval:   5*1000,
	}
}
func (option *Options) WithAdress(address string) *Options {
	option.Address = address
	return option
}
func (option *Options) WithPort(port uint64) *Options {
	option.Port = port
	return option
}
func NewOption() *Options {
	return deafultOptions()
}

从nacos读取配置文件方法

option:=client.NewOption().WithAdress(nacosIp).WithPort(8848) //nacosIp 注册中心ip
nacosClient:=client.NewNacos(option,false)
content:=nacosClient.Get(global.GVA_DATA_ID,global.GVA_GROUP) //global.GVA_DATA_ID nacos中的配置文件明  global.GVA_GROUP分组

注册服务到注册中心方法

option:=client.NewOption().WithAdress(nacosIp).WithPort(port)  //注册中心和端口
nacosClient:=client.NewNacos(option,true)
if ok :=nacosClient.Register(localhostip,iport,serverName);ok{  //本机ip 本机端口  本服务名称
     //注册成功逻辑处理
}

乄珍惜

go注册服务到nacos

评论