From b5a164788c55f1170983c6b6a061bc096a3bd1e2 Mon Sep 17 00:00:00 2001
From: kanade <kanade@kumo.work>
Date: Fri, 12 Dec 2025 17:21:34 +0800
Subject: [PATCH] =?UTF-8?q?fix(client):=20=E7=A7=BB=E9=99=A4=E5=AF=B9=20ik?=
 =?UTF-8?q?3cloud=20=E7=9A=84=E7=A1=AC=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

- 删除了针对 ik3cloud 的特殊处理逻辑
- 统一使用 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