SSM框架分页展示Hdfs文件列表,返回上一级,进入下一级,上传文件,删除文件,下载文件前后端代码
时间: 2023-08-31 14:24:59 浏览: 105
SSM框架实现文件上传及其分页
4星 · 用户满意度95%
### 回答1:
由于HDFS是分布式文件系统,其文件列表的获取需要通过HDFS API来实现。下面给出一个基于SSM框架的HDFS文件操作示例,包括分页展示、返回上一级、进入下一级、上传文件、删除文件、下载文件的前后端代码。
前端代码:
```html
<!-- HDFS文件列表展示 -->
<table id="fileTable" class="table table-striped">
<thead>
<tr>
<th>文件名</th>
<th>文件类型</th>
<th>文件大小</th>
<th>修改时间</th>
<th>操作</th>
</tr>
</thead>
<tbody>
<tr v-for="file in fileList" :key="file.path">
<td>{{file.name}}</td>
<td>{{file.type}}</td>
<td>{{file.size}}</td>
<td>{{file.modificationTime}}</td>
<td>
<button v-if="file.type==='DIRECTORY'" @click="enterDir(file.path)">进入</button>
<button v-if="file.type==='FILE'" @click="downloadFile(file.path)">下载</button>
<button v-if="file.type==='FILE'" @click="deleteFile(file.path)">删除</button>
</td>
</tr>
</tbody>
</table>
<!-- 分页组件 -->
<div class="pagination">
<button :disabled="pageNum===1" @click="prevPage">上一页</button>
<span>{{pageNum}} / {{totalPage}}</span>
<button :disabled="pageNum===totalPage" @click="nextPage">下一页</button>
</div>
<!-- 返回上一级 -->
<button v-if="currentPath !== '/'" @click="backToParent">返回上一级</button>
<!-- 上传文件 -->
<input type="file" @change="uploadFile">
<!-- 提示信息 -->
<div v-if="message">{{message}}</div>
```
后端代码:
```java
@Controller
@RequestMapping("/hdfs")
public class HdfsFileController {
private static final String HDFS_URI = "hdfs://localhost:9000";
private static final Configuration conf = new Configuration();
private static final FileSystem hdfs;
static {
conf.set("fs.defaultFS", HDFS_URI);
try {
hdfs = FileSystem.get(conf);
} catch (IOException e) {
throw new RuntimeException(e);
}
}
/**
* 分页展示HDFS文件列表
* @param path 目录路径
* @param pageNum 当前页码
* @param pageSize 每页大小
* @return
*/
@GetMapping("/list")
@ResponseBody
public List<HdfsFile> listFiles(@RequestParam(defaultValue = "/") String path,
@RequestParam(defaultValue = "1") int pageNum,
@RequestParam(defaultValue = "10") int pageSize) throws IOException {
Path hdfsPath = new Path(path);
FileStatus[] fileStatuses = hdfs.listStatus(hdfsPath);
List<HdfsFile> fileList = new ArrayList<>();
for (FileStatus fileStatus : fileStatuses) {
HdfsFile hdfsFile = new HdfsFile();
hdfsFile.setName(fileStatus.getPath().getName());
hdfsFile.setPath(fileStatus.getPath().toString());
if (fileStatus.isDirectory()) {
hdfsFile.setType("DIRECTORY");
hdfsFile.setSize("-");
} else {
hdfsFile.setType("FILE");
hdfsFile.setSize(StringUtils.byteCountToDisplaySize(fileStatus.getLen()));
}
hdfsFile.setModificationTime(new Date(fileStatus.getModificationTime()));
fileList.add(hdfsFile);
}
// 分页
int total = fileList.size();
int start = (pageNum - 1) * pageSize;
int end = Math.min(start + pageSize, total);
List<HdfsFile> pageList = fileList.subList(start, end);
// 计算总页数
int totalPage = (total + pageSize - 1) / pageSize;
// 将总页数和当前路径信息加入返回结果
pageList.forEach(file -> file.setTotalPage(totalPage));
pageList.forEach(file -> file.setCurrentPath(path));
return pageList;
}
/**
* 返回上一级目录
* @param currentPath 当前目录路径
* @return
*/
@GetMapping("/parent")
@ResponseBody
public List<HdfsFile> backToParent(@RequestParam(defaultValue = "/") String currentPath) throws IOException {
Path path = new Path(currentPath);
Path parentPath = path.getParent();
if (parentPath == null) {
parentPath = new Path("/");
}
return listFiles(parentPath.toString(), 1, 10);
}
/**
* 进入子目录
* @param childPath 子目录路径
* @return
*/
@GetMapping("/child")
@ResponseBody
public List<HdfsFile> enterChild(@RequestParam String childPath) throws IOException {
return listFiles(childPath, 1, 10);
}
/**
* 上传文件
* @param currentPath 当前目录路径
* @param file 上传的文件
* @return
*/
@PostMapping("/upload")
@ResponseBody
public String uploadFile(@RequestParam(defaultValue = "/") String currentPath,
@RequestParam("file") MultipartFile file) throws IOException {
if (file.isEmpty()) {
return "上传失败,请选择文件";
}
String fileName = file.getOriginalFilename();
Path path = new Path(currentPath, fileName);
if (hdfs.exists(path)) {
return "文件已存在";
}
try (InputStream inputStream = file.getInputStream()) {
FSDataOutputStream outputStream = hdfs.create(path);
IOUtils.copyBytes(inputStream, outputStream, conf);
outputStream.close();
}
return "上传成功";
}
/**
* 删除文件或目录
* @param path 文件或目录路径
* @return
*/
@DeleteMapping("/delete")
@ResponseBody
public String deleteFile(@RequestParam String path) throws IOException {
Path hdfsPath = new Path(path);
boolean success = hdfs.delete(hdfsPath, true);
if (success) {
return "删除成功";
} else {
return "删除失败";
}
}
/**
* 下载文件
* @param path 文件路径
* @param response
*/
@GetMapping("/download")
public void downloadFile(@RequestParam String path, HttpServletResponse response) throws IOException {
Path hdfsPath = new Path(path);
FSDataInputStream inputStream = hdfs.open(hdfsPath);
String fileName = hdfsPath.getName();
response.setHeader("Content-Disposition", String.format("attachment; filename=\"%s\"", fileName));
IOUtils.copyBytes(inputStream, response.getOutputStream(), conf);
inputStream.close();
}
}
```
其中`HdfsFile`为自定义的文件类,用于存储文件信息。完整代码请参考:https://github.com/luojia65/hdfs-file-manager
### 回答2:
SSM框架是一种Java开发的轻量级全栈框架,主要包括Spring、SpringMVC和MyBatis三个核心组件。下面将分别介绍如何使用SSM框架进行分页展示HDFS文件列表以及实现返回上一级、进入下一级、上传文件、删除文件和下载文件的前后端代码。
1. 分页展示HDFS文件列表的前后端代码:
后端代码:
- 使用Hadoop的HDFS API获取指定目录下的文件列表;
- 使用PageHelper插件实现分页功能;
- 将获取的分页结果封装为实体类并返回给前端。
前端代码:
- 使用HTML和CSS布局文件列表页面;
- 使用Ajax发送请求获取后端返回的分页数据;
- 使用JavaScript动态生成文件列表并显示在页面上。
2. 返回上一级和进入下一级的前后端代码:
后端代码:
- 根据用户的请求确定要访问的目录路径;
- 根据用户请求的操作(返回上一级或进入下一级)在HDFS中进行目录切换;
- 返回切换后的目录路径给前端。
前端代码:
- 在页面上显示当前访问的目录路径;
- 使用Ajax发送请求将操作类型(返回上一级或进入下一级)发送给后端;
- 根据后端返回的目录路径更新页面显示。
3. 上传文件的前后端代码:
后端代码:
- 使用MultipartFile类型接收前端传递的文件;
- 使用HDFS API将文件写入指定目录。
前端代码:
- 添加文件上传的表单和按钮;
- 使用Ajax发送文件上传请求给后端;
- 显示上传进度和结果。
4. 删除文件的前后端代码:
后端代码:
- 根据用户请求的文件路径,使用HDFS API删除对应的文件。
前端代码:
- 在文件列表中每个文件后面添加删除按钮;
- 使用Ajax发送请求告知后端要删除的文件路径;
- 根据后端返回的结果更新页面显示。
5. 下载文件的前后端代码:
后端代码:
- 接收前端传递的文件路径;
- 使用HDFS API读取对应的文件;
- 将文件流返回给前端。
前端代码:
- 在文件列表中每个文件后面添加下载按钮;
- 点击下载按钮时,使用Ajax发送请求获取文件路径;
- 根据后端返回的文件流进行文件下载。
以上是大致的思路,具体实现还需要根据具体项目需求进行调整和完善。
### 回答3:
SSM框架分页展示Hdfs文件列表,返回上一级,进入下一级,上传文件,删除文件,下载文件前后端代码如下:
后端代码(使用Java语言和Spring框架):
1. HdfsController.java
```java
@Controller
@RequestMapping("/hdfs")
public class HdfsController {
@Autowired
private HdfsService hdfsService;
// 分页展示HDFS文件列表
@RequestMapping("/list")
@ResponseBody
public List<String> getFileList(String path, int pageNum, int pageSize) {
return hdfsService.getFileList(path, pageNum, pageSize);
}
// 返回上一级目录
@RequestMapping("/parent")
@ResponseBody
public String getParent(String path) {
return hdfsService.getParent(path);
}
// 进入下一级目录
@RequestMapping("/child")
@ResponseBody
public String getChild(String path, String childName) {
return hdfsService.getChild(path, childName);
}
// 上传文件
@RequestMapping("/upload")
@ResponseBody
public boolean uploadFile(String path, MultipartFile file) {
return hdfsService.uploadFile(path, file);
}
// 删除文件
@RequestMapping("/delete")
@ResponseBody
public boolean deleteFile(String path) {
return hdfsService.deleteFile(path);
}
// 下载文件
@RequestMapping(value = "/download", method = RequestMethod.GET)
public void downloadFile(String path, HttpServletResponse response) {
hdfsService.downloadFile(path, response);
}
}
```
2. HdfsService.java
```java
public interface HdfsService {
List<String> getFileList(String path, int pageNum, int pageSize);
String getParent(String path);
String getChild(String path, String childName);
boolean uploadFile(String path, MultipartFile file);
boolean deleteFile(String path);
void downloadFile(String path, HttpServletResponse response);
}
```
3. HdfsServiceImpl.java
```java
@Service
public class HdfsServiceImpl implements HdfsService {
private Configuration conf;
private FileSystem fs;
public HdfsServiceImpl() {
conf = new Configuration();
conf.set("fs.defaultFS", "hdfs://localhost:9000");
try {
fs = FileSystem.get(conf);
} catch (IOException e) {
e.printStackTrace();
}
}
@Override
public List<String> getFileList(String path, int pageNum, int pageSize) {
List<String> fileList = new ArrayList<>();
try {
FileStatus[] fileStatuses = fs.listStatus(new Path(path));
int start = (pageNum - 1) * pageSize;
int end = Math.min(pageNum * pageSize, fileStatuses.length);
for (int i = start; i < end; i++) {
fileList.add(fileStatuses[i].getPath().toString());
}
} catch (IOException e) {
e.printStackTrace();
}
return fileList;
}
@Override
public String getParent(String path) {
Path parentPath = new Path(path).getParent();
if (parentPath != null){
return parentPath.toString();
}
return "/";
}
@Override
public String getChild(String path, String childName) {
Path childPath = new Path(path, childName);
return childPath.toString();
}
@Override
public boolean uploadFile(String path, MultipartFile file) {
try {
String fileName = file.getOriginalFilename();
fs.copyFromLocalFile(false, true, new Path(path + fileName), new Path(fileName));
return true;
} catch (IOException e) {
e.printStackTrace();
return false;
}
}
@Override
public boolean deleteFile(String path) {
try {
boolean result = fs.delete(new Path(path), true);
return result;
} catch (IOException e) {
e.printStackTrace();
return false;
}
}
@Override
public void downloadFile(String path, HttpServletResponse response) {
try {
Path filePath = new Path(path);
FSDataInputStream in = fs.open(filePath);
OutputStream out = response.getOutputStream();
IOUtils.copyBytes(in, out, 4096, true);
} catch (IOException e) {
e.printStackTrace();
}
}
}
```
前端代码(使用HTML和JavaScript):
1. index.html
```html
<!DOCTYPE html>
<html>
<head>
<meta charset="UTF-8">
<title>HDFS文件列表</title>
<script src="https://cdn.bootcss.com/jquery/3.5.1/jquery.min.js"></script>
</head>
<body>
<h2>HDFS文件列表</h2>
<div>
<button onclick="getParent()">返回上一级</button>
<button onclick="getChild()">进入下一级</button>
<input type="file" id="uploadFile">
<button onclick="uploadFile()">上传文件</button>
</div>
<div id="fileList"></div>
<script src="js/main.js"></script>
</body>
</html>
```
2. main.js
```javascript
$(document).ready(function () {
getFileList("/");
});
function getFileList(path, pageNum, pageSize) {
$.ajax({
url: "/hdfs/list",
type: "GET",
data: {
path: path,
pageNum: pageNum,
pageSize: pageSize
},
success: function (data) {
showFileList(data);
}
});
}
function getParent() {
var path = $("#path").val();
$.ajax({
url: "/hdfs/parent",
type: "GET",
data: {
path: path
},
success: function (data) {
getFileList(data);
}
});
}
function getChild(childName) {
var path = $("#path").val();
$.ajax({
url: "/hdfs/child",
type: "GET",
data: {
path: path,
childName: childName
},
success: function (data) {
getFileList(data);
}
});
}
function uploadFile() {
var path = $("#path").val();
var file = document.getElementById("uploadFile").files[0];
var formData = new FormData();
formData.append("path", path);
formData.append("file", file);
$.ajax({
url: "/hdfs/upload",
type: "POST",
data: formData,
contentType: false,
processData: false,
success: function (data) {
getFileList(path);
}
});
}
function deleteFile(path) {
$.ajax({
url: "/hdfs/delete",
type: "GET",
data: {
path: path
},
success: function (data) {
getFileList($("#path").val());
}
});
}
function downloadFile(path) {
window.open("/hdfs/download?path=" + path);
}
function showFileList(data) {
$("#fileList").empty();
$.each(data, function (index, value) {
if (value.endsWith("/")) {
var childName = value.substring(value.lastIndexOf("/") + 1, value.length - 1);
$("#fileList").append("<div><span>" + childName + "</span><button onclick='getChild(\"" + childName + "\")'>进入</button></div>");
} else {
var fileName = value.substring(value.lastIndexOf("/") + 1);
$("#fileList").append("<div><span>" + fileName + "</span><button onclick='downloadFile(\"" + value + "\")'>下载</button><button onclick='deleteFile(\"" + value + "\")'>删除</button></div>");
}
});
}
```
阅读全文