Java基於BIO實現文件上傳功能

本文實例為大傢分享瞭Java基於BIO實現文件上傳功能的具體代碼,供大傢參考,具體內容如下

客戶端

package com.qst.file;

import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.DataOutputStream;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.FileWriter;
import java.io.IOException;
import java.io.OutputStream;
import java.net.Socket;

public class Client {

 public static void main(String[] args) {
  try {
   // 獲取輸入流
   FileInputStream stream = new FileInputStream("E:\\Java後端開發之路\\IO\\講義\\a.txt");
   
   // 請求與服務端進行建立連接
   Socket socket = new Socket("127.0.0.1", 9999);
   
   // 字節輸出流包裝成一個數據輸出流
   DataOutputStream outputStream = new DataOutputStream(socket.getOutputStream());
   
   outputStream.writeUTF(".txt");
   int len;
   byte[] b = new byte[1024];
   while ((len = stream.read(b)) > 0) {
    outputStream.write(b, 0, len);
   }
   outputStream.flush();
   
   
   // 通知服務端這邊的數據發送完畢瞭
   socket.shutdownOutput();
  } catch (Exception e) {
   // TODO: handle exception
  }

 }

}

服務端

package com.qst.file;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {

 public static void main(String[] args) throws IOException {
  
  // 建立服務器
  ServerSocket socket = new ServerSocket(9999);
  
  
  Socket accept = socket.accept();
  // 交給一個獨立的線程來處理與這個客戶端的文件通信需求。
  new ServerThread(accept).start();
 }
}

服務端線程處理

package com.qst.file;

import java.io.DataInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.net.Socket;
import java.util.UUID;

public class ServerThread extends Thread{
 
 
 private Socket socket;
 
 public ServerThread(Socket accept) {
  this.socket = accept;
 }

 @Override
 public void run() {
  
  try {
   
   // 得到一個數據輸入流讀取客戶端發送過來的數據
   DataInputStream stream = new DataInputStream(socket.getInputStream());
   
    // 讀取客戶端發送過來的文件類型
            String suffix = stream.readUTF();
            System.out.println("服務端已經成功接收到瞭文件類型:" + suffix);
            
            // 定義一個字節輸出管道負責把客戶端發來的文件數據寫出去
   FileOutputStream stream2 = new FileOutputStream("E:\\Java後端開發之路\\IO\\講義\\b.txt"+UUID.randomUUID().toString()+suffix);
   // 從數據輸入流中讀取文件數據,寫出到字節輸出流中去
   byte []  b= new byte[1024];
   
   int len;
   while((len = stream.read(b)) > 0) {
    stream2.write(b, 0, len);
   }
   System.out.println("操作完畢");
   stream2.close();
   stream.close();
   
  } catch (IOException e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  }
 }

}

以上就是本文的全部內容,希望對大傢的學習有所幫助,也希望大傢多多支持WalkonNet。

推薦閱讀: