189 8069 5689
这篇文章主要讲解了“Hadoop中的RPC机制”，文中的讲解内容简单清晰，易于学习与理解，下面请大家跟着小编的思路慢慢深入，一起来研究和学习“Hadoop中的RPC机制”吧！
成都创新互联公司是一家专业提供市南企业网站建设,专注与网站制作、网站设计、H5建站、小程序制作等业务。10年已为市南众多企业、政府机构等服务。创新互联专业网站制作公司优惠进行中。
RPC(Remote Procedure Call)—远程过程调用协议，它是一种通过网络从远程计算机程序上请求服务，而不需要了解底层网络技术的协议。RPC协议假定某些传输协议的存在，如TCP或UDP，为通信程序之间携带信息数据。在OSI网络通信模型中，RPC跨越了传输层和应用层。RPC使得开发包括网络分布式多程序在内的应用程序更加容易。
RPC采用客户机/服务器模式。请求程序就是一个客户机，而服务提供程序就是一个服务器。首先，客户机调用进程发送一个有进程参数的调用信息到服务进程，然后等待应答信息。在服务器端，进程保持睡眠状态直到调用信息的到达为止。当一个调用信息到达，服务器获得进程参数，计算结果，发送答复信息，然后等待下一个调用信息，最后，客户端调用进程接收答复信息，获得进程结果，然后调用执行继续进行。
Hadoop的整个体系结构就是构建在RPC之上的(见org.apache.hadoop.ipc包)
使用RPC: (搭建一个Hadoop伪分布式虚拟机(Server端), 本地Windows连接该虚拟机(Client端))
1. 定义RPC协议接口 LoginProtocol (Hadoop RPC协议通常是一个Java接口), RPC协议接口是Client和Server之间的通信接口, 它定义了Server对外提供的接口. LoginProtocol接口声明了一个login()方法, 需要注意的是Hadoop中所有自定义的RPC协议接口都有一个为versionID的字段, 它描述了该协议的版本信息, 这个RPC协议接口为Client/Server共同持有, Server端, Client端都必须有同一个LoginProtocol.class文件
public interface LoginProtocol {
public static final long versionID = 1L;
public String login(String username, String password);
}2. 在Server端, LoginProtocolImpl 实现RPC协议接口( LoginProtocol )
public class LoginProtocolImpl implements LoginProtocol {
@Override
public String login(String username, String password) {
return "wellcome " + username;
}
}3. 在Server端构造并启动RPC Server, "192.168.8.101"是Server的ip地址, Server端监听了"1234"端口
public static void main(String[] args) throws HadoopIllegalArgumentException, IOException {
// 设置4个必需参数:
// setBindAddress("192.168.8.101") : Server端的IP地址
// setPort(1234) : 端口
// setProtocol(LoginProtocol.class) : setRPC协议接口的class对象
// setInstance(new LoginProtocolImpl()) : RPC协议接口的实现类的实例
Server server = new RPC.Builder(new Configuration()).setBindAddress("192.168.8.101").setPort(1234)
.setProtocol(LoginProtocol.class).setInstance(new LoginProtocolImpl()).build();
server.start();
}
}4. 在Client端构造RPC客户端, 使用RPC类静态方法getProxy()构造客户端RPC代理对象( proxy ), 调用RPC代理对象( proxy )的login()方法, 发送RPC请求. "192.168.8.101"是Server的ip地址, "1234"是Server端监听端口
public class LoginClient {
public static void main(String[] args) throws IOException {
// getProxy()参数:
// LoginProtocol.class : RPC协议接口的class对象
// 1L : RPC协议接口的版本信息(versionID)
// new InetSocketAddress("192.168.8.101", 1234) : Server端的IP地址及端口
// conf : Configuration实例
LoginProtocol proxy = RPC.getProxy(LoginProtocol.class, 1L, new InetSocketAddress("192.168.8.101", 1234),
new Configuration());
String result = proxy.login("rpc", "xxx");
System.out.println(result);
}
}接下来, 神奇的一幕发生了!
本地Windows的Console输出:
wellcome rpc
本地Windows有LoginProtocol接口的实现吗?
没有哟!
感谢各位的阅读，以上就是“Hadoop中的RPC机制”的内容了，经过本文的学习后，相信大家对Hadoop中的RPC机制这一问题有了更深刻的体会，具体使用情况还需要大家实践验证。这里是创新互联，小编将为大家推送更多相关知识点的文章，欢迎关注！