基于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