1

オブジェクト ストリームを使用するサーバー クライアント チャット プログラムで、すべてのクライアントにメッセージを送信し、特定のクライアントにプライベート メッセージを送信するにはどうすればよいでしょうか?

接続方法のリッスンで、接続を受け入れます

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();
    }
}

次に、このクライアントをサーバーのスレッドに渡して、メッセージ交換を処理します。

私、e;

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

接続されたクライアントのリストを保持する方法と場所を教えてください。

キーがユーザー名とObjectOutPutStreamであるハッシュテーブルを考えました。そして、接続が受け入れられた後に送信されるオブジェクトを読み取るために、問題が発生しました。メッセージは、ユーザー名とコマンド LOGIN を与えるログイン コマンドでした。

私のコードは次のようになりました。

System.out.println("接続を待機中"); ソケット クライアント = servSocket.accept(); System.out.println("接続元: " + 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,

元）; } }

サーバーに接続するためのクライアント コード。

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;
    }
}
4

1 に答える 1

0

次のコードは私にとって完全にうまく機能します。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());
    }
}
于 2011-11-10T15:02:25.657 に答える