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。