Java模擬客戶端向服務器上傳文件

先來了解一下客戶端與服務器Tcp通信的基本步驟：　

 

1. 服務器端先啟動，然后啟動客戶端向服務器端發送數據。
2. 服務器端收到客戶端發送的數據，服務器端會響應應客戶端，向客戶端發送響應結果。
3. 客戶端讀取服務器發送的數據

 

文件上傳步驟：

 

1. 客戶端使用本地字節輸入流，指定上傳數據的數據源。

2.客戶端使用網絡字節輸出流，把讀取的本地文件上傳到服務器。

3.服務器使用網絡字節輸入流，讀取客戶端上傳的文件。

4.服務器使用本地字節輸出流，把讀取到的文件保存到服務器硬盤上。

5.服務器使用網絡字節輸出流，給客戶端響應一個“上傳成功”。

6.客戶端使用網絡字節輸入流，讀取服務器響應的數據。

 

 

客戶端的代碼實現

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

 

服務器端代碼實現

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



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

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

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

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

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

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

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

                }
            }).start();
        //}

    }

 

注：在開啟多線程的時候，因為run方法的父類並不支持throws解決異常，所以run也不支持，只能使用try...catch解決異常

 

解釋一下為什么在上傳數據的時候客戶端和服務器會出現阻塞問題以及解決阻塞的方法

為什么會出現阻塞？

出現阻塞的根本問題是，客戶端從本地硬盤讀取文件給服務器的時候，因為用的是while循環，所以文件的結束符-1並沒有被讀取到服務器，這時上傳到服務器的文件就沒有結束符，服務器把讀取到的文件保存到服務器硬盤上時就會一直執行while循環，導致阻塞。另外還有一個阻塞時服務器向客戶端響應文件時候的阻塞。

解決阻塞問題的方法？

阻塞問題的根本原因就是因為在讀取的時候沒有結束符，用  socket.shutdownOutput()  給上傳的文件一個中止序列。

API對  shutdownOutput()  的解釋：對於 TCP 套接字，任何以前寫入的數據都將被發送，並且后跟 TCP 的正常連接終止序列。