SSM框架分页展示Hdfs文件列表上传文件,删除文件,下载文件前后端代码
时间: 2023-09-04 11:04:05 浏览: 104
### 回答1:
首先需要明确的是,HDFS是一个分布式文件系统,与传统的文件系统不同,因此需要使用特定的API进行操作。在Java中,可以使用Hadoop提供的API进行操作。
一、分页展示HDFS文件列表
前端代码:
```html
<!-- 文件列表展示 -->
<table class="table table-bordered table-hover">
<thead>
<tr>
<th>文件名</th>
<th>文件大小</th>
<th>修改时间</th>
</tr>
</thead>
<tbody>
<tr th:each="file : ${fileList}">
<td th:text="${file.name}"></td>
<td th:text="${file.size}"></td>
<td th:text="${#dates.format(file.modificationTime, 'yyyy-MM-dd HH:mm:ss')}"></td>
</tr>
</tbody>
</table>
<!-- 分页 -->
<nav aria-label="Page navigation">
<ul class="pagination">
<li th:class="${pageInfo.hasPreviousPage} ? '':'disabled'">
<a th:href="@{/file/list(pageNum=1)}" aria-label="Previous">
<span aria-hidden="true">«</span>
</a>
</li>
<li th:each="pageNum : ${pageInfo.navigatepageNums}">
<a th:href="@{/file/list(pageNum=${pageNum})}" th:text="${pageNum}" th:class="${pageNum == pageInfo.pageNum} ? 'active':''"></a>
</li>
<li th:class="${pageInfo.hasNextPage} ? '':'disabled'">
<a th:href="@{/file/list(pageNum=${pageInfo.pages})}" aria-label="Next">
<span aria-hidden="true">»</span>
</a>
</li>
</ul>
</nav>
```
后端代码:
```java
@RequestMapping("/file/list")
public String listFiles(Model model,
@RequestParam(defaultValue = "1") Integer pageNum,
@RequestParam(defaultValue = "10") Integer pageSize) {
try {
// 获取Hadoop配置信息
Configuration conf = new Configuration();
conf.set("fs.defaultFS", "hdfs://localhost:9000");
conf.set("fs.hdfs.impl", "org.apache.hadoop.hdfs.DistributedFileSystem");
// 获取HDFS文件列表
FileSystem fs = FileSystem.get(conf);
Path path = new Path("/");
FileStatus[] fileStatuses = fs.listStatus(path);
// 文件列表分页展示
PageHelper.startPage(pageNum, pageSize);
List<HdfsFile> fileList = Arrays.stream(fileStatuses)
.map(HdfsFile::new)
.collect(Collectors.toList());
PageInfo<HdfsFile> pageInfo = new PageInfo<>(fileList);
model.addAttribute("fileList", fileList);
model.addAttribute("pageInfo", pageInfo);
} catch (IOException e) {
e.printStackTrace();
}
return "file/list";
}
```
二、上传文件
前端代码:
```html
<form method="post" enctype="multipart/form-data" th:action="@{/file/upload}" th:object="${file}">
<div class="form-group">
<label for="name">文件名:</label>
<input type="text" class="form-control" id="name" th:field="*{name}" placeholder="请输入文件名" required>
</div>
<div class="form-group">
<label for="file">选择文件:</label>
<input type="file" id="file" name="file" required>
</div>
<button type="submit" class="btn btn-success">上传</button>
</form>
```
后端代码:
```java
@PostMapping("/file/upload")
public String uploadFile(@RequestParam("file") MultipartFile file,
@RequestParam("name") String name) {
try {
// 获取Hadoop配置信息
Configuration conf = new Configuration();
conf.set("fs.defaultFS", "hdfs://localhost:9000");
conf.set("fs.hdfs.impl", "org.apache.hadoop.hdfs.DistributedFileSystem");
// 上传文件到HDFS
FileSystem fs = FileSystem.get(conf);
Path dstPath = new Path("/" + name);
InputStream inputStream = file.getInputStream();
OutputStream outputStream = fs.create(dstPath);
IOUtils.copyBytes(inputStream, outputStream, 4096, true);
} catch (IOException e) {
e.printStackTrace();
}
return "redirect:/file/list";
}
```
三、删除文件
前端代码:
```html
<a th:href="@{/file/delete(name=${file.name})}" class="btn btn-danger btn-sm" onclick="return confirm('确定要删除该文件吗?')">删除</a>
```
后端代码:
```java
@GetMapping("/file/delete")
public String deleteFile(@RequestParam("name") String name) {
try {
// 获取Hadoop配置信息
Configuration conf = new Configuration();
conf.set("fs.defaultFS", "hdfs://localhost:9000");
conf.set("fs.hdfs.impl", "org.apache.hadoop.hdfs.DistributedFileSystem");
// 删除文件
FileSystem fs = FileSystem.get(conf);
Path path = new Path("/" + name);
fs.delete(path, false);
} catch (IOException e) {
e.printStackTrace();
}
return "redirect:/file/list";
}
```
四、下载文件
前端代码:
```html
<a th:href="@{/file/download(name=${file.name})}" class="btn btn-primary btn-sm">下载</a>
```
后端代码:
```java
@GetMapping("/file/download")
public ResponseEntity<InputStreamResource> downloadFile(@RequestParam("name") String name) {
try {
// 获取Hadoop配置信息
Configuration conf = new Configuration();
conf.set("fs.defaultFS", "hdfs://localhost:9000");
conf.set("fs.hdfs.impl", "org.apache.hadoop.hdfs.DistributedFileSystem");
// 下载文件
FileSystem fs = FileSystem.get(conf);
Path path = new Path("/" + name);
InputStream inputStream = fs.open(path);
HttpHeaders headers = new HttpHeaders();
headers.add(HttpHeaders.CONTENT_DISPOSITION, "attachment; filename=" + name);
return ResponseEntity.ok().headers(headers).body(new InputStreamResource(inputStream));
} catch (IOException e) {
e.printStackTrace();
}
return null;
}
```
以上是SSM框架分页展示HDFS文件列表上传文件,删除文件,下载文件前后端代码的实现。
### 回答2:
SSM框架是指使用Spring + SpringMVC + MyBatis的开发环境,下面将介绍如何利用SSM框架来实现HDFS文件列表的分页展示、上传文件、删除文件和下载文件的前后端代码。
首先,需要在后端编写对应的Controller来处理前端的请求。假设后端Controller的路径为"/hdfs",那么可以按照以下方式定义相关方法:
1. 分页展示HDFS文件列表:
```
@RequestMapping(value = "/filelist", method = RequestMethod.GET)
@ResponseBody
public List<String> getFileList(@RequestParam("pageNum") int pageNum, @RequestParam("pageSize") int pageSize) {
// 在这里使用HDFS API获取指定路径下的文件列表
// 根据pageNum和pageSize进行分页处理,并返回一页的文件列表
}
```
其中,`pageNum`表示页码,`pageSize`表示每页的文件数量。通过HDFS API获取文件列表后,根据pageNum和pageSize来进行分页操作,最后返回一页的文件列表。
2. 上传文件:
```
@RequestMapping(value = "/upload", method = RequestMethod.POST)
public void uploadFile(@RequestParam("file") MultipartFile file) {
// 在这里使用HDFS API将文件上传到指定路径
}
```
通过`@RequestParam("file") MultipartFile file`来接收前端传递的文件,并使用HDFS API将文件上传到指定的路径。
3. 删除文件:
```
@RequestMapping(value = "/delete", method = RequestMethod.DELETE)
public void deleteFile(@RequestParam("fileName") String fileName) {
// 在这里使用HDFS API删除指定路径下的文件
}
```
通过`@RequestParam("fileName") String fileName`来接收需要删除的文件名,然后使用HDFS API来删除指定路径下的文件。
4. 下载文件:
```
@RequestMapping(value = "/download", method = RequestMethod.GET)
public ResponseEntity<Resource> downloadFile(@RequestParam("fileName") String fileName) {
// 在这里使用HDFS API下载指定路径下的文件,并返回ResponseEntity<Resource>
}
```
通过`@RequestParam("fileName") String fileName`来接收需要下载的文件名,然后使用HDFS API下载指定路径下的文件,并将文件内容封装到ResponseEntity<Resource>中返回。
上述代码中的HDFS API的使用可以参考Hadoop官方文档或者第三方Hadoop相关的库,具体使用方式可以根据实际需求进行调整。
在前端方面,可以使用Ajax进行异步请求,通过jQuery等工具发送请求到后端Controller的对应路径,处理相应的操作。
以上介绍了利用SSM框架实现HDFS文件列表的分页展示、上传文件、删除文件和下载文件的前后端代码,希望对你有所帮助。
### 回答3:
以下是一个使用SSM框架实现分页展示HDFS文件列表、上传文件、删除文件和下载文件的前后端代码示例:
后端代码(Java):
@Controller
@RequestMapping("/hdfs")
public class HdfsController {
@Autowired
private HdfsService hdfsService;
@RequestMapping("/list")
@ResponseBody
public List<HdfsFile> getFileList(@RequestParam(defaultValue = "1") int pageNum, @RequestParam(defaultValue = "10") int pageSize) {
return hdfsService.getFileList(pageNum, pageSize);
}
@RequestMapping("/upload")
@ResponseBody
public String uploadFile(MultipartFile file) {
if (file != null) {
return hdfsService.uploadFile(file);
} else {
return "上传文件为空";
}
}
@RequestMapping("/delete")
@ResponseBody
public String deleteFile(@RequestParam String fileName) {
return hdfsService.deleteFile(fileName);
}
@RequestMapping("/download")
public void downloadFile(@RequestParam String fileName, HttpServletResponse response) {
hdfsService.downloadFile(fileName, response);
}
}
@Service
public class HdfsServiceImpl implements HdfsService {
@Autowired
private FileSystem fileSystem;
@Override
public List<HdfsFile> getFileList(int pageNum, int pageSize) {
// 实现文件列表的分页查询逻辑
// ...
return fileList;
}
@Override
public String uploadFile(MultipartFile file) {
// 实现文件上传逻辑
// ...
return "文件上传成功";
}
@Override
public String deleteFile(String fileName) {
// 实现文件删除逻辑
// ...
return "文件删除成功";
}
@Override
public void downloadFile(String fileName, HttpServletResponse response) {
// 实现文件下载逻辑
// ...
}
}
前端代码(HTML + JavaScript):
<html>
<head>
<script src="https://cdn.bootcss.com/jquery/3.4.1/jquery.min.js"></script>
</head>
<body>
<h1>HDFS文件列表</h1>
<table id="fileListTable">
<thead>
<th>文件名</th>
<th>操作</th>
</thead>
<tbody>
</tbody>
</table>
<input type="file" id="uploadFile" />
<button onclick="upload()">上传文件</button>
<input type="text" id="deleteFileName" placeholder="请输入要删除的文件名" />
<button onclick="deleteFile()">删除文件</button>
<input type="text" id="downloadFileName" placeholder="请输入要下载的文件名" />
<button onclick="downloadFile()">下载文件</button>
<script>
function refreshFileList(pageNum, pageSize) {
$.ajax({
type: "GET",
url: "/hdfs/list?pageNum=" + pageNum + "&pageSize=" + pageSize,
success: function(data) {
var fileListTable = $("#fileListTable tbody");
fileListTable.empty();
$.each(data, function(index, file) {
fileListTable.append("<tr><td>" + file.fileName + "</td><td><a href='/hdfs/download?fileName=" + file.fileName + "'>下载</a></td></tr>");
});
}
});
}
function upload() {
var formData = new FormData();
var file = $("#uploadFile")[0].files[0];
formData.append("file", file);
$.ajax({
type: "POST",
url: "/hdfs/upload",
data: formData,
processData: false,
contentType: false,
success: function(data) {
alert(data);
refreshFileList(1, 10);
}
});
}
function deleteFile() {
var fileName = $("#deleteFileName").val();
$.ajax({
type: "POST",
url: "/hdfs/delete?fileName=" + fileName,
success: function(data) {
alert(data);
refreshFileList(1, 10);
}
});
}
function downloadFile() {
var fileName = $("#downloadFileName").val();
window.location.href = "/hdfs/download?fileName=" + fileName;
}
$(document).ready(function() {
refreshFileList(1, 10);
});
</script>
</body>
</html>
以上代码是一个简单的示例,实际应用中可能需要根据具体需求进行适当修改和调整。
阅读全文