标签:原因 自己的 要求 sys exce 文件 开始 课堂 throws
问题 : 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(); } }
标签:原因 自己的 要求 sys exce 文件 开始 课堂 throws
原文地址:https://www.cnblogs.com/memeda21/p/9733337.html