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

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

具體內(nèi)容如下

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

• 服務(wù)器端先啟動(dòng)，然后啟動(dòng)客戶端向服務(wù)器端發(fā)送數(shù)據(jù)。

• 服務(wù)器端收到客戶端發(fā)送的數(shù)據(jù)，服務(wù)器端會(huì)響應(yīng)應(yīng)客戶端，向客戶端發(fā)送響應(yīng)結(jié)果。

• 客戶端讀取服務(wù)器發(fā)送的數(shù)據(jù)
  

文件上傳步驟：

客戶端使用本地字節(jié)輸入流，指定上傳數(shù)據(jù)的數(shù)據(jù)源。

客戶端使用網(wǎng)絡(luò)字節(jié)輸出流，把讀取的本地文件上傳到服務(wù)器。

服務(wù)器使用網(wǎng)絡(luò)字節(jié)輸入流，讀取客戶端上傳的文件。

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

服務(wù)器使用網(wǎng)絡(luò)字節(jié)輸出流，給客戶端響應(yīng)一個(gè)“上傳成功”。

客戶端使用網(wǎng)絡(luò)字節(jié)輸入流，讀取服務(wù)器響應(yīng)的數(shù)據(jù)。

客戶端的代碼實(shí)現(xiàn)

public class fileClient {
     public static void main(String[] args) throws IOException {
       FileInputStream fis = new FileInputStream("D:\\1.jpg");//創(chuàng)建一個(gè)本地的輸入流，用于指定上傳數(shù)據(jù)的數(shù)據(jù)源
       Socket socket = new Socket("127.0.0.1",8888);//創(chuàng)建一個(gè)客戶端對(duì)象，host是服務(wù)器名稱或Ip地址
       OutputStream os = socket.getOutputStream();//使用socket中的方法，獲取網(wǎng)絡(luò)字節(jié)輸出流對(duì)象
   
       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ù)進(jìn)行輸出
         System.out.println(new String(bytes,0,len));
       }
   
       socket.close();//關(guān)閉流
       fis.close();
     }
   }

服務(wù)器端代碼實(shí)現(xiàn)

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



    //while(true){//讓服務(wù)器一直處于運(yùn)行狀態(tài)，保證客戶端可以隨時(shí)向服務(wù)器上傳文件
      new Thread(new Runnable() {//為了提高文件上傳效率，來一個(gè)客戶端開一個(gè)線程
        @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ù)器硬盤中的文件夾是否存在，此文件夾用于存儲(chǔ)客戶端上傳的內(nèi)容
            if (!file.exists()){//判斷服務(wù)器端的文件夾是否存在
              file.mkdirs();
            }

            String fileName = "\\picture"+System.currentTimeMillis()+new Random().nextInt(99999)+".jpg";//自己隨機(jī)生成文件名，防止重復(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解決異常，因?yàn)閞un方法不支持拋出異常
            System.out.println(e);
          }

        }
      }).start();
    //}

  }
}

注：在開啟多線程的時(shí)候，因?yàn)閞un方法的父類并不支持throws解決異常，所以run也不支持，只能使用try…catch解決異常

解釋一下為什么在上傳數(shù)據(jù)的時(shí)候客戶端和服務(wù)器會(huì)出現(xiàn)阻塞問題以及解決阻塞的方法

為什么會(huì)出現(xiàn)阻塞？

出現(xiàn)阻塞的根本問題是，客戶端從本地硬盤讀取文件給服務(wù)器的時(shí)候，因?yàn)橛玫氖莣hile循環(huán)，所以文件的結(jié)束符-1并沒有被讀取到服務(wù)器，這時(shí)上傳到服務(wù)器的文件就沒有結(jié)束符，服務(wù)器把讀取到的文件保存到服務(wù)器硬盤上時(shí)就會(huì)一直執(zhí)行while循環(huán)，導(dǎo)致阻塞。另外還有一個(gè)阻塞時(shí)服務(wù)器向客戶端響應(yīng)文件時(shí)候的阻塞。

解決阻塞問題的方法？

阻塞問題的根本原因就是因?yàn)樵谧x取的時(shí)候沒有結(jié)束符，用 socket.shutdownOutput() 給上傳的文件一個(gè)中止序列。

API對(duì) shutdownOutput() 的解釋：對(duì)于 TCP 套接字，任何以前寫入的數(shù)據(jù)都將被發(fā)送，并且后跟 TCP的正常連接終止序列。

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