纯java 远程调用DEMO

package com.yzh; import java.io.IOException; import java.io.ObjectInputStream; import java.io.ObjectOutputStream; import java.lang.reflect.InvocationTargetException; import java.lang.reflect.Method; import java.net.ServerSocket; import java.net.Socket; /** * Created by yanzhaohui on 2017/8/2. */ public class Provider { public static void main(String[] args) { try { ServerSocket server = new ServerSocket(1234); while(true){ Socket socket = server.accept(); //读取服务信息 ObjectInputStream input = new ObjectInputStream(socket.getInputStream()); String interfaceName = input.readUTF();//接口名称 String methodName = input.readUTF();//方法名称 Class<?>[] parameterTypes = (Class<?>[])input.readObject(); Object[] arguments = (Object[])input.readObject(); //执行调用 Class serviceInterfaceClass = Class.forName(interfaceName);//得到接口的class //获取接口实现类 //Object service = services.get(interfaceName);//这里没有提供services对象。用new的方式代替 Object service = new SayHelloServiceImpl(); //获取要调用的方法 Method method = serviceInterfaceClass.getMethod(methodName,parameterTypes); //执行方法 Object result = method.invoke(service,arguments); //把结果返回给客户端 ObjectOutputStream output = new ObjectOutputStream(socket.getOutputStream()); System.out.println(result); output.writeObject(result); } } catch (IOException e) { e.printStackTrace(); } catch (ClassNotFoundException e) { e.printStackTrace(); } catch (NoSuchMethodException e) { e.printStackTrace(); } catch (InvocationTargetException e) { e.printStackTrace(); } catch (IllegalAccessException e) { e.printStackTrace(); } } }