Socket+JDBC+IO实现Java文件上传下载器DEMO详解
该demo实现的功能有：
1.用户注册：
注册时输入两次密码，若两次输入不一致，则注册失败，需要重新输入。若用户名被注册过，则提示用户重新输入用户名；
2.用户登录：
需要验证数据库中是否有对应的用户名和密码，若密码输错三次，则终止用户的登录操作；
3.文件上传：
从本地上传文件到文件数据库中
4.文件下载：
从数据库中下载文件到本地
5.文件更新：
根据id可更新数据库中的文件名
6.文件删除：
根据id删除数据库中某一个文件
7.看数据库所有文件;
8.查看文件（根据用户名）;
9.查看文件（根据文件id）;
代码分为如下四个部分：Entity,Service,Socket,Util
实体包Entity中主要存放用户实体和文件实体
User类：
packageEntity;
importjava.io.Serializable;
/**
*用户类
*@authorAdministrator
*
*/
publicclassUserimplementsSerializable{
//属性
privateintid;
privateStringusername;
privateStringpassword;
//方法
//构造方法
publicUser(){
super();
}
publicUser(Stringusername,Stringpassword){
super();
this.username=username;
this.password=password;
}
//Getter,Setter方法
publicintgetId(){
returnid;
}
publicvoidsetId(intid){
this.id=id;
}
publicStringgetUsername(){
returnusername;
}
publicvoidsetUsername(Stringusername){
this.username=username;
}
publicStringgetPassword(){
returnpassword;
}
publicvoidsetPassword(Stringpassword){
this.password=password;
}
}
文件类：
packageEntity;
importjava.io.Serializable;
importjava.util.Arrays;
/**
*文件实体类
*@authorAdministrator
*
*/
publicclassFileEntityimplementsSerializable{
//属性
privateintfid;
privateStringusername;//用户名，方便查看某个用户上传的文件
publicStringgetUsername(){
returnusername;
}
publicvoidsetUsername(Stringusername){
this.username=username;
}
privateStringfname;
privatebyte[]fcontent;
//方法
//构造方法
publicFileEntity(){
super();
}
publicFileEntity(Stringusername,Stringfname,byte[]fcontent){
super();
this.username=username;
this.fname=fname;
this.fcontent=fcontent;
}
//Getter,Setter方法
publicintgetFid(){
returnfid;
}
publicvoidsetFid(intfid){
this.fid=fid;
}
publicStringgetFname(){
returnfname;
}
publicvoidsetFname(Stringfname){
this.fname=fname;
}
publicbyte[]getFcontent(){
returnfcontent;
}
publicvoidsetFcontent(byte[]fcontent){
this.fcontent=fcontent;
}
@Override
publicStringtoString(){
return"FileEntity[fid="+fid+",username="+username+",fname="
+fname+"]";
}
}
Service包:包括用户服务类和文件服务类
UserSevice类包括了与用户相关的注册和登录功能相关的方法
packageService;
importjava.sql.Connection;
importjava.sql.PreparedStatement;
importjava.sql.ResultSet;
importjava.sql.SQLException;
importUtil.DBUtil;
importEntity.User;
publicclassUserService{
privateConnectionconn=null;
privatePreparedStatementpstmt=null;
privateResultSetrs=null;
/**
*登陆
*/
publicbooleanlogin(Useruser){
Stringsql="select*fromtb_userwhereusername=?andpassword=?";
try{
conn=DBUtil.getConnection();
pstmt=conn.prepareStatement(sql);
pstmt.setString(1,user.getUsername());
pstmt.setString(2,user.getPassword());
rs=pstmt.executeQuery();
if(rs.next()){
returntrue;
}
}catch(SQLExceptione){
e.printStackTrace();
}finally{
DBUtil.CloseAll(rs,pstmt,conn);
}
returnfalse;
}
/**
*注册
*/
publicvoidregister(Useruser){
Stringsql="insertintotb_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(SQLExceptione){
e.printStackTrace();
}finally{
DBUtil.CloseAll(rs,pstmt,conn);
}
}
/**
*查找tb_user,查看用户是否已经注册过
*/
publicbooleanqueryByUsername(Stringusername){
conn=DBUtil.getConnection();
Stringsql="select*fromtb_userwhereusername=?";
try{
pstmt=conn.prepareStatement(sql);
pstmt.setString(1,username);
rs=pstmt.executeQuery();
if(rs.next()){
//说明已经被注册过,要求重新填写用户名
returntrue;
}
}catch(SQLExceptione){
e.printStackTrace();
}
returnfalse;
}
}
文件服务类：
packageService;
importjava.io.ByteArrayInputStream;
importjava.io.File;
importjava.io.FileInputStream;
importjava.io.FileOutputStream;
importjava.io.IOException;
importjava.sql.Connection;
importjava.sql.PreparedStatement;
importjava.sql.ResultSet;
importjava.sql.SQLException;
importjava.util.ArrayList;
importjava.util.List;
importjava.util.Scanner;
importEntity.FileEntity;
importUtil.DBUtil;
publicclassFileService{
privateConnectionconn=null;
privatePreparedStatementpstmt=null;
privateResultSetrs=null;
/**
*保存文件到数据库，类似用户的注册功能
*@paramfileEntity
*/
以上所述是小编给大家介绍的Socket+JDBC+IO实现Java文件上传下载器DEMO详解，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对毛票票网站的支持！