Hadoop RPC通信

Posted tongxupeng

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Hadoop RPC通信相关的知识,希望对你有一定的参考价值。

Remote Procedure Call(简称RPC):远程过程调用协议
1. 通过网络从远程计算机程序上请求服务
2. 不需要了解底层网络技术的协议(假定某些传输协议的存在,如TCP或UDP)
3. 采用客户机/服务机模式

请求程序就是一个客户机,服务提供程序就是一个服务器

例子:hadoop RPC机制的一个简单实现

1.导jar包,/share/hadoop/common 的相关的jar包 以及/share/hadoop/hdfs 相关的jar包

2.编程实现

1). 定义一个协议接口 如 Isay 接口

public interface Isay {

    public static final long versionID=1234L;//前后一致

    public String say(String username);
}

2). 创建通信的服务端 (服务程序实现协议接口)

 

public class SayRpcServer implements Isay{

    //实现Isay接口
    @Override
    public String say(String username) {
        // TODO Auto-generated method stub
        System.out.println("server received data->["+username+"]");
        return "Hello! ["+username+"]";
    }

    public static void main(String[] args) throws HadoopIllegalArgumentException, IOException {
        Configuration conf = new Configuration();
        //创建builder对象
        Builder builder = new RPC.Builder(conf);
        //为builder设置服务对象,服务端地址,端口,定义代理协议
        builder.setInstance(new SayRpcServer()).setBindAddress("Master").setPort(8001).setProtocol(Isay.class);
        //创建  server
        Server server = builder.build();
        //启动 server
        server.start();
        System.out.println("server started");
    }

}

 

3).创建一个通信客户端

public class SayRpcClient {
    private static Scanner sc;

    public static void main(String[] args) throws IOException {

        InetSocketAddress inetSocketAddress=new InetSocketAddress("Master", 8001);
        Configuration conf=new Configuration();
        //初始化 RPC 代理
        Isay proxySay=RPC.getProxy(Isay.class, 1234L, inetSocketAddress, conf);

        System.out.println("请输入用户名(quit退出)");
        //从控制台读入数据
        sc=new Scanner(System.in);
        while(sc.hasNext()) {
            String userName=sc.next();
            if("quit".equals(userName)) {//设定退出条件
                System.out.println("RPC client exited");
                return ;
            }
            String s=proxySay.say(userName);//远程调用
            System.out.println(s);
            System.out.println("请再输入姓名(quit退出)");
        }
    }
}

 

4)输出结果 
1.启动服务端

server started

2.启动客户端

请输入用户名(quit退出)
Jack
Hello! [Jack]
请再输入姓名(quit退出)
Mark
Hello! [Mark]
请再输入姓名(quit退出)
quit
RPC client exited

同时server的输出结果

server started
server received data->[Jack]
server received data->[Mark]

 







以上是关于Hadoop RPC通信的主要内容,如果未能解决你的问题,请参考以下文章

Hadoop学习笔记—3.Hadoop RPC机制的使用

自编写RPC通信实例解析HadoopRPC通信原理

自编写RPC通信实例解析HadoopRPC通信原理

Hadoop RPC通信

Hadoop -- RPC机制

Hadoop RPC 探究