Hadoop3：RPC通信原理及简单案例实现
一、场景介绍
我们知道，Hadoop中存在多种服务，那么，服务之间是如何通信的了？
比如，DN和NN之间如何通信？
这里，实际上是通过RPC实现进程间通信的了。
RPC属于Java网络编程范畴
需要编写客户端和服务端
底层实现是NIO
一般RPC框架的使用，需要配合服务注册中心组件使用。比如zookeeper，nacos等
客户端通过zookeeper，拿到服务端的IP、PORT、method等参数
然后，本地实现远程服务调用，就类似调用本地方法一样简洁。
比较成功的RPC框架有：Dubbo、WebSocket、gRPC、OpenFeign等
二、案例
1、需求
模拟RPC的客户端、服务端、通信协议三者如何工作的
2、代码
接口RPCProtocol
package com.atguigu.rpc;
public interface RPCProtocol {
long versionID = 666;
void mkdirs(String path);
}
服务端NNServer
package com.atguigu.rpc;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.ipc.RPC;
import org.apache.hadoop.ipc.Server;
import java.io.IOException;
public class NNServer implements RPCProtocol {
@Override
public void mkdirs(String path) {
System.out.println("服务端，创建路径" + path);
}
public static void main(String[] args) throws IOException {
Server server = new RPC.Builder(new Configuration())
.setBindAddress("localhost")
.setPort(8888)
.setProtocol(RPCProtocol.class)
.setInstance(new NNServer())
.build();
System.out.println("服务器开始工作");
server.start();
}
}
客户端HDFSClient
package com.atguigu.rpc;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.ipc.RPC;
import java.io.IOException;
import java.net.InetSocketAddress;
public class HDFSClient {
public static void main(String[] args) throws IOException {
RPCProtocol client = RPC.getProxy(
RPCProtocol.class,
RPCProtocol.versionID,
new InetSocketAddress("localhost", 8888),
new Configuration());
System.out.println("我是客户端");
client.mkdirs("/input");
}
}
3、测试
启动服务端
查看进程
运行客户端
服务端方法被执行
原文地址：https://blog.csdn.net/Brave_heart4pzj/article/details/140495728
免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！