黑马程序员技术交流社区

标题: 【黑马程序员】网络编程(练习)客户端向服务器上传文件 [打印本页]
作者: huburt    时间: 2016-5-23 14:26
标题: 【黑马程序员】网络编程(练习)客户端向服务器上传文件
服务端：
  1. import java.io.BufferedReader;
  2. import java.io.File;
  3. import java.io.FileOutputStream;
  4. import java.io.IOException;
  5. import java.io.InputStream;
  6. import java.io.InputStreamReader;
  7. import java.io.PrintStream;
  8. import java.net.ServerSocket;
  9. import java.net.Socket;

  11. public class Server {

  13.         public static void main(String[] args) throws IOException {
  14.                 //创建服务器
  15.                 ServerSocket server = new ServerSocket(12345);
  16.                 //创建服务器的数据存储空间
  17.                 File dir = new File("data");
  18.                 dir.mkdir();
  19.                 //多线程接收连接
  20.                 while(true){
  21.                         final Socket socket = server.accept();
  22.                         System.out.println("连接");       
  23.                         new Thread(){
  24.                                 public void run() {
  25.                                         try {
  26.                                                 InputStream is = socket.getInputStream();
  27.                                                 BufferedReader br = new BufferedReader(new InputStreamReader(is));
  28.                                                 PrintStream ps = new PrintStream(socket.getOutputStream());
  29.                                                 //接收文件名
  30.                                                 File file = new File(dir,br.readLine());
  31.                                                 //判断并反馈客户端
  32.                                                 if(file.exists()){
  33.                                                         ps.println("1");
  34.                                                 }else{//文件不存在，则储存
  35.                                                         ps.println("0");
  36.                                                         FileOutputStream fos = new FileOutputStream(file);
  37.                                                         byte[] b = new byte[1024*4];
  38.                                                         int len;
  39.                                                         while((len=is.read(b))!=-1){
  40.                                                                 fos.write(b, 0, len);
  41.                                                         }
  42.                                                         fos.close();
  43.                                                 }
  44.                                                 //关闭socket,会自动关闭IO流
  45.                                                 socket.close();
  46.                                         } catch (IOException e) {
  47.                                                 e.printStackTrace();
  48.                                         }
  49.                                 };
  50.                         }.start();
  51.                 }
  52.         }
  53. }
复制代码


顾客端：
  1. import java.io.BufferedReader;
  2. import java.io.File;
  3. import java.io.FileInputStream;
  4. import java.io.IOException;
  5. import java.io.InputStreamReader;
  6. import java.io.PrintStream;
  7. import java.net.Socket;
  8. import java.util.Scanner;

  10. public class Client {

  12.         public static void main(String[] args) throws IOException{
  13.                 Scanner sc = new Scanner(System.in);
  14.                 File file;
  15.                 //键盘接一个路径，判断是否是文件
  16.                 System.out.println("请输入要上传的文件路径：");
  17.                 while(true){
  18.                         file = new File(sc.nextLine());
  19.                         if(file.exists()){
  20.                                 if(file.isFile()){
  21.                                         break;
  22.                                 }else{
  23.                                         System.out.println("这是一个文件夹路径，请重新输入一个文件路径：");
  24.                                 }
  25.                         }else{
  26.                                 System.out.println("输入的文件不存在！请重新输入：");
  27.                         }
  28.                 }
  29.                
  30.                 //发起连接
  31.                 Socket socket = new Socket("127.0.0.1", 12345);
  32.                 //打开输入输出流
  33.                 BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
  34.                 PrintStream ps = new PrintStream(socket.getOutputStream());
  35.                 //发送服务器
  36.                 ps.println(file.getName());
  37.                 //接收返回值
  38.                 String reponse = br.readLine();
  39.                 if(reponse.equals("1")){
  40.                         System.out.println("文件已存在于服务器！");
  41.                 }else{//文件不存在，则上传
  42.                         FileInputStream fis = new FileInputStream(file);
  43.                         byte[] b = new byte[1024*4];
  44.                         int len;
  45.                         while((len=fis.read(b))!=-1){
  46.                                 ps.write(b, 0, len);
  47.                         }
  48.                         fis.close();
  49.                 }
  50.                 //关闭连接
  51.                 socket.close();
  52.         }
  53. }
复制代码




欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2