目录

引言

准备工作：

一    环境变量的设置

二   群起集群进行测试

三   问题总结

引言

hadoop完全分布集群搭建完毕后，我们在对hadoop集群的操作想更加的系统化，就需要我们搭建出一个hadoop客户端来完成对集群的操作了。本文就将介绍如何在Windows环境下搭建出hadoop客户端。

准备工作：

（1）首先要有搭建好的hadoop集群供我们使用。（未搭建集群的同学可以参照hadoop3.x系列完全分布式集群部署（虚拟机网络连接、jdk安装、hadoop安装）_杂乱无章的我的博客-CSDN博客_hadoop 集群管理工具）

（2）下载并解压编译好的hadoopWindows环境下的依赖，这里给出两个版本供大家使用：

hadoop-3.1.0链接：https://pan.baidu/s/1IcABAqzLlXQLaTpdTOKCyQ 
提取码：1949

hadoop-2.7.2链接：https://pan.baidu/s/17gytdAhMg7w_04BGWG88aQ 
提取码：1949

本文采用的是hadoop-2.7.2版本。

（3）maven仓库的配置。（未配置的同学可以参照Maven仓库的配置_杂乱无章的我的博客-CSDN博客）

（4）IDEA编译器

一    环境变量的设置

首先将hadoop依赖下载并解压到我们的文件夹，打开我们的bin目录可以查看到winutils.exe启动程序。

打开我们的设置--->高级系统设置---->环境变量，我们来设置对应的环境变量

首先设置HADOOP_HOME（变量值设置bin目录的父文件夹）

接着设置path路径

新建一个，然后将下列代码复制粘贴进去

%HADOOP_HOME%\bin

这样我们就完成了环境变量的配置。

如果环境变量不起作用，可以重启电脑

二   群起集群进行测试

首先进入虚拟机将集群启动，并且保证主机与虚拟机之间能够成功联通。

进入IDEA中开始编写代码连接集群并对其进行操作。

首先在IDEA中创建一个Maven工程HdfsClientDemo，并且导入对应的依赖。代码如下：

<dependencies>
<--  设置对应hadoop客户端支持 -->
    <dependency>
        <groupId>org.apache.hadoop</groupId>
        <artifactId>hadoop-client</artifactId>
        <version>3.1.3</version>
    </dependency>
<--   设置对应的测试包 -->
    <dependency>
        <groupId>junit</groupId>
        <artifactId>junit</artifactId>
        <version>4.12</version>
    </dependency>
<--   设置日志打印，方便错误查找 -->
    <dependency>
        <groupId>org.slf4j</groupId>
        <artifactId>slf4j-log4j12</artifactId>
        <version>1.7.30</version>
    </dependency>
</dependencies>

同时在项目src/main/resources目录下，创建一个文件，命名为“log4j.properties”，同时在文件中加入如下代码

log4j.rootLogger=INFO, stdout  
log4j.appender.stdout=org.apache.log4j.ConsoleAppender  
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout  
log4j.appender.stdout.layout.ConversionPattern=%d %p [%c] - %m%n  
log4j.appender.logfile=org.apache.log4j.FileAppender  
log4j.appender.logfile.File=target/spring.log  
log4j.appender.logfile.layout=org.apache.log4j.PatternLayout  
log4j.appender.logfile.layout.ConversionPattern=%d %p [%c] - %m%n

 创建软件包名com.test.hdfs，同时创建HdfsClient类来进行测试。

 在测试类HdfsClient中添加如下代码。（注意：在使用本代码时，将namenode节点改为自己的，同时将使用用户也设置为自己使用的）、

客户端代码常用编写流程主要是
1.获取一个客户端对象
2.执行相关的命令操作
3.关闭资源

package com.test.hdfs;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import org.junit.Test;
import java.io.IOException;
import java.URI;
import java.URISyntaxException;
public class HdfsClient {
    @Test
    public void testmkdir() throws URISyntaxException, IOException, InterruptedException {
        //连接的集群namenode地址
        URI uri = new URI("hdfs://hadoop130:8020");
        //创建一个配置文件
        Configuration configuration = new Configuration();
        //用户
        String user = "hr";
        //获取到客户端对象
        FileSystem fs = FileSystem.get(uri,configuration,user);
        //创建一个文件夹
        fs.mkdirs(new Path("test"));
        //关闭资源
        fs.close();
    }
}

运行此测试类，并且观察是否创建出文件夹test。

三   问题总结

在测试类出现错误时，观察以下几个问题。

（1）Windows依赖hadoop是否配置成功。

（2）集群是否完整且集群是否启动成功。

（3）测试类中编写连接的namenode节点的ip值是否正确，连接用户是否正确。

（4）测试类中导入的包是否正确。

（5）hadoop集群是否能够正常与Windows主机进行连接。