public class fileClient {
     public static void main(String[] args) throws IOException {
       FileInputStream fis = new FileInputStream("D:\\1.jpg");//創(chuàng)建一個本地的輸入流，用于指定上傳數(shù)據(jù)的數(shù)據(jù)源
       Socket socket = new Socket("127.0.0.1",8888);//創(chuàng)建一個客戶端對象，host是服務(wù)器名稱或Ip地址
       OutputStream os = socket.getOutputStream();//使用socket中的方法，獲取網(wǎng)絡(luò)字節(jié)輸出流對象
   
       byte[] bytes = new byte[1024];//把本地硬盤的數(shù)據(jù)通過網(wǎng)絡(luò)字節(jié)輸出流傳遞給客戶端
       int len = 0;
       while ((len = fis.read(bytes))!=-1){
         os.write(bytes,0,len);
       }
   
       socket.shutdownOutput();//為了解決阻塞問題
   
       InputStream is = socket.getInputStream();//使用socket中的方法，獲取網(wǎng)絡(luò)字節(jié)輸入流，用于讀取客戶端的數(shù)據(jù)
       while((len = is.read(bytes))!=-1){//讀取客戶端的數(shù)據(jù)進行輸出
         System.out.println(new String(bytes,0,len));
       }
   
       socket.close();//關(guān)閉流
       fis.close();
     }
   }

public class fileServer {
  public static void main(String[] args) throws IOException {
    ServerSocket serverSocket = new ServerSocket(8888);//創(chuàng)建服務(wù)器端對象



    //while(true){//讓服務(wù)器一直處于運行狀態(tài)，保證客戶端可以隨時向服務(wù)器上傳文件
      new Thread(new Runnable() {//為了提高文件上傳效率，來一個客戶端開一個線程
        @Override
        public void run() {
          try{
            Socket socket = serverSocket.accept();//使用accept方法接收客戶端的數(shù)據(jù)
            InputStream is = socket.getInputStream();//創(chuàng)建網(wǎng)絡(luò)字節(jié)輸入流

            File file = new File("D:\\upload");//判斷服務(wù)器硬盤中的文件夾是否存在，此文件夾用于存儲客戶端上傳的內(nèi)容
            if (!file.exists()){//判斷服務(wù)器端的文件夾是否存在
              file.mkdirs();
            }

            String fileName = "\\picture"+System.currentTimeMillis()+new Random().nextInt(99999)+".jpg";//自己隨機生成文件名，防止重復(fù)

            FileOutputStream fos = new FileOutputStream(file+fileName);//

            int len;
            byte[] bytes = new byte[1024];
            while((len = is.read(bytes))!= -1 ){//將客戶端的數(shù)據(jù)寫入服務(wù)器硬盤中
              fos.write(bytes,0,len);
            }

            OutputStream os = socket.getOutputStream();//向客戶端回應(yīng)
            os.write("上傳成功".getBytes());

            socket.close();
            fos.close();
          }catch (IOException e){//在這里只能使用try catch解決異常，因為run方法不支持拋出異常
            System.out.println(e);
          }

        }
      }).start();
    //}

  }
}