diff --git a/cluster/cluster.go b/cluster/cluster.go
index 2863349..0852c36 100644
--- a/cluster/cluster.go
+++ b/cluster/cluster.go
@@ -101,13 +101,15 @@ func (slf *CCluster) ListenService() error {
 		os.Exit(1)
 		return err2
 	}
+	go slf.AcceptRpc(tcplisten)
+	slf.ReSetLocalRpcClient()
+	return nil
+}
 
+func (slf *CCluster) ReSetLocalRpcClient() {
 	slf.reader, slf.writer = net.Pipe()
 	go rpc.ServeConn(slf.reader)
 	slf.LocalRpcClient = rpc.NewClient(slf.writer)
-
-	go slf.AcceptRpc(tcplisten)
-	return nil
 }
 
 type CPing struct {
@@ -172,6 +174,9 @@ func (slf *CCluster) ConnService() error {
 			v.pclient = client
 		}
 
+		if slf.LocalRpcClient.IsClosed() {
+			slf.ReSetLocalRpcClient()
+		}
 		time.Sleep(time.Second * 4)
 	}