rpc 实现原理

先说一下rpc 的调用过程

客户端：知道接口名和方法名，以及参数类型、调用参数的值 ，但是本地并没有该接口的实现

服务端：这里有接口的实现

调用时，客户端使用JDK动态代理，利用接口创建了一个代理对象

创建代理对象需要两个东西：

1、一个就是接口的全限定名(包名+接口名)，

2、还需要一个调用处理接口 InvocationHandler 的实现

说明：每次使用代理对象调用方法时，其实调用的是 InvocationHandler 接口的实现中的invoke 方法

invoke  方法中的实现了远程调用：

        1、根据服务端的IP 和端口号，创建一个socketServer ,

        2、将接口全限定名、方法名、参数类型、参数值、通过socket 传递到服务端

        3、服务端根据接口名获得接口的实现类的实例对象，使用反射调用该方法，得到执行结果

        4、将执行结果写入socket ,传递给客户端

        5、客户端得到结果返回结果

这里是invoke代码

@Override
public Object invoke(Object proxy, Method method, Object[] args) throws Throwable
{
// 把调用服务所需的信息封装到bean中
InvokerBean invokerBean = new InvokerBean(name, new RPCMethod(method.getName(), method.getParameterTypes()),
args);

// 启动socket
Socket client = new Socket(address, port);

// 把序列化对象转换成流，使用JDK自带的ObjectOutputStream
ObjectOutputStream oos = new ObjectOutputStream(client.getOutputStream());
oos.writeObject(invokerBean);
oos.flush();

// 读取服务端返回的结果
ObjectInputStream ois = new ObjectInputStream(client.getInputStream());
invokerBean = (InvokerBean) ois.readObject();

oos.close();
ois.close();
client.close();

return invokerBean.getResult();
}

整个过程就是rpc 的基本实现原理