服务器代码:
package com.xfr.test;
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 Test2_UpLoadServer {
/**
* @param args
* @throws IOException
*/
public static void main(String[] args) throws IOException {
ServerSocket server = new ServerSocket(6666); //创建服务器,绑定端口号777
System.out.println("启动服务器,端口号为6666!!!");
while(true){
final Socket socket = server.accept(); //接收客户端的请求,有可能接收多个客户端的请求,所以用多线程
new Thread(){
public void run(){
try {
InputStream is = socket.getInputStream();
//拿到客户端的流
BufferedReader br = new BufferedReader(new InputStreamReader(is));
//用Buffer缓冲区更好读取
PrintStream ps = new PrintStream(socket.getOutputStream());
//用PrintStream的好处是可以写字符也可以写字节
String fileName = br.readLine();//接收到要上传的文件的名字
File dir = new File("upload"); //创建一个文件夹来存放文件
dir.mkdir();
File file = new File(dir,fileName); //对文件名字进行封装来进行判断操作
if(file.exists()){
ps.println("存在"); //若文件在服务器中存在,给与客户端提示
socket.close();
}else{
//文件在服务器中没有,则开始接收
FileOutputStream fos = new FileOutputStream(file);
byte[] arr = new byte[8192];
int len;
while(( len = is.read(arr)) != -1){
fos.write(arr, 0, len);
}
fos.close(); //记得关流和关端口
socket.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}.start();
}
}
}
客户端代码:
package com.xfr.test;
import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Scanner;
public class Test2_UploadClient {
/**
* 向服务器上传文件,文件路径从键盘获取
* @param args
* @throws IOException
* @throws UnknownHostException
*/
public static void main(String[] args) throws UnknownHostException, IOException {
Socket socket = new Socket("169.254.33.252",6666);//创建客户端
File file = getFile();//获取文件
BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
PrintStream ps = new PrintStream(socket.getOutputStream());
ps.println(file.getName()); //将文件名字传给服务器,服务器再对其进行判断
String result = br.readLine();
if("存在".equals(result)){
System.out.println("该文件在服务器中已经存在,请不要重复上传!");
socket.close();
return;
}
else {
//文件不存在的话,开始读取该文件
FileInputStream fis = new FileInputStream(file);
byte[] arr = new byte[8192];
int len;
while((len = fis.read(arr)) != -1){
ps.write(arr, 0, len);//向服务器传
}
fis.close();
socket.close();//F:\Test\aaa.txt
}
}
public static File getFile() {
Scanner sc = new Scanner(System.in);
while(true){
String s = sc.nextLine();
File file = new File(s);
if(!file.exists()){
System.out.println("您要上传的文件不存在!重新输入文件路径:");
}
else if(file.isDirectory()){
System.out.println("您输入的是文件夹路径!重新输入文件路径:");
}
else{
return file;
}
}
}
}
###执行后输入路径,路径正确的话程序不会停下来,红方块一直在
手动点掉红方块后刷新项目
可以看到eclipse当前路径多了要拷贝的文件,可是文件字节大小为0
更多
