实现HDFS数据上传和下载代码

    import java.io.FileInputStream;  
    import java.io.FileOutputStream;  
    import java.io.IOException;  
    import java.io.InputStream;  
    import java.io.OutputStream;  
    import java.net.URI;  
    import java.net.URISyntaxException;  
      
    import org.apache.hadoop.conf.Configuration;  
    import org.apache.hadoop.fs.FileSystem;  
    import org.apache.hadoop.fs.Path;  
    import org.apache.hadoop.io.IOUtils;  
    import org.junit.Before;  
    import org.junit.Test;  
      
    /* 
     1、通过代码来操作HDFS 
     2、实现了下载、上传文件的功能 
     */  
    public class HDFSDemo {   
        /* 
         1、通过代码来操作HDFS 
         2、实现了下载功能 
         */   
        public static void main(String[] args) throws IOException,URISyntaxException {  
            //与master建立联系  
            FileSystem fs =FileSystem.get(new URI("hdfs://master:9000"),new Configuration());  
            //通过流方式读取HDFS中的文件，将文件读入到内存当中  
            InputStream in  = fs.open(new Path("/user/guest/esri/xiaojson/xiao.json"));  
            //输出路径  
            OutputStream out = new FileOutputStream("D://xiao.json");  
            //工具类将in中的内容copy到out中，大师级默认都是4096  
            IOUtils.copyBytes(in,out,4096,true);  
        }  
        /* 
         1、通过代码来操作HDFS 
         2、实现了下载功能,通过一句话实现下载 
         */   
        @Test  
        public void testDownLoad() throws IllegalArgumentException,IOException{  
            fs.copyToLocalFile(new Path("/user/guest/esri/xiaojson/xiao.json"),new Path("D://xiao1.json"));  
        }  
          
        FileSystem fs = null;  
        @Before  
        public void init() throws IOException,URISyntaxException,InterruptedException{  
            //创建FileSystem的实现类 （工具类）与master建立联系  
            fs =FileSystem.get(new URI("hdfs://master:9000"),new Configuration(),"guest");  
        }  
        /* 
         1、通过代码来操作HDFS 
         2、实现了上传功能 
         */   
        @Test  
        public void testUpload() throws IOException{  
            //读取本地文件系统的文件，返回输入流  
            InputStream in = new FileInputStream("D://xiao123.json");  
            //在HDFS上创建一个文件，返回输出流  
            OutputStream out = fs.create(new Path("/test.jar"));  
            //工具类将in中的内容copy到out中，大师级默认都是4096  
            IOUtils.copyBytes(in,true);  
        }   
          
    }