這期內容當中小編將會給大家帶來有關使用Socket+JDBC實現一個Java文件上傳下載功能，文章內容豐富且以專業的角度為大家分析和敘述，閱讀完這篇文章希望大家可以有所收獲。
該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實現一個Java文件上傳下載功能了，如果剛好有類似的疑惑，不妨參照上述分析進行理解。如果想知道更多相關知識，歡迎關注億速云行業資訊頻道。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
