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后端開(kāi)發(fā)之路\\IO\\講義\\a.txt");
   
   // 請(qǐng)求與服務(wù)端進(jìn)行建立連接
   Socket socket = new Socket("127.0.0.1", 9999);
   
   // 字節(jié)輸出流包裝成一個(gè)數(shù)據(jù)輸出流
   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();
   
   
   // 通知服務(wù)端這邊的數(shù)據(jù)發(fā)送完畢了
   socket.shutdownOutput();
  } catch (Exception e) {
   // TODO: handle exception
  }

 }

}

服務(wù)端

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 {
  
  // 建立服務(wù)器
  ServerSocket socket = new ServerSocket(9999);
  
  
  Socket accept = socket.accept();
  // 交給一個(gè)獨(dú)立的線程來(lái)處理與這個(gè)客戶端的文件通信需求。
  new ServerThread(accept).start();
 }
}

服務(wù)端線程處理

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 {
   
   // 得到一個(gè)數(shù)據(jù)輸入流讀取客戶端發(fā)送過(guò)來(lái)的數(shù)據(jù)
   DataInputStream stream = new DataInputStream(socket.getInputStream());
   
    // 讀取客戶端發(fā)送過(guò)來(lái)的文件類型
            String suffix = stream.readUTF();
            System.out.println("服務(wù)端已經(jīng)成功接收到了文件類型：" + suffix);
            
            // 定義一個(gè)字節(jié)輸出管道負(fù)責(zé)把客戶端發(fā)來(lái)的文件數(shù)據(jù)寫(xiě)出去
   FileOutputStream stream2 = new FileOutputStream("E:\\Java后端開(kāi)發(fā)之路\\IO\\講義\\b.txt"+UUID.randomUUID().toString()+suffix);
   // 從數(shù)據(jù)輸入流中讀取文件數(shù)據(jù)，寫(xiě)出到字節(jié)輸出流中去
   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();
  }
 }

}