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