该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详解，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对脚本之家网站的支持！
