关于hadoop HDFS进行读写文件操作的问题

Posted 2021-01-09 memeda21

问题 ： java无法链接 报错显示被拒绝链接 刚开始一直以为是自己hadoop没有配好（或者自己的jar包没有导入好），开始就走偏了导致时间浪费

原因是：hadoop没有开起来........

一个读写的代码如下

package com;
import java.io.IOException;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FSDataInputStream;
import org.apache.hadoop.fs.FSDataOutputStream;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;

public class NanShou {

    public static void main(String[] args) throws IOException {
        //HDFS连接
        Configuration conf=new Configuration();
        FileSystem fs = FileSystem.get(conf);
        //要求1
        fs.mkdirs(new Path("/usr/local/hadoop/l"));//建立文件夹
        Path inFile1 =new Path("/usr/local/hadoop/l/hdfstest1.txt");//创建文本hdfstest1.txt
        FSDataOutputStream outputStream1=fs.create(inFile1);
        outputStream1.writeUTF("信1605-1  20163678 胡 HDFS课堂测试");//输入
        outputStream1.flush();
       outputStream1.close();
        //要求2
        Path inFile2=new Path("/usr/local/hadoop/l/hdfstest2.txt");//创建文本hdfstest2.txt
        FSDataOutputStream outputStream2=fs.create(inFile2);
        FSDataInputStream inputStream1=fs.open(inFile1);//打开hdfstest1.txt
        outputStream2.writeUTF(inputStream1.readUTF());//读取hdfstest1.txt内容并写入hdfstest2.txt
        outputStream2.flush();
       outputStream2.close();
       inputStream1.close();
        //要求3
        FSDataInputStream inputStream2=fs.open(inFile2);//打开hdfstest2.txt
      System.out.println(inputStream2.readUTF());//输出//打开hdfstest2.txt内容
      inputStream2.close();
    }
    
}