欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

Socket+JDBC+IO实现Java文件上传下载器DEMO详解

程序员文章站 2023-12-21 13:58:22
该demo实现的功能有: 1.用户注册: 注册时输入两次密码,若两次输入不一致,则注册失败,需要重新输入。若用户名被注册过,则提示用户重新输入用户名; 2.用户登录:...

该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详解,希望对大家有所帮助

上一篇:

下一篇: