go 集成nacos注册中心、配置中心

使用限制

Go>=v1.15

Nacos>2.x

安装

使用go get安装SDK：

go get -u github.com/nacos-group/nacos-sdk-go/v2

快速使用

  • 初始化客户端配置ClientConfig
constant.ClientConfig{TimeoutMs            uint64 // 请求Nacos服务端的超时时间，默认是10000msNamespaceId          string // Nacos的命名空间IdEndpoint             string // 当使用地址服务器时，需要该配置. https://help.aliyun.com/document_detail/130146.htmlRegionId             string // Nacos&KMS的regionId，用于配置中心的鉴权AccessKey            string // Nacos&KMS的AccessKey，用于配置中心的鉴权SecretKey            string // Nacos&KMS的SecretKey，用于配置中心的鉴权OpenKMS              bool   // 是否开启kms，默认不开启，kms可以参考文档 https://help.aliyun.com/product/28933.html// 同时DataId必须以"cipher-"作为前缀才会启动加解密逻辑CacheDir             string // 缓存service信息的目录，默认是当前运行目录UpdateThreadNum      int    // 监听service变化的并发数，默认20NotLoadCacheAtStart  bool   // 在启动的时候不读取缓存在CacheDir的service信息UpdateCacheWhenEmpty bool   // 当service返回的实例列表为空时，不更新缓存，用于推空保护Username             string // Nacos服务端的API鉴权UsernamePassword             string // Nacos服务端的API鉴权PasswordLogDir               string // 日志存储路径RotateTime           string // 日志轮转周期，比如：30m, 1h, 24h, 默认是24hMaxAge               int64  // 日志最大文件数，默认3LogLevel             string // 日志默认级别，值必须是：debug,info,warn,error，默认值是info
}
  • ServerConfig
constant.ServerConfig{ContextPath string // Nacos的ContextPath，默认/nacos，在2.0中不需要设置IpAddr      string // Nacos的服务地址Port        uint64 // Nacos的服务端口Scheme      string // Nacos的服务地址前缀，默认http，在2.0中不需要设置GrpcPort    uint64 // Nacos的 grpc 服务端口, 默认为 服务端口+1000, 不是必填
}

 Note：我们可以配置多个ServerConfig，客户端会对这些服务端做轮询请求

Create client

// 创建clientConfig
clientConfig := constant.ClientConfig{NamespaceId:         "e525eafa-f7d7-4029-83d9-008937f9d468", // 如果需要支持多namespace，我们可以创建多个client,它们有不同的NamespaceId。当namespace是public时，此处填空字符串。TimeoutMs:           5000,NotLoadCacheAtStart: true,LogDir:              "/tmp/nacos/log",CacheDir:            "/tmp/nacos/cache",LogLevel:            "debug",
}// 创建clientConfig的另一种方式
clientConfig := *constant.NewClientConfig(constant.WithNamespaceId("e525eafa-f7d7-4029-83d9-008937f9d468"), //当namespace是public时，此处填空字符串。constant.WithTimeoutMs(5000),constant.WithNotLoadCacheAtStart(true),constant.WithLogDir("/tmp/nacos/log"),constant.WithCacheDir("/tmp/nacos/cache"),constant.WithLogLevel("debug"),
)// 至少一个ServerConfig
serverConfigs := []constant.ServerConfig{{IpAddr:      "console1.nacos.io",ContextPath: "/nacos",Port:        80,Scheme:      "http",},{IpAddr:      "console2.nacos.io",ContextPath: "/nacos",Port:        80,Scheme:      "http",},
}// 创建serverConfig的另一种方式
serverConfigs := []constant.ServerConfig{*constant.NewServerConfig("console1.nacos.io",80,constant.WithScheme("http"),constant.WithContextPath("/nacos"),),*constant.NewServerConfig("console2.nacos.io",80,constant.WithScheme("http"),constant.WithContextPath("/nacos"),),
}// 创建服务发现客户端
_, _ := clients.CreateNamingClient(map[string]interface{}{"serverConfigs": serverConfigs,"clientConfig":  clientConfig,
})// 创建动态配置客户端
_, _ := clients.CreateConfigClient(map[string]interface{}{"serverConfigs": serverConfigs,"clientConfig":  clientConfig,
})// 创建服务发现客户端的另一种方式 (推荐)
namingClient, err := clients.NewNamingClient(vo.NacosClientParam{ClientConfig:  &clientConfig,ServerConfigs: serverConfigs,},
)// 创建动态配置客户端的另一种方式 (推荐)
configClient, err := clients.NewConfigClient(vo.NacosClientParam{ClientConfig:  &clientConfig,ServerConfigs: serverConfigs,},
)

服务发现

  • 注册实例：RegisterInstance
success, err := namingClient.RegisterInstance(vo.RegisterInstanceParam{Ip:          "10.0.0.11",Port:        8848,ServiceName: "demo.go",Weight:      10,Enable:      true,Healthy:     true,Ephemeral:   true,Metadata:    map[string]string{"idc":"shanghai"},ClusterName: "cluster-a", // 默认值DEFAULTGroupName:   "group-a",   // 默认值DEFAULT_GROUP
})
  • 注销实例：DeregisterInstance
success, err := namingClient.DeregisterInstance(vo.DeregisterInstanceParam{Ip:          "10.0.0.11",Port:        8848,ServiceName: "demo.go",Ephemeral:   true,Cluster:     "cluster-a", // 默认值DEFAULTGroupName:   "group-a",   // 默认值DEFAULT_GROUP
})
  • 获取服务信息：GetService
services, err := namingClient.GetService(vo.GetServiceParam{ServiceName: "demo.go",Clusters:    []string{"cluster-a"}, // 默认值DEFAULTGroupName:   "group-a",             // 默认值DEFAULT_GROUP
})
  • 获取所有的实例列表：SelectAllInstances
// SelectAllInstance可以返回全部实例列表,包括healthy=false,enable=false,weight<=0
instances, err := namingClient.SelectAllInstances(vo.SelectAllInstancesParam{ServiceName: "demo.go",GroupName:   "group-a",             // 默认值DEFAULT_GROUPClusters:    []string{"cluster-a"}, // 默认值DEFAULT
})
  • 获取实例列表 ：SelectInstances
// SelectInstances 只返回满足这些条件的实例列表：healthy=${HealthyOnly},enable=true 和weight>0
instances, err := namingClient.SelectInstances(vo.SelectInstancesParam{ServiceName: "demo.go",GroupName:   "group-a",             // 默认值DEFAULT_GROUPClusters:    []string{"cluster-a"}, // 默认值DEFAULTHealthyOnly: true,
})
  • 获取一个健康的实例（加权随机轮询）：SelectOneHealthyInstance
// SelectOneHealthyInstance将会按加权随机轮询的负载均衡策略返回一个健康的实例
// 实例必须满足的条件：health=true,enable=true and weight>0
instance, err := namingClient.SelectOneHealthyInstance(vo.SelectOneHealthInstanceParam{ServiceName: "demo.go",GroupName:   "group-a",             // 默认值DEFAULT_GROUPClusters:    []string{"cluster-a"}, // 默认值DEFAULT
})
  • 监听服务变化：Subscribe
// Subscribe key=serviceName+groupName+cluster
// 注意:我们可以在相同的key添加多个SubscribeCallback.
err := namingClient.Subscribe(vo.SubscribeParam{ServiceName: "demo.go",GroupName:   "group-a",             // 默认值DEFAULT_GROUPClusters:    []string{"cluster-a"}, // 默认值DEFAULTSubscribeCallback: func(services []model.Instance, err error) {log.Printf("\n\n callback return services:%s \n\n", utils.ToJsonString(services))},
})
  • 取消服务监听：Unsubscribe
err := namingClient.Unsubscribe(vo.SubscribeParam{ServiceName: "demo.go",GroupName:   "group-a",             // 默认值DEFAULT_GROUPClusters:    []string{"cluster-a"}, // 默认值DEFAULTSubscribeCallback: func(services []model.Instance, err error) {log.Printf("\n\n callback return services:%s \n\n", utils.ToJsonString(services))},
})
  • 获取服务名列表
serviceInfos, err := namingClient.GetAllServicesInfo(vo.GetAllServiceInfoParam{NameSpace: "0e83cc81-9d8c-4bb8-a28a-ff703187543f",PageNo:   1,PageSize: 10,}),

动态配置

  • 发布配置：PublishConfig
success, err := configClient.PublishConfig(vo.ConfigParam{DataId:  "dataId",Group:   "group",Content: "hello world!222222"})
  • 删除配置：DeleteConfig
success, err = configClient.DeleteConfig(vo.ConfigParam{DataId: "dataId",Group:  "group"})
  • 获取配置：GetConfig
content, err := configClient.GetConfig(vo.ConfigParam{DataId: "dataId",Group:  "group"})
  • 监听配置变化：ListenConfig
err := configClient.ListenConfig(vo.ConfigParam{DataId: "dataId",Group:  "group",OnChange: func(namespace, group, dataId, data string) {fmt.Println("group:" + group + ", dataId:" + dataId + ", data:" + data)},
})
  • 取消配置监听：CancelListenConfig
err := configClient.CancelListenConfig(vo.ConfigParam{DataId: "dataId",Group:  "group",
})
  • 搜索配置: SearchConfig
configPage,err := configClient.SearchConfig(vo.SearchConfigParam{Search:   "blur",DataId:   "",Group:    "",PageNo:   1,PageSize: 10,
})

工具

client

/** Copyright 1999-2020 Alibaba Group Holding Ltd.** Licensed under the Apache License, Version 2.0 (the "License");* you may not use this file except in compliance with the License.* You may obtain a copy of the License at**      http://www.apache.org/licenses/LICENSE-2.0** Unless required by applicable law or agreed to in writing, software* distributed under the License is distributed on an "AS IS" BASIS,* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.* See the License for the specific language governing permissions and* limitations under the License.*/package nacosimport ("fmt""github.com/nacos-group/nacos-sdk-go/v2/clients/naming_client""github.com/nacos-group/nacos-sdk-go/v2/vo"
)func RegisterServiceInstance(client naming_client.INamingClient, param vo.RegisterInstanceParam) {success, err := client.RegisterInstance(param)if !success || err != nil {panic("RegisterServiceInstance failed!" + err.Error())}fmt.Printf("RegisterServiceInstance,param:%+v,result:%+v \n\n", param, success)
}func BatchRegisterServiceInstance(client naming_client.INamingClient, param vo.BatchRegisterInstanceParam) {success, err := client.BatchRegisterInstance(param)if !success || err != nil {panic("BatchRegisterServiceInstance failed!" + err.Error())}fmt.Printf("BatchRegisterServiceInstance,param:%+v,result:%+v \n\n", param, success)
}func DeRegisterServiceInstance(client naming_client.INamingClient, param vo.DeregisterInstanceParam) {success, err := client.DeregisterInstance(param)if !success || err != nil {panic("DeRegisterServiceInstance failed!" + err.Error())}fmt.Printf("DeRegisterServiceInstance,param:%+v,result:%+v \n\n", param, success)
}func UpdateServiceInstance(client naming_client.INamingClient, param vo.UpdateInstanceParam) {success, err := client.UpdateInstance(param)if !success || err != nil {panic("UpdateInstance failed!" + err.Error())}fmt.Printf("UpdateServiceInstance,param:%+v,result:%+v \n\n", param, success)
}func GetService(client naming_client.INamingClient, param vo.GetServiceParam) {service, err := client.GetService(param)if err != nil {panic("GetService failed!" + err.Error())}fmt.Printf("GetService,param:%+v, result:%+v \n\n", param, service)
}func SelectAllInstances(client naming_client.INamingClient, param vo.SelectAllInstancesParam) {instances, err := client.SelectAllInstances(param)if err != nil {panic("SelectAllInstances failed!" + err.Error())}fmt.Printf("SelectAllInstance,param:%+v, result:%+v \n\n", param, instances)
}func SelectInstances(client naming_client.INamingClient, param vo.SelectInstancesParam) {instances, err := client.SelectInstances(param)if err != nil {panic("SelectInstances failed!" + err.Error())}fmt.Printf("SelectInstances,param:%+v, result:%+v \n\n", param, instances)
}func SelectOneHealthyInstance(client naming_client.INamingClient, param vo.SelectOneHealthInstanceParam) {instances, err := client.SelectOneHealthyInstance(param)if err != nil {panic("SelectOneHealthyInstance failed!")}fmt.Printf("SelectOneHealthyInstance,param:%+v, result:%+v \n\n", param, instances)
}func Subscribe(client naming_client.INamingClient, param *vo.SubscribeParam) {_ = client.Subscribe(param)
}func UnSubscribe(client naming_client.INamingClient, param *vo.SubscribeParam) {_ = client.Unsubscribe(param)
}func GetAllService(client naming_client.INamingClient, param vo.GetAllServiceInfoParam) {service, err := client.GetAllServicesInfo(param)if err != nil {panic("GetAllService failed!")}fmt.Printf("GetAllService,param:%+v, result:%+v \n\n", param, service)
}

config

/** Copyright 1999-2020 Alibaba Group Holding Ltd.** Licensed under the Apache License, Version 2.0 (the "License");* you may not use this file except in compliance with the License.* You may obtain a copy of the License at**      http://www.apache.org/licenses/LICENSE-2.0** Unless required by applicable law or agreed to in writing, software* distributed under the License is distributed on an "AS IS" BASIS,* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.* See the License for the specific language governing permissions and* limitations under the License.*/package nacosimport ("fmt""github.com/nacos-group/nacos-sdk-go/v2/clients/config_client""github.com/nacos-group/nacos-sdk-go/v2/model""github.com/nacos-group/nacos-sdk-go/v2/vo"
)func PublishConfig(client config_client.IConfigClient, param vo.ConfigParam) {//publish config//config key=dataId+group+namespaceId_, err := client.PublishConfig(param)if err != nil {fmt.Printf("PublishConfig err:%+v \n", err)}
}func DeleteConfig(client config_client.IConfigClient, param vo.ConfigParam) {_, err := client.DeleteConfig(param)if err != nil {fmt.Printf("DeleteConfig err:%+v \n", err)}
}func GetConfig(client config_client.IConfigClient, param vo.ConfigParam) string {//get configcontent, err := client.GetConfig(param)if err != nil {fmt.Printf("GetConfig err:%+v \n", err)} else {fmt.Println("GetConfig,config :" + content)}return content
}func ListenConfig(client config_client.IConfigClient, param vo.ConfigParam) {//Listen config change,key=dataId+group+namespaceId.err := client.ListenConfig(vo.ConfigParam{DataId: "test-data",Group:  "test-group",OnChange: func(namespace, group, dataId, data string) {fmt.Println("config changed group:" + group + ", dataId:" + dataId + ", content:" + data)},})if err != nil {fmt.Printf("PublishConfig err:%+v \n", err)}
}func CancelListenConfig(client config_client.IConfigClient, param vo.ConfigParam) {//cancel config changeerr := client.CancelListenConfig(param)if err != nil {fmt.Printf("CancelListenConfig err:%+v \n", err)}
}func SearchConfig(client config_client.IConfigClient, param vo.SearchConfigParam) *model.ConfigPage {searchPage, err := client.SearchConfig(param)if err != nil {fmt.Printf("SearchConfig err:%+v \n", err)} else {fmt.Printf("SearchConfig:%+v \n", searchPage)}return searchPage
}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/889168.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

ModelScope-Agent(1): 基于开源大语言模型的可定制Agent系统

ModelScope-Agent(1): 基于开源大语言模型的可定制Agent系统

目录 简介快速入门 简介 github地址 快速入门 看前两篇&#xff0c;调用千问API和天气API # 选用RolePlay 配置agent from modelscope_agent.agents.role_play import RolePlay # NOQArole_template 你扮演一个天气预报助手&#xff0c;你需要查询相应地区的天气&#x…
阅读更多...
终端中运行 conda install 命令后一直显示“Solving environment: \ ”

终端中运行 conda install 命令后一直显示“Solving environment: \ ”

初步接触深度学习&#xff0c;在配置环境方面出了点问题&#xff0c;运行 conda install 命令时&#xff0c;卡在 "Solving environment: \ "。 网上搜索发现&#xff0c; 一般可能的原因就是以下几种 环境解析耗时&#xff1a; Conda 在安装包时需要解析当前环境&…
阅读更多...
Jenkins相关的Api接口调用详解

Jenkins相关的Api接口调用详解

Jenkins API是Jenkins持续集成和持续部署（CI/CD）平台提供的一组接口，允许外部程序通过HTTP请求与Jenkins进行交互。以下是对Jenkins API使用的简介： 一、Jenkins API的主要功能 作业管理：通过API，可以创建、配置、删除以及查询作业（Job）。构建触发：可以远程触发新的构…
阅读更多...
【模型对比】ChatGPT vs Kimi vs 文心一言那个更好用？数据详细解析，找出最适合你的AI辅助工具！

【模型对比】ChatGPT vs Kimi vs 文心一言那个更好用？数据详细解析，找出最适合你的AI辅助工具！

在这个人工智能迅猛发展的时代&#xff0c;AI聊天助手已经深入我们的工作与生活。你是否曾在选择使用ChatGPT、Kimi或是百度的文心一言时感到一头雾水&#xff1f;每款AI都有其独特的魅力与优势&#xff0c;那么&#xff0c;究竟哪一款AI聊天助手最适合你呢&#xff1f;本文将带…
阅读更多...
react 和 react-dom 是什么关系

react 和 react-dom 是什么关系

React和React DOM是两个与React生态系统密切相关的npm包&#xff0c;它们在构建用户界面时扮演不同的角色&#xff0c;但相互之间存在紧密的依赖关系。以下是React和React DOM关系的详细解释&#xff1a; React的作用 React是一个用于构建用户界面的JavaScript库。它提供了构建…
阅读更多...
微信小程序uni-app+vue3实现局部上下拉刷新和scroll-view动态高度计算

微信小程序uni-app+vue3实现局部上下拉刷新和scroll-view动态高度计算

微信小程序uni-appvue3实现局部上下拉刷新和scroll-view动态高度计算 前言 在uni-appvue3项目开发中,经常需要实现列表的局部上下拉刷新功能。由于网上相关教程较少且比较零散,本文将详细介绍如何使用scroll-view组件实现这一功能,包括动态高度计算、下拉刷新、上拉加载等完整…
阅读更多...
Netty面试内容整理-常见问题排查与调试

Netty面试内容整理-常见问题排查与调试

在使用 Netty 进行开发时，排查和调试常见问题是确保系统稳定运行的关键部分。以下是一些 Netty 中常见的问题排查和调试的方法，以及对应的解决思路： 内存泄漏问题 问题描述：Netty 内存泄漏可能发生在 ByteBuf 没有被正确释放的情况下，导致内存逐渐被耗尽。 排查方法：Reso…
阅读更多...
SQL——DQL分组聚合

SQL——DQL分组聚合

分组聚合&#xff1a; 格式&#xff1a; select 聚合函数1(聚合的列),聚合函数2(聚合的列) from 表名 group by 标识列; ###若想方便分辨聚合后数据可在聚合函数前加上标识列&#xff08;以标识列进行分组&#xff09; 常见的聚合函数: sum(列名):求和函数 avg(列名)…
阅读更多...
maven打包时出现找不到符号的错误如何解决

maven打包时出现找不到符号的错误如何解决

在maven打包的时候有时会出现找不到符号的情况&#xff0c;具体原因是由于引用的BaseEntity是framework模块下的实体类&#xff0c;所以需要将framework重新clean再install&#xff0c;成功后再将我们的模块打包就成功了
阅读更多...
NumPy和Pandas之间直接相互转换

NumPy和Pandas之间直接相互转换

NumPy数组转换为Pandas DataFrame 要将NumPy数组转换为Pandas DataFrame&#xff0c;可以使用Pandas的DataFrame类的构造函数。这个过程很简单&#xff0c;只需要将NumPy数组作为参数传递给DataFrame构造函数即可。此外&#xff0c;还可以指定列名&#xff0c;以便在DataFrame…
阅读更多...
openGauss开源数据库实战二十一

openGauss开源数据库实战二十一

文章目录 任务二十一 使用JDBC访问openGauss数据库任务目标实施步骤一、准备工作 二、下载并安装JavaSE81 下载JavaSE8安装Java8SE并配置环境变量 三、下载并安装eclipse四、下载并安装openGauss的JDBC驱动包五、使用IDEA编写JDBC测试程序1 使用IDEA的SSH连接虚拟机2 创建项目并…
阅读更多...
Git：常用命令

Git：常用命令

一、查看当前分支 git branch 二、查看所有分支 git branch -a 三、切换到远程分支 git checkout origin/分支名 示例&#xff1a;git checkout origin/dev 四、拉取远程分支代码 git pull origin 分支名 示例&#xff1a;git pull origin dev 五、常用指令 查看暂存区…
阅读更多...
运维实战：K8s 上的 Doris 高可用集群最佳实践

运维实战：K8s 上的 Doris 高可用集群最佳实践

今天我们将深入探讨&#xff1a;&#xff1a;如何在 K8s 集群上部署 Compute storage coupled&#xff08;存算耦合&#xff09; 模式的 Doris 高可用集群&#xff1f; 本文&#xff0c;我将为您提供一份全面的实战指南&#xff0c;逐步引导您完成以下关键任务&#xff1a; 配…
阅读更多...
2024.12.10总结

2024.12.10总结

早上和上午&#xff0c;通过一个自动化测试工具对环境进行自动化测试&#xff0c;跑的时候出现各种问题。如何去定位问题并且解决问题&#xff0c;确实是一个比较关键的能力。晚上去考了测试专业级科目一&#xff0c;只找到了12个bug&#xff0c;距离通关17个以上&#xff0c;还…
阅读更多...
在GITHUB上传本地文件指南（详细图文版）

在GITHUB上传本地文件指南（详细图文版）

这份笔记简述了如何在GITHUB上上传文件夹的详细策略。 既是对自己未来的一个参考&#xff0c;又希望能给各位读者带来帮助。 详细步骤 打开目标文件夹&#xff08;想要上传的文件夹&#xff09; 右击点击git bash打开 GitHub创立新的仓库后&#xff0c;点击右上方CODE绿色按…
阅读更多...
Vue框架入门

Vue框架入门

Author&#xff1a;Dawn_T17?? 目录 什么是框架 一.Vue 的使用方向 二.Vue 框架的使用场景 &#xff08;TIP&#xff09;MVVM思想 三.Vue入门案例 TIP&#xff1a;插值表达式 四.Vue-指令? &#xff08;1&#xff09;v-bind 和 v-model? ? &#xff08;2&#x…
阅读更多...
FPGA 遍历读 LMK04803 寄存器

FPGA 遍历读 LMK04803 寄存器

主要思路&#xff1a; 1.使用 VIO 输出信号控制什么时候开始读LMK04803寄存器 2.遍历LMK04803所有寄存器&#xff0c;将读到的每个寄存器的值显示在VIO上。 3.遍历指的是 从 R0 开始读&#xff0c;R0读完接着读 R1&#xff0c;一直到R31 结束 4.注意的是写寄存器是 32bit &…
阅读更多...
【uni-app 微信小程序】新版本发布提示用户进行更新

【uni-app 微信小程序】新版本发布提示用户进行更新

知识准备 uni.getUpdateManager文档介绍 不支持APP与H5&#xff0c;所以在使用的时候要做好平台类型的判断&#xff0c;如何判断&#xff0c;参考条件编译处理多端差异 代码参考 export const updateApp () > {const updateManager uni.getUpdateManager()updateManag…
阅读更多...
vue实现点击左右按钮横向滚动

vue实现点击左右按钮横向滚动

html部分 <div ref"tabHeaderRef" class"flex items-center tabs_header"><div class"tab-pre" v-if"hidePre" click"leftPre"><i class"el-icon-arrow-left"></i></div><div r…
阅读更多...
数据结构（3）单链表的模拟实现

数据结构（3）单链表的模拟实现

上一节我们进行了数据结构中的顺序表的模拟式现&#xff0c;今天我们来实现一下另外一个数据结构&#xff1a;单链表。 我们在实现顺序表之后一定会引发一些问题和思考&#xff1a; 1.顺序表在头部和中间插入数据会用到循环&#xff0c;时间复杂O&#xff08;N&#xff09; …
阅读更多...
最新文章

Copyright @ 2022~2023