该demo实现的功能有：

1.用户注册：

注册时输入两次密码，若两次输入不一致，则注册失败，需要重新输入。若用户名被注册过，则提示用户重新输入用户名；

2.用户登录：

需要验证数据库中是否有对应的用户名和密码，若密码输错三次，则终止用户的登录操作；

3.文件上传：

从本地上传文件到文件数据库中

4.文件下载：

从数据库中下载文件到本地

5.文件更新：

根据id可更新数据库中的文件名

6.文件删除：

根据id删除数据库中某一个文件

7.看数据库所有文件;

8.查看文件（根据用户名）;

9.查看文件（根据文件id）;

代码分为如下四个部分：Entity,Service,Socket,Util

实体包Entity中主要存放用户实体和文件实体

User类：

package Entity;import java.io.Serializable;/** * 用户类 * @author Administrator * */public class User implements Serializable{ //属性 private int id; private String username; private String password; //方法 //构造方法 public User(){ super(); } public User(String username, String password) { super(); this.username = username; this.password = password; } //Getter,Setter方法 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 getPassword() { return password; } public void setPassword(String password) { this.password = password; }}

文件类：

package Entity;import java.io.Serializable;import java.util.Arrays;/** * 文件实体类 * @author Administrator * */public class FileEntity implements Serializable { //属性 private int fid; private String username;// 用户名，方便查看某个用户上传的文件 public String getUsername() { return username; } public void setUsername(String username) { this.username = username; } private String fname; private byte[] fcontent; //方法 //构造方法 public FileEntity(){ super(); } public FileEntity(String username,String fname, byte[] fcontent) { super(); this.username=username; this.fname = fname; this.fcontent = fcontent; } //Getter,Setter方法 public int getFid() { return fid; } public void setFid(int fid) { this.fid = fid; } public String getFname() { return fname; } public void setFname(String fname) { this.fname = fname; } public byte[] getFcontent() { return fcontent; } public void setFcontent(byte[] fcontent) { this.fcontent = fcontent; } @Override public String toString() { return "FileEntity [fid=" + fid + ", username=" + username + ", fname=" + fname + "]"; }}

Service包:包括用户服务类和文件服务类

UserSevice类包括了与用户相关的注册和登录功能相关的方法

package Service;import java.sql.Connection;import java.sql.PreparedStatement;import java.sql.ResultSet;import java.sql.SQLException;import Util.DBUtil;import Entity.User;public class UserService { private Connection conn=null; private PreparedStatement pstmt=null; private ResultSet rs=null; /** * 登陆 */ public boolean login(User user){ String sql="select * from tb_user where username=? and password=?"; try{ conn=DBUtil.getConnection(); pstmt=conn.prepareStatement(sql); pstmt.setString(1, user.getUsername()); pstmt.setString(2, user.getPassword()); rs=pstmt.executeQuery(); if(rs.next()){ return true; } }catch(SQLException e){ e.printStackTrace(); }finally{ DBUtil.CloseAll(rs, pstmt, conn); } return false; } /** * 注册 */ public void register(User user){ String sql="insert into tb_user(username,password)value(?,?)"; try { conn=DBUtil.getConnection(); pstmt=conn.prepareStatement(sql); pstmt.setString(1, user.getUsername()); pstmt.setString(2, user.getPassword()); pstmt.executeUpdate(); } catch (SQLException e) { e.printStackTrace(); }finally{ DBUtil.CloseAll(rs, pstmt, conn); } } /** * 查找tb_user,查看用户是否已经注册过 */ public boolean queryByUsername(String username){ conn=DBUtil.getConnection(); String sql="select * from tb_user where username=?"; try { pstmt=conn.prepareStatement(sql); pstmt.setString(1, username); rs=pstmt.executeQuery(); if(rs.next()){ //说明已经被注册过,要求重新填写用户名 return true; } } catch (SQLException e) { e.printStackTrace(); } return false; }}

文件服务类：

package Service;import java.io.ByteArrayInputStream;import java.io.File;import java.io.FileInputStream;import java.io.FileOutputStream;import java.io.IOException;import java.sql.Connection;import java.sql.PreparedStatement;import java.sql.ResultSet;import java.sql.SQLException;import java.util.ArrayList;import java.util.List;import java.util.Scanner;import Entity.FileEntity;import Util.DBUtil;public class FileService { private Connection conn=null; private PreparedStatement pstmt=null; private ResultSet rs=null; /** * 保存文件到数据库，类似用户的注册功能 * @param fileEntity */

以上所述是小编给大家介绍的Socket+JDBC+IO实现Java文件上传下载器DEMO详解，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对网站的支持！