１. Hadoop-rpc框架

ClientNamenodeProtocal

接口定义

NameNode

接口的实现

ServerPublisher

用于发布服务的类

package cn.toto.rpc.protocal;

public interface ClientNamenodeProtocal {

   //为了保证客户端和服务端的版本是一致的,如果没有定义将报错

   public static final long versionID = 1L;

   public String getMetaData(String path);

}

package cn.toto.rpc.server;

import cn.toto.rpc.protocal.ClientNamenodeProtocal;

public class NameNode implements ClientNamenodeProtocal {

   @Override

   public String getMetaData(String path) {

      return path + " 2 {BLK1,BLK2} {BLK1:min1,mini2} {BLK2:mini4,mini5}";

   }

}

package cn.toto.rpc.server;

import java.io.IOException;

import org.apache.hadoop.conf.Configuration;

import org.apache.hadoop.ipc.RPC;

import org.apache.hadoop.ipc.RPC.Builder;

import org.apache.hadoop.ipc.RPC.Server;

import cn.toto.rpc.protocal.ClientNamenodeProtocal;

public class ServerPublisher {

   public static void main(String[] args) throws Exception, IOException {

      Builder builder = new RPC.Builder(new Configuration());

      //暴露的仅仅是ClientNamenodeProtocal.class中的new NameNode()实现的方法

      builder.setBindAddress("localhost").setPort(8787)

             .setProtocol(ClientNamenodeProtocal.class)

             .setInstance(new NameNode());

      //构建一个Server，并且启动一下

      Server server = builder.build();

      server.start();

   }

}

ClientNamenodeProtocal

和服务端一样的接口

HdfsClient

用于调用的客户端代码

package cn.toto.rpc.protocal;

public interface ClientNamenodeProtocal {

   //为了保证客户端和服务端的版本是一致的,如果没有定义将报错

   public static final long versionID = 1L;

   public String getMetaData(String path);

}

package cn.toto.rpc.client;

import java.io.IOException;

import java.net.InetSocketAddress;

import org.apache.hadoop.conf.Configuration;

import org.apache.hadoop.ipc.RPC;

import cn.toto.rpc.protocal.ClientNamenodeProtocal;

public class HdfsClient {

   /**

    * 在使用这个之前，需要先启动服务端

    */

   public static void main(String[] args) throws IOException {

      //通过这种方式获取到一个远程调用对象

      ClientNamenodeProtocal nameNode = RPC.getProxy(ClientNamenodeProtocal.class,

                 1L,

                 new InetSocketAddress("localhost",8787),

                 new Configuration());

      //调用服务端的接口，看看返回的结果

      String metaData = nameNode.getMetaData("/a.doc");

      System.out.println(metaData);

   }

}