最简单的JAVA RPC框架实现

/** * Created on 2018年5月9日 by caiming */ package com.demo; import java.io.ObjectInputStream; import java.io.ObjectOutputStream; import java.lang.reflect.InvocationHandler; import java.lang.reflect.Method; import java.lang.reflect.Proxy; import java.net.InetSocketAddress; import java.net.Socket; /** * * @Title 本地服務代理类 * @Description 1、将本地的接口调用转换成JDK的动态代理，在动态代理中实现接口的远程调用 * 2、创建Socket客户端，根据指定地址连接远程服务提供者 * 3、将远程服务调用所需的接口类、方法名、参数列表等编码后发送给服务提供者 4、同不阻塞等待服务端返回应答，获取应答之后返回 * @author caiming * @version 1.0 * @修改记录 * @修改序号，修改日期，修改人，修改内容 */ public class RpcImporter<S> { @SuppressWarnings("unchecked") public S importer(final Class<?> interfaceClass, final InetSocketAddress addr) { return (S) Proxy.newProxyInstance(interfaceClass.getClassLoader(), new Class<?>[] { interfaceClass }, new InvocationHandler() { @Override public Object invoke(Object proxy, Method method, Object[] arg2) throws Throwable { Socket socket = null; ObjectOutputStream output = null; ObjectInputStream input = null; try { socket = new Socket(); socket.connect(addr); output = new ObjectOutputStream(socket.getOutputStream()); output.writeUTF(interfaceClass.getName()); output.writeUTF(method.getName()); output.writeObject(method.getParameterTypes()); output.writeObject(arg2); input = new ObjectInputStream(socket.getInputStream()); return input.readObject(); } finally { if (socket != null) { socket.close(); } if (output != null) { output.close(); } if (input != null) { input.close(); } } } }); } }