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