Создание клиент-серверной программы чата

Question

В программе чата сервера клиента, использующей потоки объектов, как я смогу отправить сообщение всем клиентам и частное сообщение для определенных клиентов?

в моем методе прослушивания соединений я принимаю соединение

public void listenForConnections()
{
    String sUserName="";

    try{
        do {
            System.out.println("Waiting on connections");
            Socket client = servSocket.accept();
            System.out.println("Connection From: " + client.getInetAddress());          


            //pass message handling to thread and listen
            ClientHandler handler = new ClientHandler(client,this);
            handler.start();//As usual, this method calls run.                

        } while (true);
    }
    catch(Exception e){
        e.printStackTrace();
    }
}

Затем я передаю этот клиент потоку на сервере для обработки обмена сообщениями;

i, e;

            //pass message handling to thread and listen
            ClientHandler handler = new ClientHandler(client,this);
            handler.start();//As usual, this method calls run.

Как игде я могу хранить список подключенных клиентов?

Я подумал о hastable, ключом которого являются имя пользователя и ObjectOutPutStream.И затем прочитать объект, отправленный после того, как соединение было принято, но я столкнулся с проблемами.Сообщение было командой входа в систему с именем пользователя и командой LOGIN

Мой код стал;

System.out.println («Ожидание соединения»);Socket client = servSocket.accept ();System.out.println ("Connection From:" + client.getInetAddress ());

            ObjectOutputStream clientOOS = new ObjectOutputStream(client.getOutputStream());

            outputStreams.put(sUserName, oos );


            //big problem here
            //serializeation
            /*ois = new ObjectInputStream(client.getInputStream());
            oos = new ObjectOutputStream(client.getOutputStream());

            //ask for the username /authenticate
            System.out.println("SERVER: getting username");
            myMessage inMessageLogin = (myMessage) ois.readObject();

            if(inMessageLogin.getCOMMAND()==ServerCommands.CMD_LOGIN)
            {
                sUserName=inMessageLogin.getsUserName();
                System.out.println("SERVED User " + sUserName + " connected.");
                //save stream
                outputStreams.put(sUserName, oos );
                //oos.close();
                //oos.flush();
                //ois.close();
                ois=null;
                //oos=null;
            }

            //end of problem!!!!!*/

Что я прокомментировал, поскольку он выдавал ошибки о поврежденных потоках, есть идеи?

Спасибо

Чтобы отправить сообщение на сервер от клиента;

//default cmd is to send to all
public void sendMessage(String sText,int iCommand)
{
    System.out.println("sendMessage");

    outMessage=new myMessage();

    outMessage.setsUserName(sCurrentUser);
    //set command
    outMessage.setCOMMAND(iCommand);

    outMessage.setsMessage(sText);

    System.out.println("send msg" + outMessage.displayMessage());

    try {
        oos.writeObject(outMessage);
        oos.flush();
        oos.reset();
        //clear up send message from txbox
        txtMessage.setText("");
    } catch (IOException ex) {
        Logger.getLogger(myClientGUI.class.getName()).log(Level.SEVERE, null,

ex);}}

код клиента для подключения к серверу;

public void connectToServer()
{
    String sServer=txtServer.getText();
    PORT=Integer.parseInt(txtPort.getText());
    try {
        //host = InetAddress.getByName("localhost");//InetAddress.getLocalHost();
        host = InetAddress.getByName(sServer);
        clientSocket = new Socket(host, PORT);
    }
    catch (Exception e){
        e.printStackTrace();
    }
}

public boolean createStreams()
{
    try{
        //serial
        //*******************************************************************************
        // open I/O streams for objects - serialization streams
        oos = new ObjectOutputStream(clientSocket.getOutputStream());
        ois = new ObjectInputStream(clientSocket.getInputStream());



        return true;
    }
    catch(Exception e)
    {
        e.printStackTrace();
        return false;
    }
}

Answer 1

Следующий код прекрасно работает для меня.Обратите внимание, что класс Server должен иметь доступ к классу Message в своем пути к классам, а класс Message реализует Serializable.

Клиент:

class Client {
    private Socket clientSocket;

    public void connectToServer()
    {
        String sServer="localhost";
        int PORT = 8181;
        try {
            InetAddress host = InetAddress.getByName(sServer);
            clientSocket = new Socket(host, PORT);
        }
        catch (Exception e){
            e.printStackTrace();
        }
    }

    public void sendMessage(String sText,int iCommand) throws IOException {
        Message outMessage = new Message();

        outMessage.setCOMMAND(iCommand);
        outMessage.setsMessage(sText);

        ObjectOutputStream oos = new ObjectOutputStream(clientSocket.getOutputStream());
        try {
            oos.writeObject(outMessage);
            oos.flush();
            oos.reset();
        } catch (IOException ex) {
            ex.printStackTrace();
        }
    }

    public static void main(String[] args) {
        Client c = new Client();
        c.connectToServer();
        try {
            c.sendMessage("test message", 42);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

class Message implements Serializable {
    private int iCommand;
    private String sText;

    public void setCOMMAND(int iCommand) {
        this.iCommand = iCommand;
    }

    public void setsMessage(String sText) {
        this.sText = sText;
    }

    @Override
    public String toString() {
        return "Message{" +
                "iCommand=" + iCommand +
                ", sText='" + sText + '\'' +
                '}';
    }
}

Сервер:

class Server {
    public static void main(String[] args) throws IOException {
        ServerSocket serverSocket = new ServerSocket(8181);

        do {
            Socket s = serverSocket.accept();
            try {
                processClient(s);
            } catch (ClassNotFoundException e) {
                e.printStackTrace();
            }
        } while (true);
    }

    private static void processClient(Socket s) throws IOException, ClassNotFoundException {
        ObjectInputStream ois = new ObjectInputStream(s.getInputStream());
        Message message = (Message) ois.readObject();
        System.out.println(message.toString());
    }
}