package kernel.rmi;
|
|
import java.io.Serializable;
|
import java.lang.reflect.Method;
|
import java.util.Arrays;
|
|
import com.alibaba.fastjson.JSON;
|
|
import kernel.web.ApplicationUtil;
|
|
/**
|
* @author JORGE
|
* @description RMI实体
|
*/
|
public class RmiEntity implements Serializable{
|
/**
|
* 调用结果对象
|
*/
|
private Object result;
|
|
/**
|
* 方法参数列表
|
*/
|
private Object[] params;
|
|
/**
|
* 传输对象是否被序列化
|
*/
|
public boolean serialed;
|
|
/**
|
* 方法参数类型
|
*/
|
public Class<?>[] paramTypes;
|
|
/**
|
* 序列化版本ID
|
*/
|
private static final long serialVersionUID = -5588644542304795465L;
|
|
public RmiEntity(Object result,boolean... forces) {
|
if(null==result) return;
|
boolean force=(null==forces || 0==forces.length)?false:forces[0];
|
|
if(force) {
|
this.serialed=true;
|
this.result=JSON.toJSONString(result);
|
return;
|
}
|
|
if(result instanceof Serializable) {
|
this.result=result;
|
}else {
|
this.serialed=true;
|
this.result=JSON.toJSONString(result);
|
}
|
}
|
|
public RmiEntity(Method method,Object[] params,boolean... forces) {
|
if(0==method.getParameterCount()) return;
|
|
this.paramTypes=method.getParameterTypes();
|
boolean force=(null==forces || 0==forces.length)?false:forces[0];
|
|
if(force) {
|
this.serialed=true;
|
this.params=Arrays.stream(params).map(ele->null==ele?null:JSON.toJSONString(ele)).toArray();
|
return;
|
}
|
|
int len=params.length;
|
boolean requireSerialize=false;
|
for(int i=0;i<len;i++) {
|
if(! (params[i] instanceof Serializable)) {
|
requireSerialize=true;
|
break;
|
}
|
}
|
|
if(requireSerialize) {
|
this.serialed=true;
|
this.params=Arrays.stream(params).map(ele->null==ele?null:JSON.toJSONString(ele)).toArray();
|
return;
|
}else {
|
this.params=params;
|
}
|
}
|
|
public Object getResult(Method method) throws Throwable {
|
if(null==result) return null;
|
Object retObject=!serialed?result:JSON.parseObject((String)result,method.getGenericReturnType());
|
if(retObject instanceof Throwable) {
|
throw ApplicationUtil.getDeclaredCause((Throwable)retObject, method);
|
}else {
|
return retObject;
|
}
|
}
|
|
public Object[] getParams() {
|
if(!serialed) return params;
|
if(null==paramTypes) return null;
|
|
int len=paramTypes.length;
|
Object[] args=new Object[len];
|
for(int i=0;i<len;args[i]=JSON.parseObject((String)params[i],paramTypes[i++]));
|
|
return args;
|
}
|
}
|
