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"); } }