HDFS代码分析-RPC框架

古城微笑少年丶 2022-03-10 12:18 167阅读 0赞

## 什么是RPC框架: ##

RPC（Remote Procedure Call）—[远程过程调用][Link 1]，它是一种通过[网络][Link 2]从远程计算机程序上请求服务，而不需要了解底层网络技术的协议。[RPC协议][RPC]假定某些[传输协议][Link 3]的存在，如TCP或UDP，为通信程序之间携带信息数据。在OSI[网络通信][Link 4]模型中，RPC跨越了[传输层][Link 5]和[应用层][Link 6]。RPC使得开发包括网络[分布式][Link 7]多程序在内的应用程序更加容易。

RPC采用客户机/服务器模式。请求程序就是一个客户机，而服务提供程序就是一个服务器。首先，客户机调用进程发送一个有进程参数的调用信息到服务进程，然后等待应答信息。在服务器端，进程保持睡眠状态直到调用信息到达为止。当一个调用信息到达，服务器获得进程参数，计算结果，发送答复[信息][Link 8]，然后等待下一个调用信息，最后，客户端调用进程接收答复信息，获得进程结果，然后调用执行继续进行。

### 简单来说就是:  ###

服务器A和服务器B同时都内部实现同一个抽象类,但是服务器B有对抽象类的具体实现的子类,而服务器A没有,但是服务器A使用动态代理来实现这个抽象类,果服务器A调用对象函数,这时代理会拦截函数调用,携带函数参数发送socket请求给服务器B,服务器B可以调用子类的具体实现的函数并且将函数返回值使用socket方式返回.

### 抽象类: ###

package com.sy.rpc.service;
    
    public interface LoginServerInterface {
    
        public static final long versionID = 1L;
        String login(String username,String password);
    
    
    }

### 服务器A代码: ###

package com.sy.rpc;
    
    import com.sy.rpc.service.LoginServerInterface;
    import org.apache.hadoop.conf.Configuration;
    import org.apache.hadoop.ipc.RPC;
    
    import java.io.IOException;
    import java.net.InetSocketAddress;
    
    public class RpcClientScript {
        public static void main(String[] args) throws IOException {
            LoginServerInterface loginServer =RPC.getProxy(LoginServerInterface.class,
                    LoginServerInterface.versionID,
                    new InetSocketAddress("127.0.0.1",1300), new Configuration());
            String str = loginServer.login("老王","123");
            System.out.println(str);
    
        }
    }

### 服务器B代码: ###

package com.sy.rpc;
    
    import com.sy.rpc.service.LoginServerInterface;
    import com.sy.rpc.service.imp.LoginServerImp;
    import org.apache.hadoop.conf.Configuration;
    import org.apache.hadoop.ipc.RPC;
    
    import java.io.IOException;
    
    public class RpcServerScript {
        public static void main(String[] args) throws IOException {
            RPC.Builder builder = new RPC.Builder(new Configuration());
            builder.setBindAddress("127.0.0.1");
            builder.setPort(1300);
            builder.setProtocol(LoginServerInterface.class);
            builder.setInstance(new LoginServerImp());
            RPC.Server server = builder.build();
            server.start();
        }
    }

### 服务器B对抽象类具体实现: ###

package com.sy.rpc.service.imp;
    
    import com.sy.rpc.service.LoginServerInterface;
    
    public class LoginServerImp implements LoginServerInterface {
        @Override
        public String login(String username, String password) {
            return username+" logged in successfully!";
        }
    }

[Link 1]: https://baike.baidu.com/item/%E8%BF%9C%E7%A8%8B%E8%BF%87%E7%A8%8B%E8%B0%83%E7%94%A8/7854346
[Link 2]: https://baike.baidu.com/item/%E7%BD%91%E7%BB%9C/143243
[RPC]: https://baike.baidu.com/item/RPC%E5%8D%8F%E8%AE%AE
[Link 3]: https://baike.baidu.com/item/%E4%BC%A0%E8%BE%93%E5%8D%8F%E8%AE%AE/8048821
[Link 4]: https://baike.baidu.com/item/%E7%BD%91%E7%BB%9C%E9%80%9A%E4%BF%A1/9636548
[Link 5]: https://baike.baidu.com/item/%E4%BC%A0%E8%BE%93%E5%B1%82/4329536
[Link 6]: https://baike.baidu.com/item/%E5%BA%94%E7%94%A8%E5%B1%82/4329788
[Link 7]: https://baike.baidu.com/item/%E5%88%86%E5%B8%83%E5%BC%8F
[Link 8]: https://baike.baidu.com/item/%E4%BF%A1%E6%81%AF/111163