准备开发环境：

（1）hadoop-eclipse-plugin-2.7.7.jar。

　　在Hadoop2.x版本中为了做Mapreduce开发,要使用Eclipse,并且需要对应的Hadoop插件hadoop-eclipse-plugin-xxx.jar，插件版本要和HadooP版本兼容。将其放入到Eclipse安装目录下的plugins文件夹下，我们实训环境已经将其放入，不需要操作。

（2）通过Eclipse配置Hadoop Map/Reduce。

junit的作用和常用注解：

（1）作用：junit是一个 Java语言的单元测试框架，用于编写和运行可重复的测试。能让我们快速完成单元测试。简化单元测试，写一点测一点，在编写以后的代码中如果发现问题可以较快的追踪到问题的原因，减小回归错误的纠错难度。

（2）常用注解：

• @test：测试方法。
• @Before：每个测试方法之前运行。
• @After：每个测试方法之后运行。

涉及主要类：

　　在Java中操作HDFS，主要涉及以下类：

（1）configuration：该类的对象封装了客户端或者服务器的配置，为YARN、HDFS、MapReduce等提供参数的配置、配置文件的分布式传输(实现了 Writable 接口)等重要功能。

使用：　　使用Configuration类的一般过程是：构造Configuration对象，并通过类的addResource()方法添加需要加载的资源；然后使用get()或set()方法访问或设置配置项，资源会在第一次使用的时候自动加载到对象中。

实例：

Configuration conf=new Configuration(); 
conf.addResource("core-default.XMl"); 
conf.addResource("core-site.xML"); 
conf.set("fs.defaultFS", "hdfs://localhost:9000");

解释：　　上述实例中，我们加载了两个配置资源，这两个配置资源包含了相同的配置项，此时，后面的配置将覆盖前面的配置，即core-site.xml中的配置将覆盖core-default.xml中的同名配置。

　　之后使用set()方法设置了“fs.defaultFS”配置项，此项将覆盖core-site.xml或core-default.xml配置项中的同名配置。

（2）FileSystem：该类的对象是一个文件系统对象，可以用该对象的一些方法来对文件进行操作，通过FileSystem的静态方法get获得该对象。

获取FileSystem方式：

方式一：通过配置获取

@Test
public void getFileSystem1() throws IOException {
    	Configuration configuration = new Configuration();
    //指定我们使用的文件系统类型:  
	configuration.set("fs.defaultFS", "hdfs://localhost:9000/");
    //获取指定的文件系统
	FileSystem fileSystem = FileSystem.get(configuration);
    	System.out.println(fileSystem.toString());
}

方式二：直接获取

@Test
public void getFileSystem2() throws  Exception{
// 不需要配置“fs.defaultFS”参数，直接传入URI和用户身份，最后一个参数是安装Hadoop集群的用户，实训环境中是“root”
    FileSystem fileSystem = FileSystem.get(new URI("hdfs://localhost:9000"), new Configuration(),"root");
    System.out.println("fileSystem:"+fileSystem);
}

注意：如果我们的代码中没有指定fs.defaultFS ，并且工程classpath下也没有给定相应的配置，conf中的默认值就来自于Hadoop的jar包中的core-default.xml，默认值为file:///，此时获取的将不是我们指定文件系统的实例（如HDFS），而是一个本地文件系统的客户端对象。