Клиент-сервер со множеством клиентов java

package simplechat;
 
import java.net.*;
import java.io.*;
import java.util.*;
 
/**
 *
 * @author Sergey
 */
public class Client {
 
    private String userName;
    
    public Client(){
        this.userName = "";
    }
 
    public void setName(String name){
        this.userName = name;
    }
    public String getName(){
        return userName;
    }
 
    public static void main(String[] args) throws IOException{
        System.out.println("Welcome to Client!");
        String fuser, fserver;
 
        Socket fromserver = new Socket("localhost", 4444);
 
        Scanner sc = new Scanner(System.in);
        BufferedReader in  = new BufferedReader
                (new InputStreamReader(fromserver.getInputStream()));
        PrintWriter    out = new PrintWriter
                (fromserver.getOutputStream(),true);
         BufferedReader inu  = new BufferedReader
                (new InputStreamReader(System.in));
         
        System.out.println("Set name: ");
        Client cl = new Client();
        if(sc.hasNext()){
           cl.setName(sc.next());
        }
        System.out.println("Name confirmed, "+cl.getName());
        out.println(cl.getName());
        
        while((fuser = inu.readLine())!= null){
            out.println(fuser);
            fserver = in.readLine();
            System.out.println(fserver);
            if(fuser.equalsIgnoreCase("exit chat")) break;
            if(fuser.equalsIgnoreCase("close chat")) break;
        }
 
        out.close();
        in.close();
        inu.close();
        fromserver.close();
    }     
}

package simplechat;
 
import java.io.*;
import java.net.*;
import java.util.*;
 
/**
 *
 * @author Sergey
 */
public class Server implements Runnable{
    
    Socket connection;
    String input;
    
    public Server(Socket socket){
        this.connection = socket;
        
    }
    
    public static void main(String[] args) throws IOException{
        System.out.println("Welcome to Server!");
 
        ServerSocket servers = null;
        
        try{
            servers = new ServerSocket(4444);
        }catch(IOException e){
            System.out.println("Can't connect to port");
            System.exit(-1);
        }
        while(true){
            try{
                System.out.println("Waiting for a client...");
                Socket connection = servers.accept();
                Runnable runnable = new Server(connection);
                Thread thread = new Thread(runnable);
                thread.start();
                System.out.println("Client connected");
            }catch(IOException e){
                System.out.println("");
                System.exit(-1);
            }
        }   
    }
 
    @Override
    public void run() {
        String name="";
        try {
            BufferedReader in = new BufferedReader(new 
                        InputStreamReader(connection.getInputStream()));
            PrintWriter out = new PrintWriter(connection.getOutputStream(), true);
            if((input = in.readLine())!=null){ 
                name = input;
            }
            System.out.println("Waiting for messages...");
            while(true){
                if((input = in.readLine())!=null){
                    out.println(name+": "+input);
                    System.out.println("S: "+input);
                }
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}