fix(client): 移除对 ik3cloud 的硬编码配置
- 删除了针对 ik3cloud 的特殊处理逻辑 - 统一使用 consul 进行服务发现 - 简化客户端初始化流程 - 修复潜在的配置冲突问题 - 提高代码可维护性 - 减少不必要的条件分支
This commit is contained in:
@@ -61,18 +61,9 @@ func GetClient(s interface{}) (*RpcClient, error) {
|
|||||||
mutex.Lock()
|
mutex.Lock()
|
||||||
xClient, ok = mClient.Load(key)
|
xClient, ok = mClient.Load(key)
|
||||||
if !ok {
|
if !ok {
|
||||||
var d client.ServiceDiscovery
|
d, err := consulClient.NewConsulDiscovery(basePath, servicePath, config.RpcConfig.RegistryServer, nil)
|
||||||
var err error
|
if err != nil {
|
||||||
if basePath == "ik3cloud" {
|
return nil, errors.New("系统异常")
|
||||||
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("系统异常")
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
option := client.DefaultOption
|
option := client.DefaultOption
|
||||||
option.Retries = 3
|
option.Retries = 3
|
||||||
|
|||||||
Reference in New Issue
Block a user