Чат - как написать серверную часть

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.Iterator;
 
public class ChatServer {
 
ArrayList clientOutputStreams;
 
    public class ClientHandler implements Runnable{
        BufferedReader reader;
        Socket socket;
 
        public ClientHandler(Socket clientSocket){
            try{
                socket = clientSocket;
                InputStreamReader isReadr = new InputStreamReader(socket.getInputStream());
                reader = new BufferedReader(isReadr);
            } catch (Exception ex) {ex.printStackTrace();}
        }
 
        @Override
        public void run() {
            String message;
            try {
                while (((message = reader.readLine()) != null)) {
                    System.out.println("read " + message);
                    tellEveryone(message);
                }
            }catch (Exception ex) {ex.printStackTrace(); }
                } // run
            } // вложенный клас
 
    public static void main(String[] args) {
        new ChatServer().go();
    }
 
    public void go(){
        clientOutputStreams = new ArrayList();
        try {
            ServerSocket serverSocket = new ServerSocket(5000);
 
            while (true) {
                Socket clientSocket = serverSocket.accept();
                PrintWriter writer = new PrintWriter(clientSocket.getOutputStream());
                clientOutputStreams.add(writer);
 
                Thread t = new Thread(new ClientHandler(clientSocket));
                t.start();
                System.out.println("got a connection");
            }
        }catch (Exception ex){ex.printStackTrace();}
            } // clouse go();
 
        public void tellEveryone(String message){
            Iterator it = clientOutputStreams.iterator();
            while (it.hasNext()){
                try{
                    PrintWriter writer = (PrintWriter) it.next();
                    writer.println(message);
                    writer.flush();} catch (Exception ex) {ex.printStackTrace();}
                } // end while
            } // clouse tellEveryone
        } // clouse class

import javax.swing.*;
import java.awt.*;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
 
public class ChatClient {
 
    JTextArea incoming;
    JTextField outgoing;
    BufferedReader reader;
    PrintWriter writer;
    Socket socket;
    String name = "Игорь";
 
    public String getName() {
        return name;
    }
 
    public static void main(String[] args) {
        ChatClient client = new ChatClient();
        client.go();
    }
 
    public void go(){
        JFrame frame = new JFrame("Чат");
        JPanel mainPanel  = new JPanel();
        incoming = new JTextArea(15,50);
        incoming.setLineWrap(true);
        incoming.setLineWrap(true);
        incoming.setEditable(false);
        JScrollPane qScroll = new JScrollPane(incoming);
        qScroll.setVerticalScrollBarPolicy(ScrollPaneConstants.VERTICAL_SCROLLBAR_ALWAYS);
        qScroll.setHorizontalScrollBarPolicy(ScrollPaneConstants.HORIZONTAL_SCROLLBAR_NEVER);
        outgoing = new JTextField(20);
        JButton sendButton = new JButton("Send");
        sendButton.addActionListener(new SendButtonListener());
        mainPanel.add(qScroll);
        mainPanel.add(outgoing);
        mainPanel.add(sendButton);
        setUpNetworking();
 
/*
        try {
            writer.println(outgoing.getName());
            writer.flush();
            System.out.println(getName());
        }catch (Exception ex){
            ex.printStackTrace();
        }
*/
 
        Thread readerThread = new Thread (new IncomingReader());
        readerThread.start();
 
        frame.getContentPane().add(BorderLayout.CENTER, mainPanel);
        frame.setSize(700, 400);
        frame.setVisible(true);
    }
 
    private void setUpNetworking(){
        try {
            socket = new Socket("127.0.0.1", 5000);
            InputStreamReader streamReader = new InputStreamReader(socket.getInputStream());
            reader = new BufferedReader(streamReader);
            writer = new PrintWriter(socket.getOutputStream());
            System.out.println("Networking established");
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
 
    public class SendButtonListener implements ActionListener{
        @Override
        public void actionPerformed(ActionEvent e) {
            try {
                writer.println(outgoing.getText());
                writer.flush();
            }catch (Exception ex){
                ex.printStackTrace();
            }
            outgoing.setText("");
            outgoing.requestFocus();
            incoming.append("send");
        }
    }
 
    public class IncomingReader implements Runnable{
 
        @Override
        public void run() {
            String message;
            try {
                while((message = reader.readLine()) != null){
                    System.out.println("read "+message);
                    incoming.append(message + "\n");
                }
            } catch (Exception ex) { ex.printStackTrace(); }
        }
    }
}