Hadoop之RPC机制 | 我本沉默

什么是RPC机制

Remote Procedure Call（简称：RPC):远程过程调用协议。

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

RPC的运行模式

RPC采用客户机/服务器模式。

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

RPC的简单实现

客户端和服务端通信必须要按照某种协议来执行，要不就乱套了。那么我们来定一个RPC协议的接口，里面包含协议的版本号，及RPC方法名。

package com.itunic.rpc;
/**
* RPC协议定义接口
* @author itunic
*
*/
public interface RPCProtocal {
/**
* 定义RPC协议版本号
*/
public static final long versionID = 1111;
/**
* 根据id获取名字
* @param id
* @return
*/
public String getName(String id);
}

定义完成后，实现RPC服务端，服务端必须实现上面RPC接口。然后在启动服务时将服务绑定到某个ip下的某个端口。这样才能正常的进行服务。

package com.itunic.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.Server;
/**
* RPC服务端的简单实现
* @author itunic
*
*/
public class RPCService implements RPCProtocal {
@Override
public String getName(String id) {
System.out.println("查找");
return id + "的Name";
}
/**
* 设置RPC协议接口,将服务绑定到192.168.31.104:9999
* @param args
* @throws HadoopIllegalArgumentException
* @throws IOException
*/
public static void main(String[] args) throws HadoopIllegalArgumentException, IOException {
Server server = new RPC.Builder(new Configuration()).setInstance(new RPCService())
.setProtocol(RPCProtocal.class).setBindAddress("192.168.31.104").setPort(9999).build();
server.start();
}
}

这样的话服务端就实现完毕了。我们运行一下，看看结果

可以看到服务端已经正常运行了。接下来我们实现RPC客户端的代码。

package com.itunic.rpc;
import java.io.IOException;
import java.net.InetSocketAddress;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.ipc.RPC;
/**
* RPC客户端简单实现
* @author itunic
*
*/
public class RPCClient {
public static void main(String[] args) throws IOException {
/**
* 绑定RPC协议接口，输入RPC协议版本号,绑定服务端地址和端口
* 绑定完成后，调用接口的getName方法。
*/
RPCProtocal proxy = RPC.getProxy(RPCProtocal.class, 1111, new InetSocketAddress("192.168.31.104", 9999),
new Configuration());
String name= proxy.getName("itunic");
System.out.println(name);
RPC.stopProxy(proxy);
}
}