# springboot-hadoop

**Repository Path**: silentlyCode/springboot-hadoop

## Basic Information

- **Project Name**: springboot-hadoop
- **Description**: No description available
- **Primary Language**: Java
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 1
- **Created**: 2020-10-21
- **Last Updated**: 2021-12-08

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

## 简介
springboot整合Hadoop，进击大数据一小步。

## 功能介绍
**1、hdfs基本操作**
###### ① 实现最基本的文件操作系统  √

**2、MapReduce基本操作**
###### ① 实现简单的分词和统计  √

**3、yaml基本了解以及操作**

**4、案例**

###### ① 数据分析（日志为案例）   √
② 系统推荐   

② 个体价值计算   

## Hadoop 3.1.2安装（仅展示win下安装方式）
[Hadoop安装教程链接](http://note.youdao.com/noteshare?id=5b22302f342ecf12c5a7789208a90238)

## 工程结构
``` 
hadoop-demo
├── docs -- 相关文件存放
├── src
├──── analyze -- 数据分析
├──── base -- 前端视图基础类
├──── config -- hadoop配置类
├──── controller -- hdfs操作接口 
├──── hdfs -- hdfs 相关配置以及操作
├──── mapReduce -- mapReduce 相关配置以及操作
├──── props -- hadoop属性配置
├──── util -- 工具类 
└──── HadoopDemoApplication.java -- springboot启动类
``` 

## 一、HDFS接口功能展示
**1、查看目录**
``` 
GET请求 请求地址: http://127.0.0.1:8080/file/getPathInfo
参数说明：{"path": ${目录路径}}
参数示例：{"path": "/"}
``` 

**2、创建目录**
``` 
POST请求 请求地址: http://127.0.0.1:8080/file/mkdir
参数说明：{"folderPath": ${目录路径}}
form-data参数示例：{"folderPath": "/data"}
``` 

**3、上传文件**
``` 
POST请求 请求地址: http://127.0.0.1:8080/file/upload
参数说明：{"uploadPath": ${hdfs目录路径}, "file": ${MultipartFile文件}}
form-data参数示例：{"uploadPath": "/data", "file": ${MultipartFile文件}}
``` 

**4、上传本地文件到hdfs**
``` 
POST请求 请求地址: http://127.0.0.1:8080/file/uploadFileFromLocal
参数说明：{"path": ${本地文件路径}, "uploadPath": ${上传的hdfs路径}}
form-data参数示例：{"path": "/data", "uploadPath": "C:\Users\XXX\Desktop\用户信息-导入模板.xlsx"}
``` 

**5、获取目录下文件列表**
``` 
GET请求 请求地址: http://127.0.0.1:8080/file/getPathInfo
参数说明：{"path": ${目录路径}}
参数示例：{"path": "/"}
``` 

**6、下载文件**
``` 
POST请求 请求地址: http://127.0.0.1:8080/file/download
参数说明：{"path": ${hdfs目录路径}, "fileName": ${MultipartFile文件}}
form-data参数示例：{"path": "/data", "fileName": "用户信息-导入模板.xlsx"}
``` 

**7、下载文件到本地电脑**
``` 
POST请求 请求地址: http://127.0.0.1:8080/file/downloadFileFromLocal
参数说明：{"path": ${hdfs文件路径}, "downloadPath": ${本地电脑路径}}
form-data参数示例：{"path": "/data", "downloadPath": "C:\Users\XXX\Desktop\"}
``` 

**8、复制文件**
``` 
POST请求 请求地址: http://127.0.0.1:8080/file/copyFile
参数说明：{"sourcePath": ${hdfs源文件路径}, "targetPath": ${hdfs目标文件路径}}
form-data参数示例：{"sourcePath": "/data/用户信息-导入模板.xlsx", "targetPath": "/test/用户信息-导入模板.xlsx"}
``` 

**9、读取文件内容**
``` 
POST请求 请求地址: http://127.0.0.1:8080/file/readFile
参数说明：{"filePath": ${hdfs文件路径}}
form-data参数示例：{"filePath": "/data/计税公式.txt"}
``` 

**10、文件或文件夹重命名**
``` 
POST请求 请求地址: http://127.0.0.1:8080/file/renameFile
参数说明：{"oldName": ${hdfs旧文件名称}, "newName": ${hdfs新文件名称}}
form-data参数示例：{"oldName": "/data/用户信息-导入模板.xlsx", "newName": "/data/用户信息-重命名.xlsx"}
``` 

**11、删除文件或文件夹**
``` 
POST请求 请求地址: http://127.0.0.1:8080/file/rmdir
参数说明：{"path": ${hdfs文件路径}, "fileName": ${文件名称，不填为删除文件夹}}
form-data参数示例：{"path": "/data", "fileName": "用户信息-导入模板.xlsx"}
``` 

## 二、MapReduce接口功能展示
**1、单词统计(统计指定key单词的出现次数)**
``` 
GET请求 请求地址: http://127.0.0.1:8080/reduce/wordCount
参数说明：{"jobName": ${计划名称}, "inputPath": ${分词路径，如果是文件家路径，则默认分词该文件夹下所有的文件}}
参数示例：{"jobName": "test", "inputPath": "/fenci"}
``` 

HDFS结果查询（指令）
``` 
遍历根目录下的文件 
hadoop fs -ls / 

查看分词结果
hadoop fs -cat /output/test/part-r-00000
``` 

**2、数据分析（日志为案例）**

日志数据为nginx产生的日志，Linux一般存放在/var/log/nginx，自行下载上传到hdfs的/log目录下，也可以从项目的docs文件下获取“access.log-20190720”数据文件

日志分析三种指标（案例只列出以下几种指标，可自行分析其他指标）

① 请求地址

② 响应结果

③ 请求类型
``` 
POST请求 请求地址: 127.0.0.1:8080/analyze/log
参数说明：{"jobName": ${计划名称}, "inputPath": ${分词路径，如果是文件家路径，则默认分词该文件夹下所有的文件}}
参数示例：{"jobName": "log", "inputPath": "/log"}

查看请求类型统计
hadoop fs -cat /output/log-request/part-r-00000

查看响应结果统计
hadoop fs -cat hadoop fs -cat /output/log-requestStatus/part-r-00000

查看请求类型统计
hadoop fs -cat /output/log-requestMethod/part-r-00000
``` 

## 提示
此demo只是作为Hadoop学习demo，若有其他请联系作者

Email：*yuanjjrr@foxmail.com*