remotecall.java

一个简单的java邮件系统源码

package com.easyjf.web.ajax;

import java.lang.reflect.Method;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Comparator;
import java.util.List;
import java.util.Map;

import org.apache.log4j.Logger;

import com.easyjf.beans.BeanUtils;
import com.easyjf.beans.BeanWrapper;
import com.easyjf.util.ClassUtils;
import com.easyjf.web.exception.FrameworkException;

/**
 * 这个类主要用来执行远程调操作
 * @author 大峡
 *@since 2006-12-29
 */
public class RemoteCall {
private static final Logger logger =Logger.getLogger(RemoteCall.class);
private String serviceName;
private String methodName;
private Map paras;
public RemoteCall(String serviceName,String methodName,Map paras)
{
	this.serviceName=serviceName;
	this.methodName=methodName;
	this.paras=paras;
}
public String execute() throws Exception
{
	Object service=AjaxUtil.getServiceContainer().getService(serviceName);
	if(service==null)throw new ServiceNotAvailableException(serviceName);
	CallParameter[] ps=convertJsonParamater(paras);
	Class[] clzs = new Class[ps.length];
	Object[] objs = new Object[ps.length];
	convertCallParameter2Obj(clzs, objs, ps);	
	Method method = service.getClass().getMethod(methodName, clzs);	
	if(!AjaxUtil.isRemoteMethod(serviceName,method))throw new MethodNotAvailableException(method);
	Object result = method.invoke(service, objs);
	return AjaxUtil.getJSON(result);
}
public CallParameter[] convertJsonParamater(Map map)
{
	java.util.Map propertys = new java.util.HashMap();
	java.util.Iterator it = map.keySet().iterator();		
	while (it.hasNext()) {
		String name = (String) it.next();
		logger.debug("remote call paramater's name:"+name);
		logger.debug("parameter value:"+map.get("name"));
		if (name.length() > 10
				&& name.substring(0, 11).equals("ajax-call-p")) {
			String index = name.substring(11, name.indexOf('.', 11));
			addProperty(propertys, Integer.parseInt(index), name
					.substring(name.indexOf('.', 11) + 1), map.get(name));
		}
	}
	List ps = new ArrayList(propertys.values());
	java.util.Collections.sort(ps, new Comparator() {
		public int compare(Object arg0, Object arg1) {
			return ((CallParameter) arg0).getIndex()
					- ((CallParameter) arg1).getIndex();
		}
	});
	CallParameter[] cps=new CallParameter[ps.size()];
	ps.toArray(cps);
	return cps;
}
public void convertCallParameter2Obj(Class[] clzs,Object[] objs,CallParameter[] ps)
{
	for (int i = 0; i < ps.length; i++) {
		CallParameter parameter = ps[i];
		clzs[i] = ps[i].getType();			
		if(ClassUtils.isPrimitiveOrWrapper(clzs[i])||clzs[i]==String.class)
		{
			if(parameter.getPropetys().get("value")!=null)
			objs[i]=JSonConvertUtil.simpleConvert((String)parameter.getPropetys().get("value"), clzs[i]);//,new Object[]{});
		}
		else if(Number.class.isAssignableFrom(clzs[i]) || java.util.Date.class.isAssignableFrom(clzs[i]))
		{
			objs[i]=com.easyjf.beans.BeanUtils.convertType(parameter.getPropetys().get("value"),clzs[i]);//,new Object[]{});
		}
		else if(clzs[i].isArray())
		{
			//数据组转换
			objs[i]=JSonConvertUtil.arrayConvert((String)parameter.getPropetys().get("value"),clzs[i]);
		}
		else if(Collection.class.isAssignableFrom(clzs[i])){
			//System.out.println("集合");
			objs[i]=JSonConvertUtil.collectionConvert((String)parameter.getPropetys().get("value"),clzs[i]);
		}
		else {
		objs[i] = BeanUtils.instantiateClass(clzs[i]);
		BeanWrapper wrapper = new BeanWrapper(objs[i]);	
		java.util.Iterator pvs=parameter.getPropetys().entrySet().iterator();
		while(pvs.hasNext())
		{
			Map.Entry en=(Map.Entry)pvs.next();
			String propertyName=(String)en.getKey();				
			if(propertyName.indexOf('.')>0){
				initBeanProperty(objs[i],propertyName);
			}
			if(wrapper.isWritableProperty(propertyName))
			wrapper.setPropertyValue((String)en.getKey(), en.getValue());	
		}		
		}
	}
}
public  void addProperty(java.util.Map map, int index, String name,
		Object value)  {
	CallParameter p = (CallParameter) map.get("property" + index);
	if (p == null) {
		p = new CallParameter();
		p.setIndex(index);
		//p.setName(name);
		map.put("property" + index, p);
	}
	if ("java-type".equalsIgnoreCase(name))
	{
		try{
		p.setType(ClassUtils.forName((String) value));
		}
		catch(Exception e)
		{
			throw new FrameworkException(e.getMessage());
		}
	}
	else
		p.addProperty(name, value);
}
//使用默认构造子初始化一个二级属性
public  void initBeanProperty(Object bean,String propertyName)
{
	String p=propertyName.substring(0,propertyName.indexOf('.'));
	BeanWrapper wrapper=new BeanWrapper(bean);
	if(wrapper.getPropertyValue(p)==null)wrapper.setPropertyValue(p, BeanUtils.instantiateClass(wrapper.getPropertyDescriptor(p).getPropertyType()));
	String nextp=propertyName.substring(propertyName.indexOf('.')+1);
	if(nextp.indexOf('.')>0){
		initBeanProperty(wrapper.getPropertyValue(p),nextp);
	}
}
}