main.go 1.4 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162
  1. package main
  2. import (
  3. "fmt"
  4. "github.com/nacos-group/nacos-sdk-go/clients"
  5. "github.com/nacos-group/nacos-sdk-go/common/constant"
  6. "github.com/nacos-group/nacos-sdk-go/vo"
  7. "log"
  8. )
  9. func main() {
  10. //创建 ServerConfig
  11. serverConfigs := []constant.ServerConfig{
  12. {
  13. IpAddr: "127.0.0.1",
  14. Port: 8848,
  15. },
  16. }
  17. //创建 Client
  18. namingClient, err := clients.NewNamingClient(
  19. vo.NacosClientParam{
  20. ServerConfigs: serverConfigs,
  21. },
  22. )
  23. if err != nil {
  24. log.Fatal("nacos初始化错误:", err)
  25. }
  26. //进行服务注册
  27. isSuccess, err := namingClient.RegisterInstance(vo.RegisterInstanceParam{
  28. Ip: "127.0.0.1",
  29. Port: 8848,
  30. ServiceName: "demo.go",
  31. Weight: 10,
  32. Enable: true,
  33. Healthy: true,
  34. Ephemeral: true,
  35. Metadata: map[string]string{"a": "aaaa"},
  36. ClusterName: "cluster-a", //默认值是 DEFAULT
  37. GroupName: "group-a", //默认值是 DEFAULT_GROUP
  38. })
  39. if err != nil {
  40. log.Fatal("服务注册错误:", err)
  41. }
  42. if !isSuccess {
  43. log.Fatal("服务注册失败:")
  44. }
  45. //获取服务
  46. services, err := namingClient.GetService(vo.GetServiceParam{
  47. ServiceName: "demo.go",
  48. Clusters: []string{"cluster-a"}, // 默认值是 DEFAULT
  49. GroupName: "group-a", // 默认值是 DEFAULT_GROUP
  50. })
  51. if err != nil {
  52. log.Fatal("获取服务错误:", err)
  53. }
  54. //打印服务元数据
  55. fmt.Println(services.Name)
  56. }