java 反射

1.service层

@Component("orderService")
public class OrderServiceImpl implements OrderService {
	
	@Autowired
	private OrderDao orderDao;
	
	public String queryOrderList(String param) {
		
		System.out.println("这是测试的："+param+":"+orderDao.queryOrderInfo());
		
		return param+":"+orderDao.queryOrderInfo();
	}
	
    public String queryProductList(String[] param) {
		
    	System.out.println("这是测试的："+JSON.toJSONString(param)+":"+orderDao.queryProductList());
    	
		return param+":"+orderDao.queryProductList();
	}

	public void queryOrderInfoQueue() {
		try {
			CountDownLatch latch = new CountDownLatch(2);
			
			QueueMessage queueMessage = new QueueMessage();
			
			OrderNotice orderNotice = new OrderNotice(latch);
			
			queueMessage.send(this, "queryOrderList", new String[]{"orderinfo"}, orderNotice);
			
			String productParam = "productInfo";
			Object[] productObjects = new Object[1];
			productObjects[0] = productParam;
			
			ProductNotice productNotice = new ProductNotice(latch);
			
			queueMessage.send(this, "queryProductList", productObjects, productNotice);
			
			latch.await();
			
			System.out.println("订单信息："+orderNotice.result);
			System.out.println("产品信息:"+productNotice.result);
			
		//	test(new String[]{"参数1","参数2"}, "queryProductList");
		
        } catch (Exception e) {
			System.out.println("日志处理："+e);
		}
	}
	
	/*public void test(Object[] parametersT,String methodT) {
		Class clazz = this.getClass();
		Object result = null;
		try {
			Object[] parameters = parametersT;
			Class[] parameterTypes = null;
			if(parameters!=null) {				
				parameterTypes = new Class[parameters.length];
				
				for(int i=0;i<parameters.length;i++) {
					parameterTypes[i] = parameters[i].getClass();
				}
			}
			Method method = clazz.getMethod(methodT,new Class[]{String[].class});
			//method.setAccessible(true);
			result = method.invoke(this, new Object[]{parametersT});
			
		} catch (Exception e) {
			
		} finally{
			
		}
	}*/
	
}

 2.QueueMessage

public class QueueMessage {

	ExecutorService pool = Executors.newCachedThreadPool();
	
	public void send(Object object,String method,Object[] parameters,ExecutionResultNotice notice) {
		Message message = new Message();
		message.setObject(object);
		message.setMethod(method);
		message.setParameters(parameters);
		message.setNotice(notice);
		
		MessageServiceExecutor service = new MessageServiceExecutor(message);
		
		try {
			pool.execute(service);
		} catch (Exception e) {
			e.printStackTrace();
		}
		
	}
	
}

 3.Message

public class Message {

	private Object object;
	private String method;
	private Object[] parameters;
	private ExecutionResultNotice notice;
	
	public Object getObject() {
		return object;
	}
	public void setObject(Object object) {
		this.object = object;
	}
	public String getMethod() {
		return method;
	}
	public void setMethod(String method) {
		this.method = method;
	}
	public Object[] getParameters() {
		return parameters;
	}
	public void setParameters(Object[] parameters) {
		this.parameters = parameters;
	}
	public ExecutionResultNotice getNotice() {
		return notice;
	}
	public void setNotice(ExecutionResultNotice notice) {
		this.notice = notice;
	}
}

 4.MessageServiceExecutor

public class MessageServiceExecutor implements Runnable {

	private Message message;
	
	public MessageServiceExecutor(Message message) {
		this.message = message;
	}

	public void run() {
		Class clazz = message.getObject().getClass();
		Object result = null;
		try {
			Object[] parameters = message.getParameters();
			Class[] parameterTypes = null;
			if(parameters!=null) {				
				parameterTypes = new Class[parameters.length];
				
				for(int i=0;i<parameters.length;i++) {
					parameterTypes[i] = parameters[i].getClass();
				}
			}
			Method method = clazz.getMethod(message.getMethod(),parameterTypes);
			result = method.invoke(message.getObject(), message.getParameters());
			
			
		} catch (Exception e) {
			message.getNotice().notice("异常:"+e);
		} finally{
			message.getNotice().notice(result);
		}
		
	}
}