练习：利用网络编程和前面所学，建立客户端向服务器端上传文件的程序。
思路：客户端和服务器端要建立连接，所以用TCP协议。
客户端方面：1.提示输入要上传的文件路径, 验证路径是否存在以及是否是文件夹
2.发送文件名到服务端
4.发送文件大小到服务端
7.接收结果, 如果存在给予提示, 程序直接退出
8.如果不存在, 定义FileInputStream读取文件, 写出到网络
服务端方面：3.读取文件名
5.读取文件大小
6 .判断文件是否存在, 将结果发回客户端
9.定义FileOutputStream, 从网络读取数据, 存储到本地
//代码：
//客户端程序：
package cn.itcast.exercise;
import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.Socket;
import java.util.Scanner;
public class Exercise3_UploadClient {
public static void main(String[] args) throws Exception {
// 1.提示输入要上传的文件路径, 验证路径是否存在以及是否是文件夹
File file = getFile();
// 2.发送文件名到服务端
Socket socket = new Socket("192.168.1.100", 12345);
BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
PrintStream ps = new PrintStream(socket.getOutputStream());
ps.println(file.getName());
// 2.1.发送文件大小到服务端
ps.println(file.length());
// 5.接收结果, 如果存在给予提示, 程序直接退出
String result = br.readLine();
if ("存在".equals(result)) {
System.out.println("文件已存在, 请不要重复上传");
socket.close();
return;
}
long length = Long.parseLong(result);// 获取服务端文件的大小
// 6.如果不存在, 定义FileInputStream读取文件, 写出到网络
FileInputStream fis = new FileInputStream(file);
fis.skip(length);// 服务端完成了多少就跳过多少
byte[] buffer = new byte[1024];
int len;
long finish = 0;
while ((len = fis.read(buffer)) != -1) {
ps.write(buffer, 0, len);
finish += len;
System.out.println("已完成: " + finish * 100 / file.length() + "%");
}
fis.close();
ps.close();
socket.close();
System.out.println("上传完毕");
}
private static File getFile() {
System.out.println("请输入要上传的文件路径:");
Scanner scanner = new Scanner(System.in);
while (true) {
File file = new File(scanner.nextLine());
if (!file.exists())
System.out.println("您输入的路径不存在, 请重新输入:");
else if (file.isDirectory())
System.out.println("暂不支持文件夹上传, 请输入一个文件路径:");
else
return file;
}
}
}
//服务器端程序：
package cn.itcast.exercise;
import java.io.BufferedReader;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.ServerSocket;
import java.net.Socket;
public class Exercise3_UploadServer {
public static void main(String[] args) throws Exception {
System.out.println("服务器已启动, 绑定12345端口.");
ServerSocket serverSocket = new ServerSocket(12345);
while (true) {
final Socket socket = serverSocket.accept();
new Thread(){
public void run() {
try {
// 3.读取文件名
InputStream is = socket.getInputStream();// 字节流可以读写各种类型的数据
BufferedReader br = new BufferedReader(new InputStreamReader(is));// 字符流只能读字符
PrintStream ps = new PrintStream(socket.getOutputStream());
String filename = br.readLine();
// 3.1.读取文件大小
long length = Long.parseLong(br.readLine());
// 4.判断文件是否存在, 将结果发回客户端
File dir = new File("upload");
dir.mkdir();
File file = new File(dir, filename);
if (file.exists() && file.length() == length) {// 文件存在, 大小一致代表已上传过了
ps.println("存在");
socket.close();
return;
} else {
ps.println(file.length());// 不存在是0, 存在则是传了一半的大小
}
String ip = socket.getInetAddress().getHostAddress();
System.out.println(ip + (file.exists() ? "断点续传:" : "开始上传: ") + file.getName());
long start = System.currentTimeMillis();
// 7.定义FileOutputStream, 从网络读取数据, 存储到本地
FileOutputStream fos = new FileOutputStream(file, true);
byte[] buffer = new byte[1024];
int len;
while ((len = is.read(buffer)) != -1)// 文件可能是任意类型, 所以使用字节流读取
fos.write(buffer, 0, len);
fos.close();
socket.close();
long end = System.currentTimeMillis();
System.out.println(ip + "上传完毕: " + file.getName() + ", 耗时: " + (end - start) + "毫秒.");
} catch (IOException e) {
e.printStackTrace();
}
}
}.start();
}
}
}