基于Hadoop的分布式文件系统，使用Java语言开发实现了一个本地文件管理系统+源代码+文档说明

package com.test.dao.file_dir; import java.io.File; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.text.SimpleDateFormat; import java.util.Date; import java.util.HashMap; import java.util.Map; import java.util.Random; import java.util.Stack; import java.util.concurrent.ExecutionException; import java.util.concurrent.FutureTask; import javax.swing.Icon; import javax.swing.ImageIcon; import javax.swing.JOptionPane; import com.test.db.DBManage; import com.test.tools.Tools; import com.test.ui.FilePanel; /** * 文件操作管理类 * @author asus * */ public class FileManager { // 文件分割 public FileSeperate fileSeperate ; // 文件合并 public FileCombination fileCombination ; // 删除文件时用到的栈 private Stack<Integer> deleteFileStack = new Stack<Integer>() ; // 数据库操作 public DBManage dbmanage ; public Connection connection ; public PreparedStatement preparedStatement ; public ResultSet resultSet ; public HdfsTools hdfsTool ; public FileManager(DBManage dbmanage) { this.dbmanage = dbmanage ; this.hdfsTool = new HdfsTools() ; } public FileManager() { this.dbmanage = new DBManage() ; this.hdfsTool = new HdfsTools() ; } // 显示文件列表 public void showFile(Icon icon , String fileName) { Tools.loginSuccess.filePanel = new FilePanel(icon , fileName) ; Tools.loginSuccess.fileBottomPanel.add(Tools.loginSuccess.filePanel) ; Tools.loginSuccess.repaint() ; } // 显示文件列表 public void showFileList(int parentId , int userId) { try { String showFile = "select * from file where parent_id = ? and u_id = ? order by f_type DESC" ; this.connection = this.dbmanage.getConnection() ; // this.preparedStatement = this.dbmanage.getPreparedStatement(Tools.SHOW_FILE) ; this.preparedStatement = this.dbmanage.getPreparedStatement(showFile) ; this.preparedStatement.setInt(1, parentId) ; this.preparedStatement.setInt(2, userId) ; this.resultSet = this.preparedStatement.executeQuery() ; while(this.resultSet.next()) { // 取得文件名 String fileName = this.resultSet.getString("f_name") ; String filetype = this.resultSet.getString("f_type") ; // 显示文件图标 if(filetype.equals("文件")) { this.showFile(new ImageIcon("image/file.png") , fileName) ; }else if(filetype.equals("文件夹")) { this.showFile(new ImageIcon("image/dir.png") , fileName) ; } } } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); }finally { // 关闭连接 if(this.resultSet != null) { try { this.resultSet.close() ; } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } this.dbmanage.closeLink() ; } } // 创建文件夹 public void createDir() { //随机产生1000以内的命名规则 String filename = "新建文件夹"+ (int)(Math.random()*1000); Date date = new Date(); String type = "文件夹"; long size = 0 ; //随机产生的文件名若重名，则继续随机产生，知道不重名为止 while (!checkFileName(filename)) { filename = "新建文件夹"+ (int)(Math.random()*1000); } try { String createDir = "insert into File (u_id , f_name , f_date , f_type , f_size , parent_id) values(? , ? , ? , ? , ? , ?)" ; this.connection = this.dbmanage.getConnection() ; // this.preparedStatement = this.dbmanage.getPreparedStatement(Tools.CREATE_DIR) ; this.preparedStatement = this.dbmanage.getPreparedStatement(createDir) ; this.preparedStatement.setInt(1, Tools.userId) ; this.preparedStatement.setString(2, filename) ; this.preparedStatement.setString(3, date.toString()) ; this.preparedStatement.setString(4, type) ; this.preparedStatement.setLong(5, size) ; this.preparedStatement.setInt(6, Tools.parentIdStack.lastElement()) ; this.preparedStatement.execute() ; // 新建的文件夹在界面上显示出来 Tools.loginSuccess.filePanel = new FilePanel(new ImageIcon("image/dir.png") , filename) ; Tools.loginSuccess.fileBottomPanel.add(Tools.loginSuccess.filePanel) ; Tools.loginSuccess.repaint(); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } finally { // 关闭连接 if(this.resultSet != null) { try { this.resultSet.close() ; } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } this.dbmanage.closeLink() ; } } /** * 检查文件是否重名,通过文件类型和文件名查询 */ public boolean checkFileName(String filename) { try { String checkFileName = "select * from File where u_id = ? and f_name = ? and parent_id = ?" ; this.connection = this.dbmanage.getConnection() ; // this.preparedStatement = this.dbmanage.getPreparedStatement(Tools.CHECK_FILE_NAME) ; this.preparedStatement = this.dbmanage.getPreparedStatement(checkFileName) ; this.preparedStatement.setInt(1, Tools.userId) ; this.preparedStatement.setString(2, filename) ; this.preparedStatement.setInt(3, Tools.parentIdStack.lastElement()) ; this.resultSet = this.preparedStatement.executeQuery() ; while(this.resultSet.next()) { return false ; } } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); return false ; } finally { // 关闭连接 if(this.resultSet != null) { try { this.resultSet.close() ; } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } this.dbmanage.closeLink() ; } return true ; } /** * 检查文件是否重名,通过文件ID号查询 */ public boolean checkPasteFileName() { try { String checkPasteFileName = "select * from File where f_name = (select f_name from File where f_id = ?) and u_id = ? and parent_id = ?" ; this.connection = this.dbmanage.getConnection() ; // this.preparedStatement = this.dbmanage.getPreparedStatement(Tools.CHECK_PASTE_FILE_NAME) ; this.preparedStatement = this.dbmanage.getPreparedStatement(checkPasteFileName) ; this.preparedStatement.setInt(1, Tools.cutFileId) ; this.preparedStatement.setInt(2, Tools.userId) ; this.preparedStatement.setInt(3, Tools.parentIdStack.lastElement()) ; this.resultSet = this.preparedStatement.executeQuery() ; if(this.resultSet.next()) { JOptionPane.showMessageDialog(null, "该文件夹已存在，不能粘贴", "警告信息", 1); return false ; } } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); return false ; } finally { // 关闭连接 if(this.resultSet != null) { try { this.resultSet.close() ; } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } this.dbmanage.closeLink() ; } return true ; } /** * 打开文件夹 */ public boolean openDir(String filename) { try { String queryFileId = "select * from File where u_id = ? and f_name = ? and parent_id = ?" ; this.connection = this.dbmanage.getConnection() ; // this.preparedStatement = this.dbmanage.getPreparedStatement(Tools.QUERY_FILE_ID) ; this.preparedStatement = this.dbmanage.getPreparedStatement(queryFileId) ; this.preparedStatement.setInt(1, Tools.userId) ; this.preparedStatement.setString(2, filename) ; this.preparedStatement.setInt(3, Tools.parentIdStack.lastElement()) ; this.resultSet = this.preparedStatement.executeQuery() ; int fileId = -1; String filetype = null ; if(this.resultSet.next()) { fileId = this.resultSet.getInt("f_id") ; filetype = this.resultSet.getString("f_type") ; } // 双击打开文件夹 if(filetype != null && filetype.equals("文件夹")) { Tools.parentIdStack.add(fileId) ; Tools.loginSuccess.fileBottomPanel.removeAll() ; this.showFileList(Tools.parentIdStack.lastElement(), Tools.userId) ; Tools.loginSuccess.fileBottomPanel.repaint() ; // 设置文件路径 String context = Tools.loginSuccess.search.getText() ; Tools.loginSuccess.search.setText(context + "\\" + filename) ; }else if(filet