一、场景介绍

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

启动服务端

查看进程

运行客户端

服务端方法被执行