本文实例为大家分享了java实现客户端向服务器发送文件的具体代码，供大家参考，具体内容如下
服务器源代码：
|
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
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
|
import java.io.BufferedReader; import java.io.File; import java.io.FileNotFoundException; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.net.ServerSocket; import java.net.Socket; /** * * 文件名：ServerReceive.java * 实现功能：作为服务器接收客户端发送的文件 * * 具体实现过程： * 1、建立SocketServer，等待客户端的连接 * 2、当有客户端连接的时候，按照双方的约定，这时要读取一行数据 * 其中保存客户端要发送的文件名和文件大小信息 * 3、根据文件名在本地创建文件，并建立好流通信 * 4、循环接收数据包，将数据包写入文件 * 5、当接收数据的长度等于提前文件发过来的文件长度，即表示文件接收完毕，关闭文件 * 6、文件接收工作结束 * * * 【注：此代码仅为演示客户端与服务器传送文件使用， * 每一个数据包之前没有文件协议命令 * 具体的协议传输和文件传出的使用阶段可根据自己程序自行放置】 * * * 作者：小菜鸟 * 创建时间：2014-08-19 * * */ public class ServerReceive { public static void main(String[] args) { /**与服务器建立连接的通信句柄*/ ServerSocket ss = null; Socket s = null; /**定义用于在接收后在本地创建的文件对象和文件输出流对象*/ File file = null; FileOutputStream fos = null; /**定义输入流，使用socket的inputStream对数据包进行输入*/ InputStream is = null; /**定义byte数组来作为数据包的存储数据包*/ byte[] buffer = new byte[4096 * 5]; /**用来接收文件发送请求的字符串*/ String comm = null; /**建立socekt通信，等待服务器进行连接*/ try { ss = new ServerSocket(4004); s = ss.accept(); } catch (IOException e) { e.printStackTrace(); } /**读取一行客户端发送过来的约定信息*/ try { InputStreamReader isr = new InputStreamReader(s.getInputStream()); BufferedReader br = new BufferedReader(isr); comm = br.readLine(); } catch (IOException e) { System.out.println("服务器与客户端断开连接"); } /**开始解析客户端发送过来的请求命令*/ int index = comm.indexOf("/#"); /**判断协议是否为发送文件的协议*/ String xieyi = comm.substring(0, index); if(!xieyi.equals("111")){ System.out.println("服务器收到的协议码不正确"); return; } /**解析出文件的名字和大小*/ comm = comm.substring(index + 2); index = comm.indexOf("/#"); String filename = comm.substring(0, index).trim(); String filesize = comm.substring(index + 2).trim(); /**创建空文件，用来进行接收文件*/ file = new File(filename); if(!file.exists()){ try { file.createNewFile(); } catch (IOException e) { System.out.println("服务器端创建文件失败"); } }else{ /**在此也可以询问是否覆盖*/ System.out.println("本路径已存在相同文件，进行覆盖"); } /**【以上就是客户端代码中写到的服务器的准备部分】*/ /** * 服务器接收文件的关键代码*/ try { /**将文件包装到文件输出流对象中*/ fos = new FileOutputStream(file); long file_size = Long.parseLong(filesize); is = s.getInputStream(); /**size为每次接收数据包的长度*/ int size = 0; /**count用来记录已接收到文件的长度*/ long count = 0; /**使用while循环接收数据包*/ while(count < file_size){ /**从输入流中读取一个数据包*/ size = is.read(buffer); /**将刚刚读取的数据包写到本地文件中去*/ fos.write(buffer, 0, size); fos.flush(); /**将已接收到文件的长度+size*/ count += size; System.out.println("服务器端接收到数据包，大小为" + size); } } catch (FileNotFoundException e) { System.out.println("服务器写文件失败"); } catch (IOException e) { System.out.println("服务器：客户端断开连接"); }finally{ /** * 将打开的文件关闭 * 如有需要，也可以在此关闭socket连接 * */ try { if(fos != null) fos.close(); } catch (IOException e) { e.printStackTrace(); }//catch (IOException e) }//finally }//public static void main(String[] args) }//public class ServerReceive |
客户端源代码：
|
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
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
|
import java.io.File; import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.IOException; import java.io.OutputStream; import java.io.PrintStream; import java.net.Socket; /** * * 文件名：ClientSend.java * 实现功能：作为客户端向服务器发送一个文件 * * 具体实现过程： * 1、建立与服务器端的连接，IP：127.0.0.1， port：4004 * 2、将文件的名字和大小通过自定义的文件传输协议，发送到服务器 * 3、循环读取本地文件，将文件打包发送到数据输出流中 * 4、关闭文件，结束传输 * * 【注：此代码仅为演示客户端与服务器传送文件使用， * 每一个数据包之前没有文件协议命令 * 具体的协议传输和文件传出的使用阶段可根据自己程序自行放置】 * * * 作者：小菜鸟 * 创建时间：2014-08-19 * * */ public class ClientSend { public static void main(String[] args) { /**与服务器建立连接的通信句柄*/ Socket s = null; /**定义文件对象，即为要发送的文件 * 如果使用绝对路径，不要忘记使用'/'和'\'的区别 * 具体区别，请读者自行查询 * */ File sendfile = new File("API.CHM"); /**定义文件输入流，用来打开、读取即将要发送的文件*/ FileInputStream fis = null; /**定义byte数组来作为数据包的存储数据包*/ byte[] buffer = new byte[4096 * 5]; /**定义输出流，使用socket的outputStream对数据包进行输出*/ OutputStream os = null; /**检查要发送的文件是否存在*/ if(!sendfile.exists()){ System.out.println("客户端：要发送的文件不存在"); return; } /**与服务器建立连接*/ try { s = new Socket("127.0.0.1", 4004); }catch (IOException e) { System.out.println("未连接到服务器"); } /**用文件对象初始化fis对象 * 以便于可以提取出文件的大小 * */ try { fis = new FileInputStream(sendfile); } catch (FileNotFoundException e1) { e1.printStackTrace(); } /**首先先向服务器发送关于文件的信息，以便于服务器进行接收的相关准备工作 * 具体的准备工作，请查看服务器代码。 * * 发送的内容包括：发送文件协议码（此处为111）/#文件名（带后缀名）/#文件大小 * */ try { PrintStream ps = new PrintStream(s.getOutputStream()); ps.println("111/#" + sendfile.getName() + "/#" + fis.available()); ps.flush(); } catch (IOException e) { System.out.println("服务器连接中断"); } /** * 此处睡眠2s，等待服务器把相关的工作准备好 * 也是为了保证网络的延迟 * 读者可自行选择添加此代码 * */ try { Thread.sleep(2000); } catch (InterruptedException e1) { e1.printStackTrace(); } /**之前的准备工作结束之后 * 下面就是文件传输的关键代码 * */ try { /**获取socket的OutputStream，以便向其中写入数据包*/ os = s.getOutputStream(); /** size 用来记录每次读取文件的大小*/ int size = 0; /**使用while循环读取文件，直到文件读取结束*/ while((size = fis.read(buffer)) != -1){ System.out.println("客户端发送数据包，大小为" + size); /**向输出流中写入刚刚读到的数据包*/ os.write(buffer, 0, size); /**刷新一下*/ os.flush(); } } catch (FileNotFoundException e) { System.out.println("客户端读取文件出错"); } catch (IOException e) { System.out.println("客户端输出文件出错"); }finally{ /** * 将打开的文件关闭 * 如有需要，也可以在此关闭socket连接 * */ try { if(fis != null) fis.close(); } catch (IOException e) { System.out.println("客户端文件关闭出错"); }//catch (IOException e) }//finally }//public static void main(String[] args) }//public class ClientSend |
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持服务器之家。
原文链接：http://blog.csdn.net/junwei_yu/article/details/38687667
