3.hadoop之RPC通信简单介绍

RPC，即Remote
Procdure Call，中文名：远程过程调用；

lRPC——远程过程调用协议，它是一种通过网络从远程计算机程序上请求服务，而不需要了解底层网络技术的协议。RPC协议假定某些传输协议的存在，如TCP或UDP，为通信程序之间携带信息数据。在OSI网络通信模型中，RPC跨越了传输层和应用层。RPC使得开发包括网络分布式多程序在内的应用程序更加容易。
lRPC采用客户机/服务器模式。请求程序就是一个客户机，而服务提供程序就是一个服务器。首先，客户机调用进程发送一个有进程参数的调用信息到服务进程，然后等待应答信息。在服务器端，进程保持睡眠状态直到调用信息的到达为止。当一个调用信息到达，服务器获得进程参数，计算结果，发送答复信息，然后等待下一个调用信息，最后，客户端调用进程接收答复信息，获得进程结果，然后调用执行继续进行。
lhadoop的整个体系结构就是构建在RPC之上的.比如Namenode与Datanode之间，Jobtracker与Tasktracker之间等。

不同进程之间的调用，底层还是java的socket机制

简单实现rpc：
服务端、客户端需同时一个实现接口，在接口中必须定义一个versionID字段

服务端：

package com.test.hadoop.rpc;

import java.io.IOException;

import org.apache.hadoop.HadoopIllegalArgumentException;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.ipc.RPC;
import org.apache.hadoop.ipc.RPC.Server;

public class RPCServer implements Bizable {

@Override
public String sayHi(String name) {
return "HI:" + name;
}

public static void main(String[] args) {
Configuration conf = new Configuration();
try {
Server server = new RPC.Builder(conf).setProtocol(Bizable.class)
.setInstance(new RPCServer())
.setBindAddress("192.168.6.100").setPort(9527).build();
server.start();

} catch (HadoopIllegalArgumentException | IOException e) {
e.printStackTrace();
}
}

}

客户端:

package com.test.hadoop.rpc;

import java.io.IOException;
import java.net.InetSocketAddress;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.ipc.RPC;

public class RPCClient {

public static void main(String[] args) {
// 得到server的代理对象后即可访问server的方法
try {
Bizable proxy = RPC.getProxy(Bizable.class, 10010L,
new InetSocketAddress("192.168.6.100", 9527),
new Configuration());
String result = proxy.sayHi("tomcat");
System.out.println(result);
RPC.stopProxy(proxy);
} catch (IOException e) {
e.printStackTrace();
}
}

}

接口：

package com.itcast.hadoop.rpc;

public interface Bizable {

public static final long versionID = 10010;

public String sayHi(String name);
}