Пересылка сообщений между клиентами

class ServeOneJabber extends Thread {
    private Socket socket;
    private BufferedReader in;
    private PrintWriter out;
    public ServeOneJabber(Socket s)
            throws IOException {
        socket = s;
        in =
                new BufferedReader(
                        new InputStreamReader(
                                socket.getInputStream()));
        // Включение автосброса буферов:
        out =
                new PrintWriter(
                        new BufferedWriter(
                                new OutputStreamWriter(
                                        socket.getOutputStream())), true);
        // Если какой либо, указанный выше класс выбросит исключение
        // вызывающая процедура ответственна за закрытие сокета
        // В противном случае нить(поток) закроет его.
 
        start(); // Вызывает run()
    }
    public void run() {
        try {
            while (true) {
                String str = in.readLine();
                if (str.equals("END")) break;
                System.out.println("Echoing: " + str);
                out.println("S "+str);
            }
            System.out.println("closing...");
        } catch(IOException e) {
            System.err.println("IO Exception");
        } finally {
            try {
                socket.close();
            } catch(IOException e) {
                System.err.println("Socket not closed");
            }
        }
    }
}
 
public class Main {
    static final int PORT = 8080;
    public static void main(String[] args)
            throws IOException {
        ServerSocket s = new ServerSocket(PORT);
        System.out.println("Server Started");
        try {
            while(true) {
                // Останавливает выполнение, до нового соединения:
                Socket socket = s.accept();
                try {
                    new ServeOneJabber(socket);
                } catch(IOException e) {
                    // Если неудача - закрываем сокет,
                    // в противном случае нить закроет его:
                    socket.close();
                }
            }
        } finally {
            s.close();
        }
    }
}

Socket socket = null;
                BufferedReader in = null;
                PrintWriter out = null;
                int counter = 0;
                int id = counter++;
                int threadcount = 0;
                System.out.println("Making client " + id);
                threadcount++;
                try {
                    socket =
                            new Socket("localhost", 8080);
                } catch(IOException e) {
                    System.err.println("Socket failed");
                    // Если сокет не создался,
                    // ничего не надо чистить.
                }
                try {
                    in =
                            new BufferedReader(
                                    new InputStreamReader(
                                            socket.getInputStream()));
                    // Включение авто-очистки буфера:
                    out =
                            new PrintWriter(
                                    new BufferedWriter(
                                            new OutputStreamWriter(
                                                    socket.getOutputStream())), true);
 
                } catch (IOException e) {
                    try {
                        socket.close();
                    } catch(IOException e2) {
                        System.err.println("Socket not closed");
                    }
                }
                {
                    try {
                        for(int i = 0; i < 3; i++) {
                            out.println("Client " + id + ": " + i);
                            String str = in.readLine();
                            System.out.println(str);
                        }
                        // out.println("END");
                    } catch(IOException e) {
                        System.err.println("IO Exception");
                    } finally {
                        // Всегда закрывает его:
                        // socket.close();
                        threadcount--; // Завершение нити
                    }
                }