RPC远程过程调用协议

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

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

有多种 RPC模式和执行。最初由 Sun 公司提出。IETF ONC 宪章重新修订了 Sun 版本，使得 ONC RPC 协议成为 IETF 标准协议。现在使用最普遍的模式和执行是开放式软件基础的分布式计算环境（DCE）。

hadoop整个体系就是建立在RPC通信的之上的,请见(org.apache.hadoop.ipc.RPC)

本例子是通过hadoop工具实现RPC通信原理的实例：

1、下面服务端和客户端两个文件以及要实现动态代理的接口：

RPCServer.java

package cn.com.leepeng.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.Builder; 

import org.apache.hadoop.ipc.RPC.Server;
/**
* Demo RPC服务端
*
* @author LEEPENG
*
*/
public class RPCServer implements Bizable {
/**
* 客户端调用的方法
*
* @param name
* @return
*/
public String sayHello(String name) {
return "hello:" + name;
}
public static void main(String[] args) throws HadoopIllegalArgumentException, IOException {
Configuration configuration = new Configuration();
Builder builder = new RPC.Builder(configuration);
//
builder.setProtocol(Bizable.class);
// 设置个实例,哪个实例对象的方法被调用，sayHello是RPCServer的实例方法被调用，所以传new RPCServer()
builder.setInstance(new RPCServer());
// 绑定一个地址,根据具体IP设置
builder.setBindAddress("192.168.1.104");
// 绑定一个端口
builder.setPort(9527);
// 创建服务
Server server = builder.build();
// 启动服务
server.start();
}
}

RPCClient.java

package cn.com.leepeng.hadoop.rpc;
import java.io.IOException;
import java.net.InetSocketAddress;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.ipc.RPC;
/**
* RPC客户端，得到代理对象，调用RPCServer的方法 

*
* @author LEEPENG
*
*/
public class RPCClient {
public static void main(String[] args) throws IOException {
// 得到代理对象
Bizable proxy = RPC.getProxy(Bizable.class, Bizable.versionID, new InetSocketAddress("192.168.1.104", 9527),
new Configuration());
String result = proxy.sayHello("RPC....");
System.out.println(result);
RPC.stopProxy(proxy);
}
}

package cn.com.leepeng.hadoop.rpc;
public interface Bizable {
public static final long versionID = 10086;
/**
* 此方法在客户端被调用，客户端要得到服务端的代理对象，实现动态代理，客户端要和服务端同时实现一个接口
*
* @param name
* @return
*/
public String sayHello(String name);
}

这样，先运行服务端，在运行客户端，执行后客户端会调用服务端的方法，因为是两个main方法，所以是两个不同的进程，如果不明显的话，可以用下面的实验测试。

现在，我将RPCClient客户端打包成JAR文件放入到Linux服务器上，并在Linux服务器上运行客户端

发现在Linux上运行客户端走的是本地服务端的方法，这就是不同进程间的方法调用。

更多资讯欢迎访问我的博客：https://www.leepeng.com.cn