Java文件上传管理器控制台

上传文件下载管理器项目技术

JDBC + IO + Socket

实现功能

客户端注册：通过输入用户名，密码，确认密码并且校验完成以后将用户信息储存在数据库中。

客户端登录：通过输入用户名和密码到数据库中校验，校验完成进入文件上传下载管理器。

上传文件：通过输入上传文件的路径上传到数据库，支持多个文件上传。

查看文件：通过登录的用户名查找上传的文件。

下载文件：通过输入文件的编号和下载的路径，从数据库进行下载。

删除文件：通过输入文件的编号进行单个文件的删除。

（PS：这次花了一天才写完，不过收获也很多，不足之处，多多交流）

完整代码

undefined

User.java

包com.xk; import java.io.Serializable; @SuppressWarnings（“serial”） public class User implements Serializable { private String username; 私人字符串密码; public String getUsername（）{ return username; } public void setUsername（String username）{ this.username = username; } public String getPassword（）{ return password; } public void setPassword（String password）{ this.password = password; } }

未定义

FileEntity.java

包com.xk; import java.io.Serializable; @SuppressWarnings（“serial”） public class FileEntity implements Serializable { private String username; private String fileName; 私有int id private byte [] fileContent; public FileEntity（int id，String fileName）{ this.id = id; this.fileName = fileName; } public FileEntity（）{ } public int getId（）{ return id; } public void setId（int id）{ this.id = id; } public String getUsername（）{ return username; } public void setUsername（String username）{ this.username = username; } public String getFileName（）{ return fileName; } public void setFileName（String fileName）{ this.fileName = fileName; } public byte [] getFileContent（）{ return fileContent; } public void setFileContent（byte [] fileContent）{ this.fileContent = fileContent; } @Override public String toString（）{ return id +“\ t”+ fileName; } }

未定义

CommandRelay.java

包com.xk; import java.io.Serializable; import java.util.ArrayList; @SuppressWarnings（“serial”） public class CommandRelay实现Serializable { private String command; 私有布尔标志 private Object userObject = null; private Object fileObject = null; private byte [] bytes = null; private ArrayList fileList = null; public String getCommand（）{ return command; } public void setCommand（String command）{ this.command = command; } public Object getUserObject（）{ return userObject; } public void setUserObject（Object userObject）{ this.userObject = userObject; } public Object getFileObject（）{ return fileObject; } public void setFileObject（Object fileObject）{ this.fileObject = fileObject; } public boolean isFlag（）{ return flag; } public void setFlag（boolean flag）{ this.flag = flag; } public ArrayList getFileList（）{ return fileList; } public void setFileList（ArrayList fileList）{ this.fileList = fileList; } public byte [] getBytes（）{ return bytes; } public void setBytes（byte [] bytes）{ this.bytes = bytes; } }

未定义

DBUtil.java

包com.xk; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; public class DBUtil { private static final String DRIVER =“com.mysql.jdbc.Driver”; private static final String URL =“jdbc：mysql：// localhost：3306 / FileUpload”; private static final String NAME =“root”; private static final String PASSWORD =“root”; / * *数据库连接 * / public连接getConnection（）{ try { Class.forName（DRIVER）; Connection conn = DriverManager.getConnection（URL，NAME，PASSWORD）; 返回conn } catch（ClassNotFoundException e）{ e.printStackTrace（）; 返回null; } catch（SQLException e）{ e.printStackTrace（）; 返回null; } } / * *数据库关闭 * / public void close（Connection conn，PreparedStatement ps，ResultSet rs）{ try { if（rs！= null）{ rs.close（）; } if（ps！= null）{ ps.close（）; } if（conn！= null）{ conn.close（）; } } catch（SQLException e）{ e.printStackTrace（）; } } }

未定义

DBTools.java

包com.xk; import java.io.ByteArrayOutputStream; import java.io.InputStream; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.util.ArrayList; public class DBTools { DBUtil dbu = new DBUtil（）; 连接con = dbu.getConnection（）; / * *用户登录 * / public boolean login（User user）throws Exception { String sql =“select * from users where username =？and password =？”; PreparedStatement ps = con.prepareStatement（sql）; ps.setString（1，user.getUsername（））; ps.setString（2，user.getPassword（））; ResultSet rs = ps.executeQuery（）; if（rs.next（））{ return true; } else { return false; } } / * *用户注册 * / public boolean register（User user）{ String sql =“insert into users（username，password）value（？，？）”; 尝试{ PreparedStatement ps = con.prepareStatement（sql）; ps.setString（1，user.getUsername（））; ps.setString（2，user.getPassword（））; ps.executeUpdate（）; } catch（SQLException e）{ e.printStackTrace（）; 返回假 } return true; } / * *上传文件 * / public boolean uploadFile（FileEntity fe）{ String sql =“insert into file（username，filename，filecontent）VALUES（？，？，？）”; 尝试{ PreparedStatement ps = con.prepareStatement（sql）; ps.setString（1，fe.getUsername（））; ps.setString（2，fe.getFileName（））; ps.setBytes（3，fe.getFileContent（））; ps.executeUpdate（）; } catch（SQLException e）{ e.printStackTrace（）; 返回假 } return true; } / * *下载文件 * / public byte [] downloadFile（FileEntity fe）throws Exception { String sql =“从文件中选择filecontent id =？”; PreparedStatement ps = con.prepareStatement（sql）; ps.setInt（1，fe.getId（））; ResultSet rs = ps.executeQuery（）; InputStream is = null; if（rs.next（））{ is = rs.getBinaryStream（1）; ByteArrayOutputStream（）; byte [] buffer = new byte [is.available（）]; int len while（（len = is.read（buffer））！= -1）{ baos.write（buffer，0，len）; } return buffer; } return null; } / * *查看文件 * / public ArrayList viewFile（FileEntity fe）throws Exception { ArrayList fileList = new ArrayList （）; String sql =“select id，filename from file where username =？”; PreparedStatement ps = con.prepareStatement（sql）; ps.setString（1，fe.getUsername（））; ResultSet rs = ps.executeQuery（）; while（rs.next（））{ fileList.add（new FileEntity（rs.getInt（1），rs.getString（2）））; } return fileList; } / * *删除文件 * / public boolean deleteFile（FileEntity fe）throws Exception { String sql =“从文件中删除id =？”; PreparedStatement ps = con.prepareStatement（sql）; ps.setInt（1，fe.getId（））; ps.execute（）; if（ps.getUpdateCount（）> 0）{ return true; } return false; } }

未定义

Server.java

包com.xk; import java.net.ServerSocket; import java.net.Socket; public class Server { public static void main（String [] args）throws Exception { @SuppressWarnings（“resource”） ServerSocket ss = new ServerSocket（8722）; Socket socket = null; 的System.out.println（ “服务器已经启动！”）; while（true）{ socket = ss.accept（）; ServerThread st = new ServerThread（socket）; st.start（）; } } }

未定义

ServerThread.java

包com.xk; import java.io.IOException; import java.io.ObjectInputStream; import java.io.ObjectOutputStream; import java.net.Socket; import java.util.ArrayList; public class ServerThread extends Thread { Socket socket = null; public ServerThread（Socket socket）{ this.socket = socket; } public void run（）{ try { ObjectInputStream ois = new ObjectInputStream（socket.getInputStream（））; ObjectOutputStream oos = new ObjectOutputStream（socket.getOutputStream（））; CommandRelay cr =（CommandRelay）ois.readObject（）; 尝试{ cr = inquire（cr）; oos.writeObject（CR）; } catch（Exception e）{ e.printStackTrace（）; } } catch（ClassNotFoundException e）{ e.printStackTrace（）; } catch（IOException e）{ e.printStackTrace（）; } }

运行效果