使用Golang客户端实现Nacos服务注册发现和配置管理

背景

最近需要把Golang实现的一个web项目集成到基于Spring Cloud Alibaba的微服务体系中，走Spring Cloud Gateway网关路由实现统一的鉴权入口。

软件版本

组件名称	组件版本
Nacos	2.2.0
Go	1.21.0
Gin	v1.9.1
Nacos-sdk-go	v2.2.5
Spring Cloud	2021.0.2
Spring Cloud Alibaba	2021.0.1.0

服务注册发现

项目图示

服务注册和发现

Golang客户端的注册发现使用的Nacos官方仓库里面的一个实现：https://github.com/nacos-group/nacos-sdk-go，我这边的实现大多数也是参考的官方提供的样例。

首先，初始化clientConfig和serverConfig的配置

sc := []constant.ServerConfig{
  *constant.NewServerConfig("localhost", 8848, constant.WithContextPath("/nacos")),
}

cc := *constant.NewClientConfig(
  constant.WithNamespaceId("xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx"),
  constant.WithTimeoutMs(5000),
  constant.WithNotLoadCacheAtStart(true),
  constant.WithLogDir("/tmp/nacos/log"),
  constant.WithCacheDir("/tmp/nacos/cache"),
  constant.WithUsername("nacos"),
  constant.WithPassword("nacos"),
)

创建服务发现客户端

client, _ := clients.NewNamingClient(
  vo.NacosClientParam{
    ClientConfig:  &cc,
    ServerConfigs: sc,
  },
)

服务注册

// 注册服务
registerServiceInstance(client, vo.RegisterInstanceParam{
  Ip:          getHostIp(),
  Port:        8777,
  ServiceName: ServiceName,
  Weight:      10,
  Enable:      true,
  Healthy:     true,
  Ephemeral:   true,
})


// 注册服务
func registerServiceInstance(nacosClient naming_client.INamingClient, param vo.RegisterInstanceParam) {
	success, err := nacosClient.RegisterInstance(param)
	if !success || err != nil {
		panic("register Service Instance failed!")
	}
}

// 获取本机ip地址
func getHostIp() string {
	conn, err := net.Dial("udp", "8.8.8.8:53")
	if err != nil {
		fmt.Println("get current host ip err: ", err)
		return ""
	}
	addr := conn.LocalAddr().(*net.UDPAddr)
	ip := strings.Split(addr.String(), ":")[0]
	return ip
}

启动服务，验证ok

客户端负载均衡

作为Go语言初学者，没有详细去了解Go中类似@LoadBalanced或者Feign的框架（后续可能会补充一下），然后我这边就是获取实例解析IP和端口信息，然后直接使用Go原生的http库进行的调用。

获取实例方法

// 获取一个健康的实例
func selectOneHealthyInstance(client naming_client.INamingClient, serviceName string) (instance *model.Instance) {
	instances, err := client.SelectOneHealthyInstance(vo.SelectOneHealthInstanceParam{
		ServiceName: serviceName,
	})
	if err != nil {
		panic("SelectOneHealthyInstance failed!")
	}
	return instances
}

具体调用

func hello(c *gin.Context) {
	name := c.Param("name")
	instance := selectOneHealthyInstance(NamingClient, "server-java")
	url := fmt.Sprintf("http://%s:%d/hello/%s", instance.Ip, instance.Port, name)
	resp, _ := http.Get(url)
	defer resp.Body.Close()
	body, _ := io.ReadAll(resp.Body)
	c.String(http.StatusOK, string(body))
}

在server-java中，提供了一个rest接口

/**
 * 启动类
 *
 * @author yuanzhihao
 * @since 2024/3/4
 */
@RestController
@RequestMapping
@SpringBootApplication
public class Application {


    @GetMapping("/hello/{name}")
    public String hello(@PathVariable("name") String name) {
        return "Hello " + name;
    }

    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

请求 http://localhost:8777/hello/yuan, 调用成功

配置管理

图示

第一步和注册发现一样，初始化clientConfig和serverConfig的配置，略

创建动态配置客户端

configClient, _ := clients.NewConfigClient(
  vo.NacosClientParam{
    ClientConfig:  &cc,
    ServerConfigs: sc,
  },
)

拉取指定data-id的配置

config, _ := ConfigClient.GetConfig(vo.ConfigParam{
  DataId: ServiceName,
})
fmt.Printf("config is " + config)

我这边写了一个rest的接口，可以指定获取某个具体配置的值

// 初始化服务端
func ServerSetup() {
	r := gin.Default()
	r.GET("/hello/:name", hello)
	r.GET("/config", getSpecifiedConfig)
	r.Run(":8777")
}

// 获取指定的配置
func getSpecifiedConfig(c *gin.Context) {
	param := c.DefaultQuery("name", "")
	config, _ := ConfigClient.GetConfig(vo.ConfigParam{
		DataId: ServiceName,
	})
	fmt.Printf("config is " + config)
	// 解析YAML数据
	var data map[string]interface{}
	err := yaml.Unmarshal([]byte(config), &data)
	if err != nil {
		fmt.Println("error unmarshalling YAML", err)
	}
	value := getValue(data, param)
	c.String(http.StatusOK, "param [ "+param+" ] value is "+value)
}

func getValue(data map[string]interface{}, keyPath string) string {
	keys := strings.Split(keyPath, ".")
	var value interface{} = data
	for _, key := range keys {
		if v, ok := value.(map[string]interface{}); ok {
			value = v[key]
		} else {
			return ""
		}
	}
	if v, ok := value.(string); ok {
		return v
	}
	return fmt.Sprintf("%v", value)
}

配置client-go如下

my:
  name: yuan
  age: 27
  city: Nanjing

调用请求 http://localhost:8777/config?name=my.name，http://localhost:8777/config?name=my.age ok

结语

参考地址：https://github.com/nacos-group/nacos-sdk-go

代码地址：https://github.com/yzh19961031/blogDemo/tree/master/go-nacos