首页 文章

serversocket上的客户端 - 服务器聊天程序问题

提问于
浏览
0

我正在做一个客户端服务器聊天项目 . 客户端A和客户端B应该连接到服务器 . 我可以将客户端A与服务器连接,但客户端B中出现问题 . 我想将客户端A和客户端B连接到服务器 . 客户端A成功连接 . 此外,我想与客户A和客户B进行沟通 . 但如果任何人帮助我,我会失败,我会真的很高兴 . 谢谢

String msgin = "";
try{
    ss= new ServerSocket(5000);
    s= ss.accept();
    din= new DataInputStream(s.getInputStream());
    dout= new DataOutputStream(s.getOutputStream());
    while(!msgin.equals("exit")) {
        msgin = din.readUTF();
        msg_area.setText(msg_area.getText().trim()+"\n Client A:\t"+msgin);
           }
}catch(IOException e){

}
String msgIn = "";
try{
    ss= new ServerSocket(6000);
    s= ss.accept();

    din= new DataInputStream(s.getInputStream());
    dout= new DataOutputStream(s.getOutputStream());
    while(!msgIn.equals("exit")) {
        msgIn = din.readUTF();
        msg_area.setText(msg_area.getText().trim()+"\n Clint B:\t"+msgIn);
           }
}catch(Exception e){

}

客户A.

java.awt.EventQueue.invokeLater(new Runnable() {
        public void run() {
            new MyClientSocket().setVisible(true);
        }
    });
     try{
        s = new Socket("127.0.0.1",5000);
        din = new DataInputStream(s.getInputStream());
        dout = new DataOutputStream(s.getOutputStream());
        String msgin="";
        while(!msgin.equals("exit")){
        msgin = din.readUTF();
        msg_area.setText(msg_area.getText().trim()+"\n Server:\t"+msgin);

        }

    }catch(Exception e){

}

客户B.

java.awt.EventQueue.invokeLater(new Runnable() {
        public void run() {
            new MyClientServerB().setVisible(true);
        }
    });

    try{
        s = new Socket("127.0.0.1",6000);

        din = new DataInputStream(s.getInputStream());
        dout = new DataOutputStream(s.getOutputStream());
        String msgIn="";
        while(!msgIn.equals("exit")){
        msgIn = din.readUTF();
        msg_area.setText(msg_area.getText().trim()+"\n Server:\t"+msgIn);

        }

    }catch(Exception e){

}

1 回答

  • 0

    为了允许多个客户端同时连接到服务器,您将需要使用多线程 . 尝试为每个连接的客户端创建一个新线程 . 服务器是长期运行的程序,因此它应该通过循环不断地监听新的客户端连接 .

    以下是您可能考虑尝试的逻辑:

    try {
            serverSocket = new ServerSocket(8080);
        } catch (IOException io) {
            io.printStackTrace();
    }
    
    while (true) {
    
            Socket clientSocket;
            try {
                clientSocket = serverSocket.accept();
            } catch (IOException io) {
                io.printStackTrace();
            }
    
            Thread t = new Thread(new Runnable() {
                 // handle each client independently 
            }
            t.start();
    
     }
    

相关问题