本文共 3248 字，大约阅读时间需要 10 分钟。

      之前，我们简单介绍了一下Hadoop的核心之一HDFS，对其中的一些概念和他的原理做了一些解析。今天我们来看看HDFS的操作实例。

三、小试牛刀

1、shell命令

2、fs实例

      在做之前，我们需要做一些准备环境，例如在Linux上安装hadoop，创建工程，导入需要的jar文件等等，网上分享的步骤很全，这里不在赘述，直接看它实际应用中的代码。

public class HDFSDemo {
       FileSystem fs=null;    @Before    public void init() throws IOException, URISyntaxException, InterruptedException {        //首先创建FileSystem的实现类（工具类），并指定当前用户        fs =FileSystem.get(new URI            ("hdfs://itcast01:9000"), new Configuration(),"root");    }    @Test    public void testUpLoad() throws Exception{        //读取本地文件系统的文件，返回输入流        InputStream in=new FileInputStream("c://test.zip");        //在HDFS上创建一个文件，返回输出流        OutputStream out=fs.create(new Path("/test1.zip"));        //输入流-》输出        IOUtils.copyBytes(in, out, 4096,true);    }    //创建文件夹    @Test    public void testMkDir() throws IllegalArgumentException, IOException{        boolean flag=fs.mkdirs(new Path("/nihao/11/22/33"));        System.out.println(flag);    }    //删除文件    @Test    public void del() throws IllegalArgumentException, IOException{        boolean flag=fs.delete(new Path("/nihao/11"),false);        System.out.println(flag);    }    //下载    @Test    public void getDown() throws Exception {        //连接HDFS，返回输入流        InputStream in=fs.open(new Path("/hadoop-2.5.2.tar.gz"));        //在本地建立文件夹，返回输出流        OutputStream out=new FileOutputStream("c://hadoop2");        //输入流-》输出        IOUtils.copyBytes(in, out, 4096,true);    }    //更快上传    @Test    public void testDownLoad() throws IllegalArgumentException, IOException{        fs.copyToLocalFile(true,new Path("/hadoop-2.5.2.tar.gz"), new Path("c://hadoop-2.5.2.tar.gz"));    }}

3、RPC实例

• 概念

        RPC——远程过程调用协议，它是一种通过网络从远程计算机程序上请求服务，而不需要了解底层网络技术的协议。RPC协议假定某些传输协议的存在，如TCP或UDP，为通信程序之间携带信息数据。在OSI网络通信模型中，RPC跨越了传输层和应用层。RPC使得开发包括网络分布式多程序在内的应用程序更加容易。

• 原理

         RPC采用客户机/服务器模式。请求程序就是一个客户机，而服务提供程序就是一个服务器。首先，客户机调用进程发送一个有进程参数的调用信息到服务进程，然后等待应答信息。在服务器端，进程保持睡眠状态直到调用信息的到达为止。当一个调用信息到达，服务器获得进程参数，计算结果，发送答复信息，然后等待下一个调用信息，最后，客户端调用进程接收答复信息，获得进程结果，然后调用执行继续进行。

• 代码

接口

public interface Bizable {    //序列化序号    public static final long versionID=10010;    //接口方法——客户端需要调用，服务端实现    public String sayHi(String name);}

客户端

public class RPCClient {    public static void main(String[] args) throws IOException {        //生成服务端的代理        Bizable proxy= RPC.getProxy(Bizable.class, 10010, new InetSocketAddress("192.168.8.***",9519), new Configuration());        //调用代理方法        String result=proxy.sayHi("tomacat");        //打印结果        System.out.println(result);        //关闭代理        RPC.stopProxy(proxy);    }}

服务端

public class RPCServer implements Bizable{
       //实现接口    public String sayHi(String name){        return "HI~"+name+".I am Service";    }    public static void main(String[] args) throws Exception {        Configuration conf=new Configuration();        //使用静态类Builder构造一个RPC Server        //其中，BindAddress（由函数setBindAddress设置）和Port（由函数setPort设置，0表示由系统随机选择一个端口号）分别表示服务器的host和监听端口号        Server server=new  RPC.Builder(conf).setProtocol(Bizable.class).setInstance(new RPCServer()).setBindAddress("192.168.8.***").setPort(9519).build();        //启动服务。此时，服务器处理监听状态，等待客户端请求到达。        server.start();    }}

总结：

      到此，我们学习了HDFS的一个大概，从概念到原理最后到实际操作，基本的一些知识已经掌握，剩下的就需要在项目中历练了。接下来我们会继续分享Hadoop的另外一个核心部分MapReduce，敬请关注。