0692-5.16.1-外部客户端跨网段访问Hadoop集群方式(续)

<dependency>
    <groupId>org.apache.hadoop</groupId>
    <artifactId>hadoop-client</artifactId>
    <version>2.6.0</version>
</dependency>
<dependency>
    <groupId>org.apache.hadoop</groupId>
    <artifactId>hadoop-common</artifactId>
    <version>2.6.0</version>
</dependency>

package com.ff;

import java.net.URI;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FSDataInputStream;
import org.apache.hadoop.fs.FileStatus;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.hdfs.web.WebHdfsFileSystem;

public class WebHDFSTest {
    public static void main(String[] args) {
        Configuration configuration = new Configuration();
        WebHdfsFileSystem webHdfsFileSystem = new WebHdfsFileSystem();
        try {
            webHdfsFileSystem.initialize(new URI("http://cdh3.hadoop.com:50070"), configuration);
            //向HDFS上传文件
            webHdfsFileSystem.copyFromLocalFile(new Path("C:/Users/TEST/Desktop/webhdfs"), new Path("/test_webhdfs"));
            System.out.println("文件成功上传到HDFS上/test_webhdfs目录下");
            //从HDFS下载文件
            webHdfsFileSystem.copyToLocalFile(new Path("http://cdh3.hadoop.com:50070/test_webhdfs/webhdfs.txt"), new Path("C:/Users/TEST/Desktop/getFromHDFS/"));
            System.out.println("文件成功下载到本地桌面的getFromHDFS文件夹下");
            //查看上传的文件内容
            FSDataInputStream open = webHdfsFileSystem.open(new Path("http://cdh3.hadoop.com:50070/test_webhdfs/webhdfs.txt"));
            byte[] bs = new byte[1024 * 1024];
            int len = 0;
            System.out.println("上传的文件内容如下:");
            while((len = open.read(bs)) != -1){
                System.out.println(new String(bs, 0, len));
            }
            //列出HDFS根目录下的所有文件
            FileStatus[] fileStatuses =  webHdfsFileSystem.listStatus(new Path("/"));
            System.out.println("HDFS根目录下的内容如下:");
            for (FileStatus fileStatus : fileStatuses) {
                System.out.println(fileStatus.getPath().getName());
            }
            webHdfsFileSystem.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

yum -y install nfs-utils
yum -y install rpcbind

systemctl start rpcbind
systemctl status rpcbind
systemctl enable rpcbind

mkdir /nfs
mount -t nfs -o vers=3,proto=tcp,nolock,noacl,sync cdh2.hadoop.com:/ /nfs

export HADOOP_ROOT_LOGGER=DEBUG,console

<property>
  <name>dfs.client.use.datanode.hostname</name>
  <value>true</value>
</property>