使用Socket+JDBC實(shí)現(xiàn)一個(gè)Java文件上傳下載功能

發(fā)布時(shí)間：2020-11-20 16:28:23 來(lái)源：億速云閱讀：212 作者：Leah 欄目：編程語(yǔ)言

這期內(nèi)容當(dāng)中小編將會(huì)給大家?guī)?lái)有關(guān)使用Socket+JDBC實(shí)現(xiàn)一個(gè)Java文件上傳下載功能，文章內(nèi)容豐富且以專(zhuān)業(yè)的角度為大家分析和敘述，閱讀完這篇文章希望大家可以有所收獲。

該demo實(shí)現(xiàn)的功能有：

1.用戶注冊(cè)：

注冊(cè)時(shí)輸入兩次密碼，若兩次輸入不一致，則注冊(cè)失敗，需要重新輸入。若用戶名被注冊(cè)過(guò)，則提示用戶重新輸入用戶名；

2.用戶登錄：

需要驗(yàn)證數(shù)據(jù)庫(kù)中是否有對(duì)應(yīng)的用戶名和密碼，若密碼輸錯(cuò)三次，則終止用戶的登錄操作；

3.文件上傳：

從本地上傳文件到文件數(shù)據(jù)庫(kù)中

4.文件下載：

從數(shù)據(jù)庫(kù)中下載文件到本地

5.文件更新：

根據(jù)id可更新數(shù)據(jù)庫(kù)中的文件名

6.文件刪除：

根據(jù)id刪除數(shù)據(jù)庫(kù)中某一個(gè)文件

7.看數(shù)據(jù)庫(kù)所有文件;

8.查看文件（根據(jù)用戶名）;

9.查看文件（根據(jù)文件id）;

代碼分為如下四個(gè)部分：Entity,Service,Socket,Util

實(shí)體包Entity中主要存放用戶實(shí)體和文件實(shí)體

User類(lèi)：

package Entity;
import java.io.Serializable;
/**
 * 用戶類(lèi)
 * @author Administrator
 *
 */
public class User implements Serializable{
 //屬性
 private int id;
 private String username;
 private String password;
 //方法
 //構(gòu)造方法
 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;
 }
}

文件類(lèi)：

package Entity;
import java.io.Serializable;
import java.util.Arrays;
/**
 * 文件實(shí)體類(lèi)
 * @author Administrator
 *
 */
public class FileEntity implements Serializable {
 //屬性
 private int fid;
 private String username;// 用戶名，方便查看某個(gè)用戶上傳的文件
 public String getUsername() {
 return username;
 }
 public void setUsername(String username) {
 this.username = username;
 }
 private String fname;
 private byte[] fcontent;
 //方法
 //構(gòu)造方法
 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包:包括用戶服務(wù)類(lèi)和文件服務(wù)類(lèi)

UserSevice類(lèi)包括了與用戶相關(guān)的注冊(cè)和登錄功能相關(guān)的方法

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=&#63; and password=&#63;";
 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;
 }
 /**
 * 注冊(cè)
 */
 public void register(User user){
 String sql="insert into tb_user(username,password)value(&#63;,&#63;)";
  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,查看用戶是否已經(jīng)注冊(cè)過(guò)
 */
 public boolean queryByUsername(String username){
 conn=DBUtil.getConnection();
 String sql="select * from tb_user where username=&#63;";
 try {
  pstmt=conn.prepareStatement(sql);
  pstmt.setString(1, username);
  rs=pstmt.executeQuery();
  if(rs.next()){
  //說(shuō)明已經(jīng)被注冊(cè)過(guò),要求重新填寫(xiě)用戶名
  return true;
  }
 } catch (SQLException e) {
  e.printStackTrace();
 }
 return false;
 }
}

文件服務(wù)類(lèi)：

 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;
 /**
 * 保存文件到數(shù)據(jù)庫(kù)，類(lèi)似用戶的注冊(cè)功能
 * @param fileEntity
 */

上述就是小編為大家分享的使用Socket+JDBC實(shí)現(xiàn)一個(gè)Java文件上傳下載功能了，如果剛好有類(lèi)似的疑惑，不妨參照上述分析進(jìn)行理解。如果想知道更多相關(guān)知識(shí)，歡迎關(guān)注億速云行業(yè)資訊頻道。

向AI問(wèn)一下細(xì)節(jié)

使用Socket+JDBC實(shí)現(xiàn)一個(gè)Java文件上傳下載功能

猜你喜歡

最新資訊

相關(guān)推薦

相關(guān)標(biāo)簽