import java.io.BufferedInputStream;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;
public class FunctionServer {
 private static int PORT = 2012;
 private String path = "需要下載的文件所在路徑";
 public static void main(String[] args) throws IOException{
  FunctionServer server = new FunctionServer();
  server.start();
 }
 public void start() throws IOException{
  ServerSocket ss = new ServerSocket(PORT);
  while(true){
   Socket s = ss.accept();
   new Service(s).start();//創(chuàng)建線程
  }
 }
 class Service extends Thread{
  Socket s;
  public Service(Socket s){
   this.s = s;
  }
  public void run(){
   try{
    InputStream in = s.getInputStream();//得到輸入流
    Scanner sc = new Scanner(in);
    OutputStream out = s.getOutputStream();
    while(true){
     String str = sc.nextLine();//讀取文件名
     if(!str.equals(null)){
      System.out.println("你的文件名是"+str);
      //根據(jù)路徑和文件名獲取文件
      File f = new File(path+str);
      FileInputStream fis = new FileInputStream(f);
      DataInputStream dis = new DataInputStream(new BufferedInputStream(fis));
      byte[] buffer = new byte[8192];
      DataOutputStream ps = new DataOutputStream(out);
      ps.writeLong((long) f.length());//發(fā)送文件大小
      ps.flush();
      while(true) {
       int read = 0;
       if(dis!=null){
        read = fis.read(buffer);
       }
       if(read == -1){
        break;
       }
       ps.write(buffer,0,read);
      }
      ps.flush();
      dis.close();
      s.close();
      out.flush();
      break;
     }
    }
   }catch(IOException e){
    e.printStackTrace();
   }
  }
 }
}

class DownloadThread extends Thread {
  Socket socket;
  InputStream in;
  OutputStream out;
  String path = "文件保存路徑";
  String functionName;
  String serverIp = "服務器IP";
  int socketPort = "服務端口號";
  int fileSize,downLoadFileSize;
  public DownloadThread(String functionName) {
   this.functionName = functionName;
  }
  @Override
  public void run() {
   Looper.prepare();
   while(!Thread.interrupted()){
    try {
     socket = new Socket(serverIp, socketPort);
     InputStream in = socket.getInputStream();
     OutputStream out = socket.getOutputStream();
     out.write((functionName + "\n").getBytes("gbk"));
     out.flush(); // 清理緩沖，確保發(fā)送到服務端
     File f = new File(path + functionName);
     OutputStream song = new FileOutputStream(f);
     DataInputStream dis = new DataInputStream(
       new BufferedInputStream(in));
     DataOutputStream dos = new DataOutputStream(
       new BufferedOutputStream(song));
     fileSize = (int) dis.readLong() - 1;
     System.out.println("開始下載");
     byte[] buffer = new byte[8192];
     while (true) {
      int read = 0;
      if (dis != null) {
       read = dis.read(buffer);
       downLoadFileSize += read;
        }
      if (read == -1) {
       break;
      }
      dos.write(buffer, 0, read);
     }
     System.out.println("文件下載完成");
     dos.close();
    } catch (UnknownHostException e) {
     // TODO Auto-generated catch block
     e.printStackTrace();
    } catch (IOException e) {
     // TODO Auto-generated catch block
     e.printStackTrace();
    } finally {
     this.interrupt();
    }
   }
  }
 }