手撕RPC

RPC(Remote Procedure Call Protocol)——远程过程调用协议，它是一种通过网络从远程计算机程序上请求服务，而不需要了解底层网络技术的协议。RPC协议假定某些传输协议的存在，如TCP/IP或UDP，为通信程序之间携带信息数据。RPC将原来的本地调用转变为调用远端的服务器上的方法，给系统的处理能力和吞吐量带来了近似于无限制提升的可能。在OSI网络通信模型中，RPC跨域了传输层和应用层。RPC使得开发包括网络分布式多程序在内的应用程序更加容易。

大白话一点，rpc对程序员朋友是透明的。你可以像调用本地方法一样调用远端方法，是两个JVM程序之间的信息交互。无论是本地方法还是远端方法，你直接用就可以了， 如果是远端方法剩下的交给RPC。

• RPC作用：

  • 进程间通讯
  • 提供和本地调用一样的调用机制
  • 屏蔽掉远程调用的细节实现

• 在spring中接口的调用是通过动态代理实现的，RPC自然也是。对JAVA来说调用方式有两种：

  • JDK动态代理
  • cglib代理

尽管cglib代理的实现更为强大和高效，cglib可以不需要接口类，jdk动态代理必须要有接口类，但是在使用时还是首选jdk动态代理，因为接口类肯定会提供的。cglib的代码不易维护。

• 调用流程

  
  调用流程.png

• 调用步骤：

  • 服务方暴露服务，并提供调用地址
  • 服务消费方以调用本地方法的方式调用服务
  • 接收到请求后，将方法，参数组装成能够进行消息传输的消息体
  • 找到服务地址，并将消息发送到服务端
  • server收到消息后进行解码
  • 根据解码结果调用本地服务
  • 本地服务执行，并将服务执行结果发送给消费方
  • 消费方收到消息后子进行解码，得到执行的结果

• 常用的分布式rpc:

  • dubbo , motan ,rpcx , grpc , thrift等

下面手撕代码

• 既然是调用远端服务，那么就必须在远端暴露一个服务，并提供调用地址，使用ServerSocker 来实现。

server端暴露服务.png

• 服务端暴露后，来写本地的动态代理方法，在本地调用时是通过动态代理来将请求转发到远端服务。

image.png

• 接口

public interface HelloRpc {
    public String helloRpc(String args);
    String hellRpc(String arg1, String arg2);
}

• 实现类

public class HelloRpcImpl implements HelloRpc {
    @Override
    public String helloRpc(String args) {
        return "HelloRPC : ---- " + args;
    }
    @Override
    public String hellRpc(String arg1, String arg2) {
        return "arg1 : " + arg1 + "args2:" + arg2;
    }
}

• 服务发布：

public static void main(String[] args) throws IOException {
    HelloRpcImpl helloRpc = new HelloRpcImpl();
        RpcFrame.server(helloRpc , 80);
}

• 消费调用：

public static void main(String[] args) {
    HelloRpc o = (HelloRpc) RpcFrame.helloRpc(HelloRpc.class, "127.0.0.1", 80);
    String hello = o.hellRpc("client !" , "verygood！");
    System.out.println(hello);
}

上面只是模拟rpc的实现方式，写的一段代码，市面上的rpc也不是这样搭建的。不过核心思想还是相同的。 但就dubbo而言，暴露的服务是要注册到zk上的，消费方如果需要某个服务，回去zk上查找，并在本地缓存。

• rpc与队列对比
  • 既然是两个服务之间的交互，为什么不用队列？
  • 队列是异步化的，对于同步返回的需求是没法满足的
  • rpc既可以做同步，也可以做异步