Пересылка файлов - Java Сети - Ответ 3823444

package tmp2;
 
import java.io.*;
import java.net.*;
import java.util.*;
 
public class ServerPart {
    
    public static final int PORT = 19999;
    
    public static List<ConnectionThread>clientList;
    public static List<Thread>threadList;
    public static List<File>fileList;
    
    
    public static void main(String[] args) {
        clientList = new ArrayList<ConnectionThread>();
        threadList = new ArrayList<Thread>();
        fileList = new ArrayList<File>();
        ServerSocket serversocket = null;
        boolean endless = true;
        try {
            serversocket = new ServerSocket(PORT);
            System.out.println("Server socket is created: " +serversocket.getInetAddress().getHostAddress()+ "\nWaiting or connection..");
            int ID = 0;
            while(endless) {
                Socket socket = serversocket.accept();
                addClient(socket, ID);
                ID++;
            }
        } catch(IOException e) {
            e.printStackTrace();
        } finally {
            try {
                if(serversocket != null)
                    serversocket.close();
                closeAllConnections();
            } catch(IOException e) {
                e.printStackTrace();
            }
        }
 
    }
    
    private static synchronized void addClient(Socket socket, int ID) {
        System.out.println("Got a connection from: " +socket.getInetAddress() +": "+ socket.getPort());
        ConnectionThread conn = new ConnectionThread(socket, ID, socket.getInetAddress());
        Thread th = new Thread(conn);
        threadList.add(th);
        clientList.add(conn);
        th.start();
    }
    
    private static void closeAllConnections() {
        for(int i=0; i<clientList.size(); i++) {
            ConnectionThread c = clientList.get(i);
            c.sendLine("Quiting...");
            clientList.remove(i);
        }
    }
    
    public static synchronized void fileSender() {
        
    }
 
}
 
class ConnectionThread implements Runnable {
    boolean c;
    PrintWriter out = null;
    BufferedReader buf = null;
    InetAddress clientAddress = null;
    public int ID;
    
    public ConnectionThread(Socket socket, int ID, InetAddress clientAddress) {
        this.ID = ID;
        this.clientAddress = clientAddress;
        try {
            out = new PrintWriter(socket.getOutputStream(), true);
            buf = new BufferedReader(new InputStreamReader(socket.getInputStream()));
        } catch(IOException e) {
            System.out.println("Failed to connect! Connection id: " +ID+ ", client address: " +clientAddress);
        }
        c = true;
        System.out.println("New connection established with id: " + ID);
        out.println("You are connected as USER: " +ID);
        //ServerPart.fileSender();
    }
    
    public void sendLine(String message) {
        if(c)
            out.println(message);
    }
    
    public void run() {
        while(c) {
            try {
                String line = buf.readLine();
                if(line != null) {
                    if(line.equals("kill")) {
                        c = false;
                        throw new IOException();
                    }
                    
                }
            } catch(IOException e) {
                c = false;
                String dcmsg = "User: " +ID+ " diconnected!!";
                System.out.println(dcmsg);
            }
        }
    }
    
    public void close() {
        while(c) {
            try {
                buf.close();
                out.close();
            } catch(IOException e) {
                e.printStackTrace();
            }
        }
    }
}

package tmp2;
 
import java.io.*;
import java.net.*;
 
public class ClientPart {
 
    
    public static void main(String[] args) {
        
        try {
            Socket socket = new Socket(InetAddress.getLocalHost(),19999);
            PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
            Listening conn = new Listening(socket);
            Thread t = new Thread(conn);
            t.start();
            BufferedReader buf = new BufferedReader(new InputStreamReader(System.in));
            StringBuffer line = new StringBuffer("");
            System.out.println("For closing session enter 'kill'!");
            while(!line.toString().equals("kill")) {
                line.setLength(0);
                line.append(buf.readLine());
                out.println(line.toString());
            }
            out.close();
            buf.close();
            socket.close();
        } catch(UnknownHostException e) {
            System.out.println("Unexpected error, exiting..");
        } catch(IOException e) {
            System.out.println("There are no servers available, exiting..");
        }
    }
 
}
 
class Listening implements Runnable {
    BufferedReader buf = null;
    public Listening(Socket socket) {
        try {
            buf = new BufferedReader(new InputStreamReader(socket.getInputStream()));
        } catch(IOException e) {
            System.out.println("Something wrong in the connection.");
        }
    }
    
    public void run() {
        StringBuffer line = new StringBuffer("");
        while(true) {
            try {
                line.setLength(0);
                line.append(buf.readLine());
                if(!(line.toString().equals("null"))) {
                    System.out.println(line);
                } else {
                    buf.close();
                    throw new Exception();
                }
            } catch(Exception e) {
                System.out.println("Lost connection to server!");
                System.exit(0);
            }
        }
    }
}

    public static synchronized void fileSender(Socket socket) throws IOException {
        int fs = 9999999;
        long start = System.currentTimeMillis();
        int bR;
        int c = 0;
        File file = new File("E:\tmp");
        File[] files = file.listFiles();
        for(int fileInList = 0; fileInList<files.length; fileInList++) {
            byte[] mba = new byte[fs];
            InputStream is = socket.getInputStream();
            FileOutputStream fos = new FileOutputStream(file);
            BufferedOutputStream bos = new BufferedOutputStream(fos);
            bR = is.read(mba,0,mba.length);
            c = bR;
            do {
                bR = is.read(mba,c,(mba.length-c));
                if(bR >= 0)
                    c += bR;
            } while(bR < -1);
            bos.write(mba,0,c);
            bos.flush();
            long end = System.currentTimeMillis();
            System.out.println(end-start);
            bos.close();
            socket.close();
        }
    }