新增判断连接状态接口

cluster/cluster.go

@@ -145,3 +145,8 @@ func GetRpcClient(nodeId int,serviceMethod string) ([]*rpc.Client,error) {
 func GetRpcServer() *rpc.Server{
 	return &cluster.rpcServer
 }
+
+func (slf *Cluster) IsNodeConnected (nodeId int) bool {
+	pClient := slf.GetRpcClient(nodeId)
+	return pClient!=nil && pClient.IsConnected()
+}

network/tcp_conn.go

@@ -111,3 +111,7 @@ func (tcpConn *TCPConn) ReadMsg() ([]byte, error) {
 func (tcpConn *TCPConn) WriteMsg(args ...[]byte) error {
 	return tcpConn.msgParser.Write(tcpConn, args...)
 }
+
+func (tcpConn *TCPConn) IsConnected() bool {
+	return tcpConn.closeFlag == false
+}

rpc/client.go

@@ -219,3 +219,7 @@ func (slf *Client) Run(){
 
 func (slf *Client) OnClose(){
 }
+
+func (slf *Client) IsConnected() bool {
+	return slf.conn!=nil && slf.conn.IsConnected()==true
+}