上一篇文章,博主为大家分享了hadoop的安装以及集群的启动,本篇博客将带领小伙伴们一起来感受下hadoop命令和Linux命令的使用有什么不同。
一、首先,启动hadoop集群,执行脚本sh start-dfs.sh;sh start-yarn.sh
二、浏览器中查看dfs中的文件目录(此时文件为空),对应的到hadoop中数据节点中的路径/home/hadoop/hdpdata/dfs/data/current/BP-302498708-192.168.29.144-1540943832361/current/finalized,其中/home/hadoop/hdpdata为配置文件中配dfs路径。
三、命令行使用体验
#查看hdfs根目录hadoop fs -ls hdfs://centos-aaron-h1:9000/ 或 hadoop fs -ls /#将test.avi这个文件上传到hdfs跟目录中,默认为128m才切开成不同的块来存放.hadoop fs -put test.avi /hadoop fs -put test.avi test1.avi /#如果文件被切成了不同的块,我们知道是哪几个块的话,可以用块直接还原文件cat bloc_2034655 >>hadoop.filecat bloc_2034656 >>hadoop.filetar -zxvf hadoop.file -C /opt #浏览test.avi文件内容hadoop fs -cat /test.avi #从hdfs中下载test.avi这个文件hadoop fs -get /test.avi#删除文件或文件夹hadoop fs -rmr /wordcount/output 或 hadoop fs -rm -r /wordcount/output#递归新建文件夹hadoop fs -mkdir -p /wordcount/input#运行jar包,wordcount为主类,/wordcount/input为主类运行需要的自己的参数输入目录,/wordcount/output/为输出目录;如果"/wordcount/output/"已经存在会报错hadoop jar hadoop-mapreduce-examples-2.9.1.jar wordcount /wordcount/input/ /wordcount/output/
效果图:
上传的文件在web页面可以下载
四、运行第一个mapreduce程序
首先,hadoop官网jar包本身自动有一些用于测试的mapreduce程序jar包,它们在/home/hadoop/apps/hadoop-2.9.1/share/hadoop/mapreduce目录下:
本次测试使用hadoop-mapreduce-examples-2.9.1.jar(官网的文档中有介绍)这个jar包,该jar包是内有一个单词统计的mapreduce程序,主类是:wordcount;
测试步骤:
a.准备用于测试单词统计使用的输入目录和结果输出目录
#递归新建输入目录hadoop fs -mkdir -p /wordcount/input
b. 准备用于测试单词统计的保存着单词的文件
#新建文件test.txt,并且输入些单词报错vi test.txtctrl+z+z#复制一份cp test.txt test1.txt#上传到上一步用于做单词统计的输入目录hadoop fs -put test.txt test1.txt /wordcount/input
c.运行hadoop-mapreduce-examples-2.9.1.jar
#运行jar包,wordcount为主类,/wordcount/input为主类运行需要的自己的参数输入目录,/wordcount/output/为输出目录;如果"/wordcount/output/"已经存在会报错hadoop jar hadoop-mapreduce-examples-2.9.1.jar wordcount /wordcount/input/ /wordcount/output/
执行效果[hadoop@centos-aaron-h3 mapreduce]$ hadoop jar hadoop-mapreduce-examples-2.9.1.jar wordcount /wordcount/input/ /wordcount/output/18/11/04 04:59:13 INFO client.RMProxy: Connecting to ResourceManager at centos-aaron-h1/192.168.29.144:803218/11/04 04:59:14 INFO input.FileInputFormat: Total input files to process : 218/11/04 04:59:15 INFO mapreduce.JobSubmitter: number of splits:218/11/04 04:59:15 INFO Configuration.deprecation: yarn.resourcemanager.system-metrics-publisher.enabled is deprecated. Instead, use yarn.system-metrics-publisher.enabled18/11/04 04:59:16 INFO mapreduce.JobSubmitter: Submitting tokens for job: job_1541270195271_000118/11/04 04:59:17 INFO impl.YarnClientImpl: Submitted application application_1541270195271_000118/11/04 04:59:17 INFO mapreduce.Job: The url to track the job: http://centos-aaron-h1:8088/proxy/application_1541270195271_0001/18/11/04 04:59:17 INFO mapreduce.Job: Running job: job_1541270195271_000118/11/04 04:59:29 INFO mapreduce.Job: Job job_1541270195271_0001 running in uber mode : false18/11/04 04:59:29 INFO mapreduce.Job: map 0% reduce 0%18/11/04 04:59:46 INFO mapreduce.Job: map 100% reduce 0%18/11/04 04:59:56 INFO mapreduce.Job: map 100% reduce 100%18/11/04 04:59:57 INFO mapreduce.Job: Job job_1541270195271_0001 completed successfully18/11/04 04:59:57 INFO mapreduce.Job: Counters: 49 File System Counters FILE: Number of bytes read=40 FILE: Number of bytes written=592624 FILE: Number of read operations=0 FILE: Number of large read operations=0 FILE: Number of write operations=0 HDFS: Number of bytes read=257 HDFS: Number of bytes written=13 HDFS: Number of read operations=9 HDFS: Number of large read operations=0 HDFS: Number of write operations=2 Job Counters Launched map tasks=2 Launched reduce tasks=1 Data-local map tasks=2 Total time spent by all maps in occupied slots (ms)=29268 Total time spent by all reduces in occupied slots (ms)=7337 Total time spent by all map tasks (ms)=29268 Total time spent by all reduce tasks (ms)=7337 Total vcore-milliseconds taken by all map tasks=29268 Total vcore-milliseconds taken by all reduce tasks=7337 Total megabyte-milliseconds taken by all map tasks=29970432 Total megabyte-milliseconds taken by all reduce tasks=7513088 Map-Reduce Framework Map input records=2 Map output records=2 Map output bytes=30 Map output materialized bytes=46 Input split bytes=235 Combine input records=2 Combine output records=2 Reduce input groups=1 Reduce shuffle bytes=46 Reduce input records=2 Reduce output records=1 Spilled Records=4 Shuffled Maps =2 Failed Shuffles=0 Merged Map outputs=2 GC time elapsed (ms)=798 CPU time spent (ms)=4970 Physical memory (bytes) snapshot=547995648 Virtual memory (bytes) snapshot=2537877504 Total committed heap usage (bytes)=259543040 Shuffle Errors BAD_ID=0 CONNECTION=0 IO_ERROR=0 WRONG_LENGTH=0 WRONG_MAP=0 WRONG_REDUCE=0 File Input Format Counters Bytes Read=22 File Output Format Counters Bytes Written=13
d.查看执行结果,_SUCCESS代表执行成功的文件,part-r-00000是输出结果文件
hadoop fs -ls /wordcount/outputhadoop fs -cat /wordcount/output/part-r-00000
五、hadoop命令详解
#1.获取命令提示hadoop fs#2.查看hadoop fs命令帮助,功能:输出这个命令参数手册hadoop fs -help#3.管道命令分页查看hadoop fs -cat /wordcount/output/part-r-00000 | more#4.功能:显示目录信息hadoop fs -ls 示例: hadoop fs -ls hdfs://hadoop-server01:9000/备注:这些参数中,hadoop-server01为namenode的主机名或域名,所有的hdfs路径都可以简写-->hadoop fs -ls / 等同于上一条命令的效果#5.功能:在hdfs上创建目录hadoop fs -mkdir 示例:hadoop fs -mkdir -p /aaa/bbb/cc/dd#6.功能:从本地剪切粘贴到hdfshadoop fs -moveFromLocal 示例:hadoop fs -moveFromLocal /home/hadoop/a.txt /aaa/bbb/cc/dd#7.功能:从hdfs剪切粘贴到本地hadoop fs -moveToLocal 示例:hadoop fs -moveToLocal /aaa/bbb/cc/dd /home/hadoop/a.txt#8.功能:追加一个文件到已经存在的文件末尾hadoop fs -appendToFile 示例:hadoop fs -appendToFile ./hello.txt hdfs://hadoop-server01:9000/hello.txt可以简写为:Hadoop fs -appendToFile ./hello.txt /hello.txt#9.功能:显示文件内容Hadoop fs -cat 示例:hadoop fs -cat /hello.txt#10.功能:显示一个文件的末尾hadoop fs -tail 示例:hadoop fs -tail /weblog/access_log.1#11.功能:以字符形式打印一个文件的内容hadoop fs -text 示例:hadoop fs -text /weblog/access_log.1#13.功能:linux文件系统中的用法一样,对文件所属权限-chgrp-chmod-chown示例:hadoop fs -chmod 666 /hello.txthadoop fs -chown someuser:somegrp /hello.txt#14.功能:从本地文件系统中拷贝文件到hdfs路径去hadoop fs -copyFromLocal 示例:hadoop fs -copyFromLocal ./jdk.tar.gz /aaa/#15.功能:从hdfs拷贝到本地hadoop fs -copyToLocal 示例:hadoop fs -copyToLocal /aaa/jdk.tar.gz#16.功能:从hdfs的一个路径拷贝hdfs的另一个路径hadoop fs -cp 示例: hadoop fs -cp /aaa/jdk.tar.gz /bbb/jdk.tar.gz.2#17.功能:在hdfs目录中移动文件hadoop fs -mv 示例: hadoop fs -mv /aaa/jdk.tar.gz /#18.功能:等同于copyToLocal,就是从hdfs下载文件到本地hadoop fs -get 示例:hadoop fs -get /aaa/jdk.tar.gz#19.功能:合并下载多个文件hadoop fs -getmerge 示例:比如hdfs的目录 /aaa/下有多个文件:log.1, log.2,log.3,...hadoop fs -getmerge /aaa/log.* ./log.sum#20.功能:等同于copyFromLocalhadoop fs -put 示例:hadoop fs -put /aaa/jdk.tar.gz /bbb/jdk.tar.gz.2#21.功能:删除文件或文件夹hadoop fs -rm 示例:hadoop fs -rm -r /aaa/bbb/#22.功能:删除空目录hadoop fs -rmdir 示例:hadoop fs -rmdir /aaa/bbb/ccc#23.功能:统计文件系统的可用空间信息hadoop fs -df 示例:hadoop fs -df -h /#24.功能:统计文件夹的大小信息hadoop fs -du示例:hadoop fs -du -s -h /aaa/*根目录统计需写全路径centos-aaron-h1为namenode域名hadoop fs -du -s -h hdfs://centos-aaron-h1:9000/#25.功能:统计一个指定目录下的文件节点数量hadoop fs -count 示例:hadoop fs -count /aaa/#26.功能:设置hdfs中文件的副本数量hadoop fs -setrep 示例:hadoop fs -setrep 3 /aaa/jdk.tar.gz <这里设置的副本数只是记录在namenode的元数据中,是否真的会有这么多副本,还得看datanode的数量>这里设置的副本数只是记录在namenode的元数据中,是否真的会有这么多副本,还得看datanode的数量>
最后补充:
a、hadoop hdfs上传大于设置的限制大小值的文件时,会进行分块上传到hdfs文件系统,对外还是表现为一个文件,但在内部可能存在不同的节点,且可能包含很多个块;
b、hadoop hdfs中没有用户和组的严格限定,你可以设置任何用户和组,即使设置的用户和组不存在也可以设置成功;
c、分块保存原理,上传时用Input循环读,当读的值大于设置值(默认128m)时,从新new一个socket和output写到另外一个分块文件,这样同一个文件的不同块就可能存在不同的集群节点,且每个块都有和设置值(默认3份)相同的副本;
d、mapreduce程序运行时,会在hdfs根目录产生一个临时文件夹tmp,是些临时数据等;
e、设置的副本数的值大于datanode节点时,最多只会保存副本数为datanode的节点数量,多一个文件块不会存多分副本在一台datanode节点上;
f、在namenode web控制台看到的文件副本数是元数据的副本值,真实值由于上面e说明的那个原因,可能存在偏差;
g、namenode的hdfs默认访问端口为9000
以上是博主本次文章的全部内容,如果大家觉得博主的文章还不错,请点赞;如果您对博主其它服务器技术或者博主本人感兴趣,请关注博主博客,并且欢迎随时跟博主沟通交流。