动态Call远程RPC服务

cluster/cluster.go

@@ -499,3 +499,18 @@ func GetNodeName(nodeid int) string {
 	//
 	return _self.cfg.GetNodeNameByNodeId(nodeid)
 }
+
+func DynamicCall(address string, serviceMethod string, args interface{}, reply interface{}) error {
+	//conn, err := rpc.DialHTTP("tcp", "127.0.0.1:8095")
+	rpcClient, err := rpc.Dial("tcp", address)
+	if err != nil {
+		return err
+	}
+	defer rpcClient.Close()
+	err = rpcClient.Call(serviceMethod, args, reply)
+	if err != nil {
+		return err
+	}
+
+	return nil
+}