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

成都創(chuàng)新互聯(lián)是專業(yè)的井研網(wǎng)站建設公司，井研接單;提供網(wǎng)站設計制作、做網(wǎng)站,網(wǎng)頁設計,網(wǎng)站設計,建網(wǎng)站,PHP網(wǎng)站建設等專業(yè)做網(wǎng)站服務;采用PHP框架,可快速的進行井研網(wǎng)站開發(fā)網(wǎng)頁制作和功能擴展;專業(yè)做搜索引擎喜愛的網(wǎng)站,專業(yè)的做網(wǎng)站團隊,希望更多企業(yè)前來合作!

具體內(nèi)容如下

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

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

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

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

文件上傳步驟：

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

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

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

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

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

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

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

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是服務器名稱或Ip地址
       OutputStream os = socket.getOutputStream();//使用socket中的方法，獲取網(wǎng)絡字節(jié)輸出流對象
   
       byte[] bytes = new byte[1024];//把本地硬盤的數(shù)據(jù)通過網(wǎng)絡字節(jié)輸出流傳遞給客戶端
       int len = 0;
       while ((len = fis.read(bytes))!=-1){
         os.write(bytes,0,len);
       }
   
       socket.shutdownOutput();//為了解決阻塞問題
   
       InputStream is = socket.getInputStream();//使用socket中的方法，獲取網(wǎng)絡字節(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();
     }
   }

服務器端代碼實現(xiàn)

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



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

            File file = new File("D:\\upload");//判斷服務器硬盤中的文件夾是否存在，此文件夾用于存儲客戶端上傳的內(nèi)容
            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 ){//將客戶端的數(shù)據(jù)寫入服務器硬盤中
              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解決異常

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

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

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

解決阻塞問題的方法？

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

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

感謝你能夠認真閱讀完這篇文章，希望小編分享的“java如何模擬客戶端向服務器上傳文件”這篇文章對大家有幫助，同時也希望大家多多支持創(chuàng)新互聯(lián)，關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道，更多相關(guān)知識等著你來學習!

新聞標題：java如何模擬客戶端向服務器上傳文件
文章分享：http://www.chinadenli.net/article38/ggphpp.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供微信公眾號、關(guān)鍵詞優(yōu)化、面包屑導航、企業(yè)網(wǎng)站制作、標簽優(yōu)化、品牌網(wǎng)站制作

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)