一、场景介绍
我们知道，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 {@Overridepublic 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、测试
启动服务端
查看进程
运行客户端
服务端方法被执行
