南阳网站优化公司,网站开发专家,wordpress数据库里的主题痕迹,四平网站seo前言
本文分析的实例来源于nacos在github上的开源仓库
nacos配置的增删查改 先具体来看一段代码#xff0c;我将逐步分析每一段的作用
package mainimport (fmttimegithub.com/nacos-group/nacos-sdk-go/clientsgithub.com/naco…前言
本文分析的实例来源于nacos在github上的开源仓库
nacos配置的增删查改 先具体来看一段代码我将逐步分析每一段的作用
package mainimport (fmttimegithub.com/nacos-group/nacos-sdk-go/clientsgithub.com/nacos-group/nacos-sdk-go/common/constantgithub.com/nacos-group/nacos-sdk-go/vo
)func main() {// 创建ServerConfigsc : []constant.ServerConfig{*constant.NewServerConfig(192.168.195.129, // Nacos服务器的IP地址8848, // Nacos服务器的端口号constant.WithContextPath(/nacos), // 上下文路径),}// 创建ClientConfigcc : *constant.NewClientConfig(constant.WithNamespaceId(ace1b5fe-80c3-4fab-b89a-625f9ff41093), // 命名空间IDconstant.WithTimeoutMs(5000), // 超时时间毫秒constant.WithNotLoadCacheAtStart(true), // 启动时不加载缓存constant.WithLogDir(/tmp/nacos/log), // 日志目录constant.WithCacheDir(/tmp/nacos/cache), // 缓存目录constant.WithLogLevel(debug), // 日志级别constant.WithUsername(nacos), // 用户名constant.WithPassword(nacos), // 密码)// 创建配置客户端client, err : clients.NewConfigClient(vo.NacosClientParam{ClientConfig: cc, // 客户端配置ServerConfigs: sc, // 服务器配置切片},)if err ! nil {panic(err) // 如果创建客户端失败程序终止并打印错误信息}// 发布配置_, err client.PublishConfig(vo.ConfigParam{DataId: test-data, // 配置的数据IDGroup: test-group, // 配置的分组Content: hello world!, // 配置的内容})if err ! nil {fmt.Printf(PublishConfig err:%v \n, err) // 如果发布配置失败打印错误信息}_, err client.PublishConfig(vo.ConfigParam{DataId: test-data-2, // 第二个配置的数据IDGroup: test-group, // 第二个配置的分组Content: hello world!, // 第二个配置的内容})if err ! nil {fmt.Printf(PublishConfig err:%v \n, err) // 如果发布配置失败打印错误信息}// 等待1秒确保配置发布完成time.Sleep(1 * time.Second)// 获取配置content, err : client.GetConfig(vo.ConfigParam{DataId: test-data, // 要获取的配置的数据IDGroup: test-group, // 要获取的配置的分组})fmt.Println(GetConfig,config : content) // 打印获取到的配置内容// 监听配置变更err client.ListenConfig(vo.ConfigParam{DataId: test-data, // 要监听的配置的数据IDGroup: test-group, // 要监听的配置的分组OnChange: func(namespace, group, dataId, data string) {fmt.Println(config changed group: group , dataId: dataId , content: data) // 配置变更时打印信息},})if err ! nil {fmt.Printf(ListenConfig err:%v \n, err) // 如果监听失败打印错误信息}err client.ListenConfig(vo.ConfigParam{DataId: test-data-2, // 第二个要监听的配置的数据IDGroup: test-group, // 第二个要监听的配置的分组OnChange: func(namespace, group, dataId, data string) {fmt.Println(config changed group: group , dataId: dataId , content: data) // 配置变更时打印信息},})if err ! nil {fmt.Printf(ListenConfig err:%v \n, err) // 如果监听失败打印错误信息}// 等待1秒确保监听配置生效time.Sleep(1 * time.Second)// 修改配置_, err client.PublishConfig(vo.ConfigParam{DataId: test-data, // 要修改的配置的数据IDGroup: test-group, // 要修改的配置的分组Content: test-listen, // 修改后的配置内容})if err ! nil {fmt.Printf(PublishConfig err:%v \n, err) // 如果修改配置失败打印错误信息}_, err client.PublishConfig(vo.ConfigParam{DataId: test-data-2, // 第二个要修改的配置的数据IDGroup: test-group, // 第二个要修改的配置的分组Content: test-listen, // 第二个修改后的配置内容})if err ! nil {fmt.Printf(PublishConfig err:%v \n, err) // 如果修改配置失败打印错误信息}// 等待2秒确保配置修改被监听到time.Sleep(2 * time.Second)// 等待1秒time.Sleep(1 * time.Second)// 删除配置_, err client.DeleteConfig(vo.ConfigParam{DataId: test-data, // 要删除的配置的数据IDGroup: test-group, // 要删除的配置的分组})if err ! nil {fmt.Printf(DeleteConfig err:%v \n, err) // 如果删除配置失败打印错误信息}// 等待1秒确保配置删除操作完成time.Sleep(1 * time.Second)// 取消监听配置变更err client.CancelListenConfig(vo.ConfigParam{DataId: test-data, // 要取消监听的配置的数据IDGroup: test-group, // 要取消监听的配置的分组})if err ! nil {fmt.Printf(CancelListenConfig err:%v \n, err) // 如果取消监听失败打印错误信息}// 搜索配置searchPage, _ : client.SearchConfig(vo.SearchConfigParam{Search: blur, // 搜索模式这里是模糊搜索DataId: , // 数据ID为空表示不指定Group: , // 分组为空表示不指定PageNo: 1, // 搜索的页码PageSize: 10, // 每页的大小})fmt.Printf(Search config:%v \n, searchPage) // 打印搜索结果
}Serverconfig
ServerConfig主要用于配置Nacos服务器的信息。它告诉客户端如何连接到Nacos服务器包括服务器的IP地址、端口号和上下文路径等。通过ServerConfig客户端可以找到并连接到Nacos服务器这里以切片的形式是为了可以保证多个选择并且具有可扩展性。
sc : []constant.ServerConfig{*constant.NewServerConfig(192.168.195.129, // Nacos服务器的IP地址8848, // Nacos服务器的端口号constant.WithContextPath(/nacos), // 上下文路径),
}这段代码配置了一个Nacos服务器使得客户端可以连接到该服务器。
ClientConfig
ClientConfig用于配置客户端的行为和属性包括命名空间ID、超时时间、日志级别、缓存目录等。ClientConfig中的命名空间IDNamespaceId指定了客户端要操作的特定命名空间。通过命名空间ID客户端可以确保只管理属于该命名空间的配置和服务。
例如
cc : *constant.NewClientConfig(constant.WithNamespaceId(ace1b5fe-80c3-4fab-b89a-625f9ff41093), // 命名空间IDconstant.WithTimeoutMs(5000),constant.WithNotLoadCacheAtStart(true),constant.WithLogDir(/tmp/nacos/log),constant.WithCacheDir(/tmp/nacos/cache),constant.WithLogLevel(debug),constant.WithUsername(nacos),constant.WithPassword(nacos),
)这段代码配置了客户端的行为特别是指定了要操作的命名空间ID。
ServerConfig用于配置Nacos服务器的信息告诉客户端如何连接到Nacos服务器。ClientConfig用于配置客户端的行为和属性包括命名空间ID告诉客户端要操作哪个命名空间中的配置和服务。
通过这两个配置客户端可以正确地连接到Nacos服务器并操作指定命名空间中的配置和服务。以下是代码中两者的使用关系
client, err : clients.NewConfigClient(vo.NacosClientParam{ClientConfig: cc, // 客户端配置包括命名空间ID等ServerConfigs: sc, // 服务器配置切片用于连接Nacos服务器},
)这里就创建了一个客户端用于访问服务器特定的命名空间。
命名空间是什么
AI答 我的理解在Nacos中命名空间Namespace是一种用于隔离配置和服务的机制。通过命名空间可以将不同的配置和服务分隔开来避免它们之间的冲突和干扰。命名空间在Nacos中通常用于多环境如开发环境、测试环境、生产环境的配置管理或者用于不同的项目或团队之间的配置隔离。
比如我的代码里面命名空间ID是 ace1b5fe-80c3-4fab-b89a-625f9ff41093。这个ID是一个唯一的标识符用于指定一个特定的命名空间。通过这个命名空间ID客户端可以操作属于该命名空间的配置和服务。 添加配置
// 发布配置
_, err client.PublishConfig(vo.ConfigParam{DataId: test-data, // 配置的数据IDGroup: test-group, // 配置的分组Content: hello world!, // 配置的内容
})
if err ! nil {fmt.Printf(PublishConfig err:%v \n, err) // 如果发布配置失败打印错误信息
}_, err client.PublishConfig(vo.ConfigParam{DataId: test-data-2, // 第二个配置的数据IDGroup: test-group, // 第二个配置的分组Content: hello world!, // 第二个配置的内容
})
if err ! nil {fmt.Printf(PublishConfig err:%v \n, err) // 如果发布配置失败打印错误信息此处实现的功能为发布配置和nacos控制台的发布配置功能是一样的 注意要选择相应的命名空间。 监视配置
// 获取配置
content, err : client.GetConfig(vo.ConfigParam{DataId: test-data, // 要获取的配置的数据IDGroup: test-group, // 要获取的配置的分组
})
fmt.Println(GetConfig,config : content) // 打印获取到的配置内容// 监听配置变更
err client.ListenConfig(vo.ConfigParam{DataId: test-data, // 要监听的配置的数据IDGroup: test-group, // 要监听的配置的分组OnChange: func(namespace, group, dataId, data string) {fmt.Println(config changed group: group , dataId: dataId , content: data) // 配置变更时打印信息},
})这里实现了获取配置以及对配置的监听为什么这里可以监听到之后配置的变更呢这里我认为应该是在函数内部使用了goroutine来实现的一旦检测到有变化监听器就会发出响应。 修改/删除配置
_, err client.PublishConfig(vo.ConfigParam{DataId: test-data, // 要修改的配置的数据IDGroup: test-group, // 要修改的配置的分组Content: test-listen, // 修改后的配置内容
})_, err client.DeleteConfig(vo.ConfigParam{DataId: test-data, // 要删除的配置的数据IDGroup: test-group, // 要删除的配置的分组
})
if err ! nil {fmt.Printf(DeleteConfig err:%v \n, err) // 如果删除配置失败打印错误信息
}至于修改以及删除的逻辑就很简单了这里不多赘述 nacos服务注册
先看代码示例在接下来我会详细讲解每一步
package mainimport (fmtgithub.com/nacos-group/nacos-sdk-go/v2/clients/naming_clienttimegithub.com/nacos-group/nacos-sdk-go/v2/clientsgithub.com/nacos-group/nacos-sdk-go/v2/common/constantgithub.com/nacos-group/nacos-sdk-go/v2/modelgithub.com/nacos-group/nacos-sdk-go/v2/utilgithub.com/nacos-group/nacos-sdk-go/v2/vo
)func main() {// 创建 ServerConfig配置 Nacos 服务器地址、端口及上下文路径sc : []constant.ServerConfig{*constant.NewServerConfig(192.168.195.129, 8848, constant.WithContextPath(/nacos)),}// 创建 ClientConfig配置客户端的基本参数如命名空间、超时时间、日志路径等cc : *constant.NewClientConfig(constant.WithNamespaceId(ace1b5fe-80c3-4fab-b89a-625f9ff41093),constant.WithTimeoutMs(5000),constant.WithNotLoadCacheAtStart(true),constant.WithLogDir(/tmp/nacos/log),constant.WithCacheDir(/tmp/nacos/cache),constant.WithLogLevel(debug),constant.WithUsername(nacos), // 用户名constant.WithPassword(nacos), // 密码)// 创建命名服务客户端client, err : clients.NewNamingClient(vo.NacosClientParam{ClientConfig: cc,ServerConfigs: sc,},)if err ! nil {panic(err) // 如果客户端创建失败则抛出异常}// 注册服务实例到 NacosregisterServiceInstance(client, vo.RegisterInstanceParam{Ip: 10.0.0.10, // 服务实例的 IP 地址Port: 8848, // 服务实例的端口号ServiceName: test.go, // 服务名称GroupName: group-a, // 分组名称ClusterName: cluster-a, // 集群名称Weight: 10, // 权重Enable: true, // 是否启用Healthy: true, // 是否健康Ephemeral: true, // 是否为临时实例Metadata: map[string]string{idc: shanghai}, // 元数据信息})//从 Nacos 取消注册服务实例deRegisterServiceInstance(client, vo.DeregisterInstanceParam{Ip: 10.0.0.10, // 服务实例的 IP 地址Port: 8848, // 服务实例的端口号ServiceName: demo.go, // 服务名称GroupName: group-a, // 分组名称Cluster: cluster-a, // 集群名称Ephemeral: true, // 必须为临时实例})time.Sleep(1 * time.Second) // 等待 1 秒// 批量注册多个服务实例batchRegisterServiceInstance(client, vo.BatchRegisterInstanceParam{ServiceName: demo.go, // 服务名称GroupName: group-a, // 分组名称Instances: []vo.RegisterInstanceParam{{Ip: 10.0.0.10, // 第一个服务实例的 IP 地址Port: 8848, // 第一个服务实例的端口号Weight: 10, // 权重Enable: true, // 是否启用Healthy: true, // 是否健康Ephemeral: true, // 是否为临时实例ClusterName: cluster-a, // 集群名称Metadata: map[string]string{idc: shanghai}, // 元数据信息}, {Ip: 10.0.0.12, // 第二个服务实例的 IP 地址Port: 8848, // 第二个服务实例的端口号Weight: 7, // 权重Enable: true, // 是否启用Healthy: true, // 是否健康Ephemeral: true, // 是否为临时实例ClusterName: cluster-a, // 集群名称Metadata: map[string]string{idc: shanghai}, // 元数据信息}},})time.Sleep(1 * time.Second) // 等待 1 秒// 根据服务名称、分组名称和集群名称获取服务信息getService(client, vo.GetServiceParam{ServiceName: demo.go, // 服务名称GroupName: group-a, // 分组名称Clusters: []string{cluster-a}, // 集群名称列表})// 获取指定服务的所有实例selectAllInstances(client, vo.SelectAllInstancesParam{ServiceName: demo.go, // 服务名称GroupName: group-a, // 分组名称Clusters: []string{cluster-a}, // 集群名称列表})// 获取指定服务的健康实例selectInstances(client, vo.SelectInstancesParam{ServiceName: demo.go, // 服务名称GroupName: group-a, // 分组名称Clusters: []string{cluster-a}, // 集群名称列表HealthyOnly: true, // 仅获取健康实例})// 根据加权随机算法获取一个健康实例selectOneHealthyInstance(client, vo.SelectOneHealthInstanceParam{ServiceName: demo.go, // 服务名称GroupName: group-a, // 分组名称Clusters: []string{cluster-a}, // 集群名称列表})// 订阅服务变更当服务信息发生变化时会触发回调函数subscribeParam : vo.SubscribeParam{ServiceName: demo.go, // 服务名称GroupName: group-a, // 分组名称SubscribeCallback: func(services []model.Instance, err error) {fmt.Printf(callback return services:%s \n\n, util.ToJsonString(services)) // 变更时打印服务实例信息},}subscribe(client, subscribeParam)// 等待 3 秒让客户端从服务端拉取变更time.Sleep(3 * time.Second)// 更新服务实例信息updateServiceInstance(client, vo.UpdateInstanceParam{Ip: 10.0.0.11, // 更新后的 IP 地址Port: 8848, // 服务实例的端口号ServiceName: demo.go, // 服务名称GroupName: group-a, // 分组名称ClusterName: cluster-a, // 集群名称Weight: 10, // 权重Enable: true, // 是否启用Healthy: true, // 是否健康Ephemeral: true, // 是否为临时实例Metadata: map[string]string{idc: beijing1}, // 更新后的元数据信息})// 等待 3 秒让客户端从服务端拉取变更time.Sleep(3 * time.Second)// 取消订阅服务变更unSubscribe(client, subscribeParam)// 获取指定分组下的所有服务名称列表getAllService(client, vo.GetAllServiceInfoParam{GroupName: group-a, // 分组名称PageNo: 1, // 分页页码PageSize: 10, // 每页大小})
}//以下为函数实现// registerServiceInstance 向 Nacos 注册一个服务实例
func registerServiceInstance(client naming_client.INamingClient, param vo.RegisterInstanceParam) {// 调用 RegisterInstance 方法注册服务实例success, err : client.RegisterInstance(param)if !success || err ! nil {// 如果注册失败抛出 panic 并打印错误信息panic(RegisterServiceInstance failed! err.Error())}// 打印注册参数和结果fmt.Printf(RegisterServiceInstance,param:%v,result:%v \n\n, param, success)
}// batchRegisterServiceInstance 向 Nacos 批量注册多个服务实例
func batchRegisterServiceInstance(client naming_client.INamingClient, param vo.BatchRegisterInstanceParam) {// 调用 BatchRegisterInstance 方法批量注册服务实例success, err : client.BatchRegisterInstance(param)if !success || err ! nil {// 如果批量注册失败抛出 panic 并打印错误信息panic(BatchRegisterServiceInstance failed! err.Error())}// 打印批量注册参数和结果fmt.Printf(BatchRegisterServiceInstance,param:%v,result:%v \n\n, param, success)
}// deRegisterServiceInstance 从 Nacos 取消注册一个服务实例
func deRegisterServiceInstance(client naming_client.INamingClient, param vo.DeregisterInstanceParam) {// 调用 DeregisterInstance 方法取消注册服务实例success, err : client.DeregisterInstance(param)if !success || err ! nil {// 如果取消注册失败抛出 panic 并打印错误信息panic(DeRegisterServiceInstance failed! err.Error())}// 打印取消注册参数和结果fmt.Printf(DeRegisterServiceInstance,param:%v,result:%v \n\n, param, success)
}// updateServiceInstance 更新 Nacos 中已注册的服务实例信息
func updateServiceInstance(client naming_client.INamingClient, param vo.UpdateInstanceParam) {// 调用 UpdateInstance 方法更新服务实例信息success, err : client.UpdateInstance(param)if !success || err ! nil {// 如果更新失败抛出 panic 并打印错误信息panic(UpdateInstance failed! err.Error())}// 打印更新参数和结果fmt.Printf(UpdateServiceInstance,param:%v,result:%v \n\n, param, success)
}// getService 从 Nacos 获取指定服务的信息
func getService(client naming_client.INamingClient, param vo.GetServiceParam) {// 调用 GetService 方法获取服务信息service, err : client.GetService(param)if err ! nil {// 如果获取服务信息失败抛出 panic 并打印错误信息panic(GetService failed! err.Error())}// 打印获取服务信息的参数和服务信息结果fmt.Printf(GetService,param:%v, result:%v \n\n, param, service)
}// selectAllInstances 从 Nacos 获取指定服务的所有实例
func selectAllInstances(client naming_client.INamingClient, param vo.SelectAllInstancesParam) {// 调用 SelectAllInstances 方法获取所有实例instances, err : client.SelectAllInstances(param)if err ! nil {// 如果获取所有实例失败抛出 panic 并打印错误信息panic(SelectAllInstances failed! err.Error())}// 打印获取所有实例的参数和实例信息结果fmt.Printf(SelectAllInstance,param:%v, result:%v \n\n, param, instances)
}// selectInstances 从 Nacos 获取指定服务的健康实例
func selectInstances(client naming_client.INamingClient, param vo.SelectInstancesParam) {// 调用 SelectInstances 方法获取健康实例instances, err : client.SelectInstances(param)if err ! nil {// 如果获取健康实例失败抛出 panic 并打印错误信息panic(SelectInstances failed! err.Error())}// 打印获取健康实例的参数和实例信息结果fmt.Printf(SelectInstances,param:%v, result:%v \n\n, param, instances)
}// selectOneHealthyInstance 从 Nacos 获取一个健康实例使用加权随机算法
func selectOneHealthyInstance(client naming_client.INamingClient, param vo.SelectOneHealthInstanceParam) {// 调用 SelectOneHealthyInstance 方法获取一个健康实例instances, err : client.SelectOneHealthyInstance(param)if err ! nil {// 如果获取健康实例失败抛出 panic 并打印错误信息panic(SelectOneHealthyInstance failed!)}// 打印获取健康实例的参数和实例信息结果fmt.Printf(SelectOneHealthyInstance,param:%v, result:%v \n\n, param, instances)
}// subscribe 订阅 Nacos 中指定服务的变化
func subscribe(client naming_client.INamingClient, param *vo.SubscribeParam) {// 调用 Subscribe 方法订阅服务变化client.Subscribe(param)
}// unSubscribe 取消订阅 Nacos 中指定服务的变化
func unSubscribe(client naming_client.INamingClient, param *vo.SubscribeParam) {// 调用 Unsubscribe 方法取消订阅服务变化client.Unsubscribe(param)
}// getAllService 从 Nacos 获取指定分组下的所有服务名称列表
func getAllService(client naming_client.INamingClient, param vo.GetAllServiceInfoParam) {// 调用 GetAllServicesInfo 方法获取所有服务名称列表service, err : client.GetAllServicesInfo(param)if err ! nil {// 如果获取服务名称列表失败抛出 panic 并打印错误信息panic(GetAllService failed!)}// 打印获取服务名称列表的参数和服务名称列表结果fmt.Printf(GetAllService,param:%v, result:%v \n\n, param, service)
}服务的注册
registerServiceInstance(client, vo.RegisterInstanceParam{Ip: 10.0.0.10, // 服务实例的 IP 地址Port: 8848, // 服务实例的端口号ServiceName: test.go, // 服务名称GroupName: group-a, // 分组名称ClusterName: cluster-a, // 集群名称Weight: 10, // 权重Enable: true, // 是否启用Healthy: true, // 是否健康Ephemeral: true, // 是否为临时实例Metadata: map[string]string{idc: shanghai}, // 元数据信息
})这里通过调用函数实现服务的注册其中test.go只是是服务的名称在注册服务之后可以通过通过服务实例的ip地址和端口号进行访问随后访问这些地址上运行的实际程序。
而这个函数是我们自己实现的我们可以来看看函数的内部
func registerServiceInstance(client naming_client.INamingClient, param vo.RegisterInstanceParam) {// 调用 RegisterInstance 方法注册服务实例success, err : client.RegisterInstance(param)if !success || err ! nil {// 如果注册失败抛出 panic 并打印错误信息panic(RegisterServiceInstance failed! err.Error())}// 打印注册参数和结果fmt.Printf(RegisterServiceInstance,param:%v,result:%v \n\n, param, success)
}这里直接通过调用client的方法来为我们注册服务而这个client可以和nacos服务器进行通信可以注册、取消注册、更新服务实例的信息以及从 Nacos 服务器获取这些信息。 取消服务的注册
deRegisterServiceInstance(client, vo.DeregisterInstanceParam{Ip: 10.0.0.10, // 服务实例的 IP 地址Port: 8848, // 服务实例的端口号ServiceName: demo.go, // 服务名称GroupName: group-a, // 分组名称Cluster: cluster-a, // 集群名称Ephemeral: true, // 必须为临时实例
})取消注册服务以上均为必须要传递的参数用于匹配将要取消注册的服务实例
实现函数
func deRegisterServiceInstance(client naming_client.INamingClient, param vo.DeregisterInstanceParam) {// 调用 DeregisterInstance 方法取消注册服务实例success, err : client.DeregisterInstance(param)if !success || err ! nil {// 如果取消注册失败抛出 panic 并打印错误信息panic(DeRegisterServiceInstance failed! err.Error())}// 打印取消注册参数和结果fmt.Printf(DeRegisterServiceInstance,param:%v,result:%v \n\n, param, success)
}和注册的方式类似直接通过调用cilent的方法并传递需要取消注册的服务实例的必要参数用于定位。 批量注册
batchRegisterServiceInstance(client, vo.BatchRegisterInstanceParam{ServiceName: demo.go, // 服务名称GroupName: group-a, // 分组名称Instances: []vo.RegisterInstanceParam{{Ip: 10.0.0.10, // 第一个服务实例的 IP 地址Port: 8848, // 第一个服务实例的端口号Weight: 10, // 权重Enable: true, // 是否启用Healthy: true, // 是否健康Ephemeral: true, // 是否为临时实例ClusterName: cluster-a, // 集群名称Metadata: map[string]string{idc: shanghai}, // 元数据信息}, {Ip: 10.0.0.12, // 第二个服务实例的 IP 地址Port: 8848, // 第二个服务实例的端口号Weight: 7, // 权重Enable: true, // 是否启用Healthy: true, // 是否健康Ephemeral: true, // 是否为临时实例ClusterName: cluster-a, // 集群名称Metadata: map[string]string{idc: shanghai}, // 元数据信息}},
})和名字一样可以想函数中传递多个参数用于注册服务但不同的一点是服务的名称和分组名称独立了出来这表示注册的服务均属于同一种服务和分组而此时传递的结构体中包含了多个instance实例(这个参数就是服务单独注册时使用到的结构体的切片)。
函数实现
func batchRegisterServiceInstance(client naming_client.INamingClient, param vo.BatchRegisterInstanceParam) {// 调用 BatchRegisterInstance 方法批量注册服务实例success, err : client.BatchRegisterInstance(param)if !success || err ! nil {// 如果批量注册失败抛出 panic 并打印错误信息panic(BatchRegisterServiceInstance failed! err.Error())}// 打印批量注册参数和结果fmt.Printf(BatchRegisterServiceInstance,param:%v,result:%v \n\n, param, success)
}无需多说也是通过调用方法来实现服务注册。 http实例自动注册服务
先看看代码的实现然后我会一步一步细说
package mainimport (contextfmtgithub.com/nacos-group/nacos-sdk-go/v2/clients/naming_clientnet/httposos/signalsyscalltimegithub.com/nacos-group/nacos-sdk-go/v2/clientsgithub.com/nacos-group/nacos-sdk-go/v2/common/constantgithub.com/nacos-group/nacos-sdk-go/v2/vo
)func main() {// 1. 创建 Nacos 客户端client : createNacosClient()// 2. 定义服务实例的元数据信息serviceName : servicetest // 服务名称groupName : group1 // 分组名称clusterName : cluster-a // 集群名称ip : 127.0.0.1 // 服务实例的 IP 地址当前虚拟机的 IP 地址port : 8080 // 服务实例的端口号metadata : map[string]string{ // 元数据信息idc: shanghai,}// 3. 注册服务实例到 NacosregisterServiceInstance(client, vo.RegisterInstanceParam{Ip: ip,Port: uint64(port),ServiceName: serviceName,GroupName: groupName,ClusterName: clusterName,Weight: 10,Enable: true,Healthy: true,Ephemeral: true,Metadata: metadata,})// 4. 启动 HTTP 服务http.HandleFunc(/, func(w http.ResponseWriter, r *http.Request) {fmt.Fprintf(w, Hello, this is demo.go service at %s:%d!, ip, port)})server : http.Server{Addr: fmt.Sprintf(%s:%d, ip, port),Handler: nil,}go func() {fmt.Printf(Starting HTTP server at http://%s:%d\n, ip, port)if err : server.ListenAndServe(); err ! nil err ! http.ErrServerClosed {fmt.Printf(HTTP server failed: %v\n, err)}}()// 5. 监听系统信号实现优雅关闭quit : make(chan os.Signal, 1)signal.Notify(quit, syscall.SIGINT, syscall.SIGTERM)-quitfmt.Println(Shutting down server...)// 6. 取消注册服务实例deRegisterServiceInstance(client, vo.DeregisterInstanceParam{Ip: ip,Port: uint64(port),ServiceName: serviceName,GroupName: groupName,Cluster: clusterName,Ephemeral: true,})// 7. 关闭 HTTP 服务ctx, cancel : context.WithTimeout(context.Background(), 5*time.Second)defer cancel()if err : server.Shutdown(ctx); err ! nil {fmt.Printf(HTTP server shutdown failed: %v\n, err)}fmt.Println(Server exited gracefully)
}// createNacosClient 创建 Nacos 客户端
func createNacosClient() naming_client.INamingClient {// 创建 ServerConfigsc : []constant.ServerConfig{*constant.NewServerConfig(192.168.195.129, // Nacos 服务器的 IP 地址8848, // Nacos 服务器的端口号constant.WithContextPath(/nacos), // Nacos 服务器的上下文路径),}// 创建 ClientConfigcc : *constant.NewClientConfig(constant.WithNamespaceId(), // 命名空间 IDconstant.WithTimeoutMs(5000), // 超时时间constant.WithNotLoadCacheAtStart(true), // 启动时不加载缓存constant.WithLogDir(/tmp/nacos/log), // 日志目录constant.WithCacheDir(/tmp/nacos/cache), // 缓存目录constant.WithLogLevel(debug), // 日志级别constant.WithUsername(nacos),constant.WithPassword(nacos),)// 创建命名服务客户端client, err : clients.NewNamingClient(vo.NacosClientParam{ClientConfig: cc,ServerConfigs: sc,},)if err ! nil {panic(Failed to create Nacos client: err.Error())}return client
}// registerServiceInstance 向 Nacos 注册一个服务实例
func registerServiceInstance(client naming_client.INamingClient, param vo.RegisterInstanceParam) {success, err : client.RegisterInstance(param)if !success || err ! nil {panic(Failed to register service instance: err.Error())}fmt.Printf(Registered service instance: %v\n, param)
}wd// deRegisterServiceInstance 从 Nacos 取消注册一个服务实例
func deRegisterServiceInstance(client naming_client.INamingClient, param vo.DeregisterInstanceParam) {success, err : client.DeregisterInstance(param)if !success || err ! nil {panic(Failed to deregister service instance: err.Error())}fmt.Printf(Deregistered service instance: %v\n, param)
}创建client
第一步便是我们的创建client此时我们也需要serverconfig和clientconfig
但是注册的client类型却不一样,注意我们之前crud的时候采取的并不是naming client而是configclient此处需要注意以下
func createNacosClient() naming_client.INamingClient {// 创建 ServerConfigsc : []constant.ServerConfig{*constant.NewServerConfig(192.168.195.129, // Nacos 服务器的 IP 地址8848, // Nacos 服务器的端口号constant.WithContextPath(/nacos), // Nacos 服务器的上下文路径),}// 创建 ClientConfigcc : *constant.NewClientConfig(constant.WithNamespaceId(), // 命名空间 IDconstant.WithTimeoutMs(5000), // 超时时间constant.WithNotLoadCacheAtStart(true), // 启动时不加载缓存constant.WithLogDir(/tmp/nacos/log), // 日志目录constant.WithCacheDir(/tmp/nacos/cache), // 缓存目录constant.WithLogLevel(debug), // 日志级别constant.WithUsername(nacos),constant.WithPassword(nacos),)// 创建命名服务客户端client, err : clients.NewNamingClient(vo.NacosClientParam{ClientConfig: cc,ServerConfigs: sc,},)if err ! nil {panic(Failed to create Nacos client: err.Error())}return client
}其他都是一样的需要指定注册在哪一个服务器哪一个命名空间。
注册服务到nacos服务器
serviceName : servicetest // 服务名称
groupName : group1 // 分组名称
clusterName : cluster-a // 集群名称
ip : 127.0.0.1 // 服务实例的 IP 地址当前虚拟机的 IP 地址
port : 8080 // 服务实例的端口号
metadata : map[string]string{ // 元数据信息idc: shanghai,
}// 3. 注册服务实例到 Nacos
registerServiceInstance(client, vo.RegisterInstanceParam{Ip: ip,Port: uint64(port),ServiceName: serviceName,GroupName: groupName,ClusterName: clusterName,Weight: 10,Enable: true,Healthy: true,Ephemeral: true,Metadata: metadata,
})此处我们需要指定当前服务实例所在的ip端口以及服务名称等一系列参数这里只是想nacos服务器表示了这个服务时存在的随后我们再启动我们的http服务。
启动http服务
http.HandleFunc(/, func(w http.ResponseWriter, r *http.Request) {fmt.Fprintf(w, Hello, this is demo.go service at %s:%d!, ip, port)
})server : http.Server{Addr: fmt.Sprintf(%s:%d, ip, port),Handler: nil,
}go func() {fmt.Printf(Starting HTTP server at http://%s:%d\n, ip, port)if err : server.ListenAndServe(); err ! nil err ! http.ErrServerClosed {fmt.Printf(HTTP server failed: %v\n, err)}
}()这里无需多说就是随便启动了一个http服务
优雅结束
// 5. 监听系统信号实现优雅关闭
quit : make(chan os.Signal, 1)
signal.Notify(quit, syscall.SIGINT, syscall.SIGTERM)
-quitfmt.Println(Shutting down server...)// 6. 取消注册服务实例
deRegisterServiceInstance(client, vo.DeregisterInstanceParam{Ip: ip,Port: uint64(port),ServiceName: serviceName,GroupName: groupName,Cluster: clusterName,Ephemeral: true,
})// 7. 关闭 HTTP 服务
ctx, cancel : context.WithTimeout(context.Background(), 5*time.Second)
defer cancel()
if err : server.Shutdown(ctx); err ! nil {fmt.Printf(HTTP server shutdown failed: %v\n, err)
}fmt.Println(Server exited gracefully)最后优雅的结束。 结语
关于这篇文章主要写出来也是想逼自己去看看官方的示例以便于自己更能理解nacos是怎么运作的在此之前我网上查了很多资料也问了AI但都没学到什么东西说实话毕竟Golang目前的学习环境跟java比起来真的差远了反而今晚上看了一会官方给的示例让我收获很大…
所以真的得去看官方的文档。
以上就是我今天所学到的内容希望对你也会有帮助如果有问题欢迎给我留言
毕竟我也只是个初学者如果有错误希望包涵以下
