Repository navigation
Expand file tree
/
Copy pathRemoteFunction.java
More file actions
executable file
·141 lines (116 loc) · 5.03 KB
/
Copy pathRemoteFunction.java
File metadata and controls
executable file
·141 lines (116 loc) · 5.03 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
/*Copyright ©2016 TommyLemon(https://github.com/TommyLemon/APIJSON)
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.*/
package zuo.biao.apijson.server;
import java.lang.reflect.InvocationTargetException;
import com.alibaba.fastjson.JSONObject;
import zuo.biao.apijson.NotNull;
import zuo.biao.apijson.StringUtil;
/**可远程调用的函数类
* @author Lemon
*/
public class RemoteFunction {
// private static final String TAG = "RemoteFunction";
/**反射调用
* @param fun
* @param request
* @param function 例如get(Map:map,key)，参数只允许引用，不能直接传值
* @return
*/
public static Object invoke(@NotNull RemoteFunction fun, @NotNull JSONObject request, @NotNull String function) throws Exception {
int start = function.indexOf("(");
int end = function.lastIndexOf(")");
String method = function.substring(0, start);
if (StringUtil.isEmpty(method, true)) {
throw new IllegalArgumentException("字符 " + function + " 不合法！远程函数的名称function不能为空，"
+ "且必须为 function(key0,key1,...) 这种单函数格式！"
+ "\nfunction必须符合Java函数命名，key是用于在request内取值的键！");
}
String[] keys = StringUtil.split(function.substring(start + 1, end));
int length = keys == null ? 0 : keys.length;
Class<?>[] types = new Class<?>[length + 1];
types[0] = JSONObject.class;
Object[] values = new Object[length + 1];
values[0] = request;
for (int i = 0; i < length; i++) {
types[i + 1] = String.class;
values[i + 1] = keys[i];
}
//碰到null就挂了！！！Number还得各种转换不灵活！不如直接传request和对应的key到函数里，函数内实现时自己 getLongValue,getJSONObject ...
// for (int i = 0; i < length; i++) {
// v = values[i] = request == null ? null : request.get(keys[i]);
// if (v instanceof Boolean) {
// types[i] = Boolean.class; //只支持JSON的几种类型
// }
// else if (v instanceof Number) {
// types[i] = Number.class;
// }
// else if (v instanceof String) {
// types[i] = String.class;
// }
// else if (v instanceof JSONObject) { // Map) {
// types[i] = JSONObject.class;
// //性能比较差 values[i] = request.getJSONObject(keys[i]);
// }
// else if (v instanceof JSONArray) { // Collection) {
// types[i] = JSONArray.class;
// //性能比较差 values[i] = request.getJSONArray(keys[i]);
// }
// else { //FIXME 碰到null就挂了！！！
// throw new UnsupportedDataTypeException(keys[i] + ":value 中value不合法！远程函数 key():" + function + " 中的arg对应的值类型"
// + "只能是 [Boolean, Number, String, JSONObject, JSONArray] 中的一种！");
// }
// }
try {
return invoke(fun, method, types, values);
} catch (Exception e) {
if (e instanceof NoSuchMethodException) {
throw new IllegalArgumentException("字符 " + function + " 对应的远程函数 " + getFunction(method, keys) + " 不在后端工程的DemoFunction内！"
+ "\n请检查函数名和参数数量是否与已定义的函数一致！"
+ "\n且必须为 function(key0,key1,...) 这种单函数格式！"
+ "\nfunction必须符合Java函数命名，key是用于在request内取值的键！"
+ "\n调用时不要有空格！");
}
if (e instanceof InvocationTargetException) {
Throwable te = ((InvocationTargetException) e).getTargetException();
if (StringUtil.isEmpty(te.getMessage(), true) == false) { //到处把函数声明throws Exception改成throws Throwable挺麻烦
throw te instanceof Exception ? (Exception) te : new Exception(te.getMessage());
}
throw new IllegalArgumentException("字符 " + function + " 对应的远程函数传参类型错误！"
+ "\n请检查 key:value 中value的类型是否满足已定义的函数 " + getFunction(method, keys) + " 的要求！");
}
throw e;
}
}
/**反射调用
* @param methodName
* @param parameterTypes
* @param args
* @return
*/
public static Object invoke(@NotNull RemoteFunction fun, @NotNull String methodName, @NotNull Class<?>[] parameterTypes, @NotNull Object[] args) throws Exception {
return fun.getClass().getDeclaredMethod(methodName, parameterTypes).invoke(fun, args);
}
/**
* @param method
* @param keys
* @return
*/
public static String getFunction(String method, String[] keys) {
String f = method + "(JSONObject request";
if (keys != null) {
for (int i = 0; i < keys.length; i++) {
f += (", String " + keys[i]);
}
}
f += ")";
return f;
}
}