From 6928ef5088b0077cfb1947cd2549958f89d3ceaf Mon Sep 17 00:00:00 2001 From: kanade Date: Tue, 9 Dec 2025 14:15:49 +0800 Subject: [PATCH] =?UTF-8?q?refactor(client):=20=E7=A7=BB=E9=99=A4=E6=9C=AC?= =?UTF-8?q?=E5=9C=B0=E5=BC=80=E5=8F=91=E7=8E=AF=E5=A2=83=E7=9A=84=E7=A1=AC?= =?UTF-8?q?=E7=BC=96=E7=A0=81=E9=85=8D=E7=BD=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 删除针对本地开发环境的硬编码服务发现配置 - 统一使用 Consul 作为服务发现机制 - 简化客户端初始化逻辑 - 提升代码可维护性和一致性 - 避免在生产环境中潜在的配置冲突 - 强制依赖注册中心以确保服务治理统一性 --- client/client.go | 15 +++------------ 1 file changed, 3 insertions(+), 12 deletions(-) diff --git a/client/client.go b/client/client.go index df6bd10..8b498d4 100644 --- a/client/client.go +++ b/client/client.go @@ -61,18 +61,9 @@ func GetClient(s interface{}) (*RpcClient, error) { mutex.Lock() xClient, ok = mClient.Load(key) if !ok { - var d client.ServiceDiscovery - var err error - if basePath == "ik3cloud" { - d, err = client.NewPeer2PeerDiscovery("tcp@localhost:8081", "") - if err != nil { - return nil, errors.New("系统异常") - } - } else { - d, err = consulClient.NewConsulDiscovery(basePath, servicePath, config.RpcConfig.RegistryServer, nil) - if err != nil { - return nil, errors.New("系统异常") - } + d, err := consulClient.NewConsulDiscovery(basePath, servicePath, config.RpcConfig.RegistryServer, nil) + if err != nil { + return nil, errors.New("系统异常") } option := client.DefaultOption option.Retries = 3