一、场景介绍

我们知道，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、测试

启动服务端

查看进程

运行客户端

服务端方法被执行