Download Manager на Java по Шилдту

import java.awt.Container;
import java.awt.GridBagConstraints;
import java.awt.GridBagLayout;
import java.awt.Toolkit;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.WindowAdapter;
import java.awt.event.WindowEvent;
import java.io.BufferedOutputStream;
import java.io.BufferedReader;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.LinkedList;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JOptionPane;
import javax.swing.JPanel;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
 
 
public class Chat extends JFrame implements Runnable{
public Chat(){
    Container cont = getContentPane();
    
    JPanel panel = new JPanel();
    panel.setLayout(new GridBagLayout());
    GridBagConstraints constrains = new GridBagConstraints();
    
    constrains.gridx = 0;
    constrains.gridy = 0;
    constrains.gridwidth = 3;
    constrains.gridheight = 1;
    constrains.weightx = 100;
    constrains.weighty = 100;
    constrains.fill = GridBagConstraints.BOTH;
    
    inArea = new JTextArea(5,40);
    inArea.setEditable(false);
    JScrollPane paneIn = new JScrollPane(inArea);
    panel.add(paneIn,constrains);
    
    
    constrains.gridx = 0;
    constrains.gridy = 1;
    constrains.gridwidth = 2;
    outArea = new JTextArea();
    outArea.setPreferredSize(inArea.getPreferredSize());
    JScrollPane paneOut = new JScrollPane(outArea);
    panel.add(paneOut,constrains);
    
    
    
    constrains.gridx = 2;
    constrains.gridy = 1;
    constrains.gridwidth = 1;
    ok = new JButton("OK");
    ok.addActionListener(new OkListener());
    panel.add(ok,constrains);
    
    cont.add(panel);
    
    setLocation((int)Toolkit.getDefaultToolkit().getScreenSize().getWidth()/4
            ,  (int)Toolkit.getDefaultToolkit().getScreenSize().getHeight()/4);
    
    setSize(300,200);
    
    setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
    
    pack();
    
    addWindowListener(new CloseFinally());
    
    setVisible(true);
    
    outArea.setText(null);
 
}
private class OkListener implements ActionListener{
 
    @Override
    public void actionPerformed(ActionEvent event) {
        try{
            String temp = outArea.getText();
        
            
            if(temp.trim().equals("")){
                throw new NullPointerException();
            }
            
            sock = new Socket(serverIp,serverPort);
            
            out = new DataOutputStream(
                    new BufferedOutputStream(sock.getOutputStream()));
            out.write(temp.getBytes());
            
        }catch(NullPointerException ex){
            JOptionPane.showMessageDialog(null, "Нельзя отсавлять поле пустым");
        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }finally{
            try {
                out.flush();
                out.close();
                sock.close();
                outArea.setText(null);
                outArea.requestFocus();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        
        
        
    }
    private DataOutputStream out;
    private Socket sock;
    
}
private class ChatSocket implements Runnable{
 
    @Override
    public void run() {
        try{
            
            ServerSocket server = new ServerSocket(Chat.chatPort);
            
            while(true){
                Socket sock = server.accept();
                in = new BufferedReader
                    (new InputStreamReader(sock.getInputStream()));
                String temp = in.readLine();
                chatList.add(temp);
                temp = "";
                for(String s : chatList){
                    temp += s;
                }
                inArea.setText("");
                inArea.setText(temp);
                sock.close();
                in.close();
 
            }
            
            
        }catch(IOException ex){
            ex.printStackTrace();
        }
        
        
        
    }
    
    private BufferedReader in;
    
}
 
 
 
    
    
    
    public static void main(String[] args){
        ExecutorService exec =  Executors.newFixedThreadPool(4);
        Chat chat = new Chat();
        ChatSocket socket = chat.new ChatSocket();
        exec.execute(socket);
        exec.execute(new FirstStart());
        
        
        
    }
    
 
    @Override
    public void run() {
        
        new Chat();
        
    }
private class CloseFinally extends WindowAdapter{
    @Override
    public void windowClosed(WindowEvent event) {
        super.windowClosed(event);
        
        try{
            
         Socket sock = new Socket(Chat.serverIp,Chat.serverPort);
         out = new DataOutputStream
            (new BufferedOutputStream(sock.getOutputStream()));
         out.write("!**closed**closed**!".getBytes());
         
         
         
        }catch(IOException ex){
            ex.printStackTrace();
        }
        
        finally
        {
            try {
                
                out.flush();
                out.close();
                sock.close();
                
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        
    }
    private Socket sock;
    private DataOutputStream out;
    
}
    
    
    
    
    public static final LinkedList<String> chatList = new LinkedList<String>();
    private static JTextArea outArea;
    private static JTextArea inArea;
    private static JButton ok;
    public static int serverPort = 7777;
    public static String serverIp = "89.236.249.221";
    public static int chatPort = 8888;
}
class FirstStart implements Runnable{
 
    @Override
    public void run() {
        try{
            
             temp = JOptionPane.showInputDialog("Введите ваше имя: ");
            
            while(temp == null || temp.trim().equals("")){
                System.out.println("WHILE");
                 temp = JOptionPane.showInputDialog("Введите ваше имя: ");  
            }
            
            sock = new Socket(Chat.serverIp,Chat.serverPort);
            out = new DataOutputStream
            (new BufferedOutputStream(sock.getOutputStream()));
            
            out.write(temp.getBytes());
            
        }catch(IOException ex){
            ex.printStackTrace();
        }catch(NullPointerException ex){
            while(temp == null){
                System.out.println("WHILE");
                 temp = JOptionPane.showInputDialog("Введите ваше имя: ");  
            }
        }
        finally{
            try {
                out.flush();
                out.close();
                sock.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    
        
        
    }
    private DataOutputStream out;
    private Socket sock ;
    private String temp;
    
}

import java.io.BufferedReader;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.TreeSet;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
 
 
public class Server {
 
    
    public static void main(String[] args) {
        ExecutorService exec = Executors.newCachedThreadPool();
        
        try{
            ServerSocket hSocket = new ServerSocket(serverPort);
            while(true){
                Socket s = hSocket.accept();
                InetAddress ip = s.getInetAddress();
                ipList.add(ip.getHostAddress());
                
                reader = new BufferedReader(
                        new InputStreamReader(s.getInputStream()));
                String temp = reader.readLine();
                
                if(temp.equals("")){
                    continue;
                }
                
                if(temp.equalsIgnoreCase("!**closed**closed**!")){
                    ipList.remove(ip.getHostAddress());
                    s.close();
                    reader.close();
                    System.err.println("EXIT");
                    System.exit(0);
                    continue;
                }
                
                
                Server server = new Server();
                OutThread out = server.new OutThread(temp);
                
                exec.execute(out);
               
                
            
                s.close();
                reader.close();
                
                
            }
            
            
            
        }catch(IOException ex){
            ex.printStackTrace();
        }
        
        
        
 
    }
    public static TreeSet<String> ipList = new TreeSet<String>();
    public static DataOutputStream writer;
    public static BufferedReader reader;
    public static int serverPort = 7777;
    public static String serverIp = "127.0.0.1";
    public static int chatPort = 8888;
    
    private class OutThread implements Runnable{
    OutThread (String message){
        this.message = message;
        this.message += "\n";
    }
        @Override
        public void run() {
            try{
                for(String ip : ipList){
                    sock = new Socket(ip,Server.chatPort);
                    out = new DataOutputStream(sock.getOutputStream());
                    out.write(message.getBytes());
                    System.err.println("server has post: " +message);
                }
 
            }catch(IOException ex){
                ex.printStackTrace();
            }catch(Exception ex){
                ex.printStackTrace();
            }
            
            finally
            {
                try 
                {
                    out.flush();
                    out.close();
                    sock.close();
                } catch (IOException e) 
                {
                    e.printStackTrace();
                }
            }
        }
    private String message; 
    private DataOutputStream out;
    private Socket sock;
        
    }
    
}