java如何模擬客戶端向服務器上傳文件

這篇文章主要介紹了java如何模擬客戶端向服務器上傳文件，具有一定借鑒價值，感興趣的朋友可以參考下，希望大家閱讀完這篇文章之后大有收獲，下面讓小編帶著大家一起了解一下。

具體內容如下

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

• 服務器端先啟動，然后啟動客戶端向服務器端發送數據。

• 服務器端收到客戶端發送的數據，服務器端會響應應客戶端，向客戶端發送響應結果。

• 客戶端讀取服務器發送的數據
  

文件上傳步驟：

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

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

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

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

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

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

客戶端的代碼實現

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的正常連接終止序列。

感謝你能夠認真閱讀完這篇文章，希望小編分享的“java如何模擬客戶端向服務器上傳文件”這篇文章對大家有幫助，同時也希望大家多多支持億速云，關注億速云行業資訊頻道，更多相關知識等著你來學習!