package com.neuedu.test;import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FSDataInputStream;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;public class HFDSClient {public static void main(String[] args) {// TODO Auto-generated method stub
        read();}public static void read(){//-------连接namenode：//1、创建一个配置对象(与配置文件是一个原理)Configuration conf=new Configuration();conf.set("fs.defaultFS", "hdfs://192.168.71.141:9000");//set配置对象Path path=new Path("/hadoop/abc.txt");//读文件//FileSystem fs=new //发现方法不能用，因为它为抽象方法，在不能用情况下，创建对象时方法很陌生且不能用，调用一下静态方法,看哪个可以返回try {FileSystem fs=FileSystem.get(conf);//只用来连接namenode//因为是读文件,需要返回一个输入流FSDataInputStream input = fs.open(path);//f 为一个路径，告诉它文件在哪 //返回了一个流//读文字可以转化为字符流，转换：InputStreamReader isr=new InputStreamReader(input);//如果想按行读，BufferedReader br=new BufferedReader(isr);//开始读String str=br.readLine();//按行读while(str!=null){//只要不为空
                        System.out.println(str);str=br.readLine();//每输出一行，读一次
                    }br.close();isr.close();input.close();//流都需要关闭} catch (IOException e) {// TODO Auto-generated catch block
                    e.printStackTrace();}}
}

public static void append(){Configuration conf=new Configuration();conf.set("fs.defaultFS", "hdfs://192.168.71.141:9000");//set配置对象try {FileSystem fs=FileSystem.get(conf);FSDataOutputStream outpustream = fs.append(new Path("/hadoop/abc.txt"));//在哪个文件上追加outpustream.writeBytes("123123123");outpustream.close();} catch (IOException e) {// TODO Auto-generated catch block
            e.printStackTrace();}}

//写入:直接写入public static void write(){Configuration conf=new Configuration();conf.set("fs.defaultFS", "hdfs://192.168.71.141:9000");//set配置对象try {FileSystem fs=FileSystem.get(conf);FSDataOutputStream outpustream = fs.create(new Path("/hadoop/abc.txt"));//在哪个文件上追加outpustream.writeBytes("123123123");outpustream.close();} catch (IOException e) {// TODO Auto-generated catch block
            e.printStackTrace();}}