該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類：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
|
package Entity;import java.io.Serializable;/** * 用戶類 * @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; }} |
文件類：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
|
package Entity;import java.io.Serializable;import java.util.Arrays;/** * 文件實(shí)體類 * @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ù)類和文件服務(wù)類
UserSevice類包括了與用戶相關(guān)的注冊(cè)和登錄功能相關(guān)的方法
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
|
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; } /** * 注冊(cè) */ 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,查看用戶是否已經(jīng)注冊(cè)過(guò) */ 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()){ //說(shuō)明已經(jīng)被注冊(cè)過(guò),要求重新填寫(xiě)用戶名 return true; } } catch (SQLException e) { e.printStackTrace(); } return false; }} |
文件服務(wù)類：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
|
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ù)，類似用戶的注冊(cè)功能 * @param fileEntity */ |
以上所述是小編給大家介紹的Socket+JDBC+IO實(shí)現(xiàn)Java文件上傳下載器DEMO詳解，希望對(duì)大家有所幫助，如果大家有任何疑問(wèn)請(qǐng)給我留言，小編會(huì)及時(shí)回復(fù)大家的。在此也非常感謝大家對(duì)服務(wù)器之家網(wǎng)站的支持！
原文鏈接：http://www.imooc.com/article/17927
