commit

kinglong/control/main/control.go

@@ -63,14 +63,14 @@ func main() {
 
 			KillRpcClientMaster, err := rpc.Dial("tcp", commonConfig.CloudConfig.Hosts[0].Ip+":"+commonConfig.CloudConfig.RpcPort)
 			if err != nil {
-				log.GlobalLogger.Error("创建rpc连接master失败：", err)
-				KillRpcClientMaster.Close()
+				log.GlobalLogger.Error("创建rpc客户端连接master失败：", err)
+				// 此处关闭client会报错
 				continue
 			}
 			KillRpcClientSlave, err := rpc.Dial("tcp", commonConfig.CloudConfig.Hosts[1].Ip+":"+commonConfig.CloudConfig.RpcPort)
 			if err != nil {
-				log.GlobalLogger.Error("创建rpc连接slave失败：", err)
-				KillRpcClientSlave.Close()
+				log.GlobalLogger.Error("创建rpc客户端连接slave失败：", err)
+				// 此处关闭client会报错
 				continue
 			}
 

pji/control/main/control.go

@@ -57,8 +57,8 @@ func main() {
 
 			KillRpcClient, err := rpc.Dial("tcp", commonConfig.CloudConfig.Hosts[0].Ip+":"+commonConfig.CloudConfig.RpcPort)
 			if err != nil {
-				c_log.GlobalLogger.Error("创建rpc连接master失败：", err)
-				KillRpcClient.Close()
+				c_log.GlobalLogger.Error("创建rpc客户端连接master失败：", err)
+				// 此处关闭client会报错
 				continue
 			}