【深入代码系列】手牵手一起过Hadoop源码

看着这张图，我陷入了沉思：

为什么？为什么？为什么？nn，dn，rm，nm到底是怎么做到互相通信的？

其实就是借助我们耳熟能详的RPC通信

RPC通信原理解析

需求：模拟RPC的客户端、服务端、通信协议三者如何工作的

代码编写：

（1）在HDFSClient项目基础上创建包名com.zuoer.rpc

（2）创建RPC协议

package com.nbchen.demo.rpc;

/**
 * @author zuoer
 * @date 2023-07-18 13:15
 */
public interface RPCProtocol {
    long versionID = 666;

    void mkdirs(String path);
}

（3）创建RPC服务端

package com.nbchen.demo.rpc;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.ipc.RPC;

import java.io.IOException;

/**
 * 实现通信接口
 * @author zuoer
 * @date 2023-07-18 13:16
 */
public class NNServer implements RPCProtocol{

    /**
     * 启动服务
     * @param args
     * @throws IOException
     */
    public static void main(String[] args) throws IOException {
        RPC.Server server = new RPC.Builder(new Configuration())
                .setBindAddress("localhost")
                .setPort(8888)
                .setProtocol(RPCProtocol.class)
                .setInstance(new NNServer())
                .build();
        System.out.println("服务器开始工作....");
        server.start();
    }

    @Override
    public void mkdirs(String path) {
        System.out.println("服务器接收到客户端的请求" + path);
    }
}

（4）创建RPC客户端

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