【问题标题】:Java client-server chat application: Weird problems with communicationJava 客户端-服务器聊天应用程序:奇怪的通信问题
【发布时间】:2016-06-18 16:52:20
【问题描述】:

我正在使用套接字在 Java 中创建一个聊天应用程序。我遇到了一些我以前从未遇到过的奇怪问题。首先是服务端类:

这是我的服务器类。如果我提供了不需要的代码,请原谅我,但是看到我的问题的性质,我想给你们完整的信息。

服务器类:

public class Server implements Runnable
{   
    private final static int port=8000;
    private static Set<Socket> socs=new HashSet<>();
    private static Thread t1;
    private static BufferedReader br;
    private static PrintWriter ps;
    private static Socket socketClient;
    private static String message;
    private static HashSet<String> users=new HashSet<>();
    private static HashMap<Socket,String> socket_id=new HashMap<>();
    private static HashMap<String,String> id_name=new HashMap<>();

public Server()
{
    try {

        ServerSocket socket=new ServerSocket(port);
        while(true)
        {System.out.println("Waiting for connections...");
        socketClient=socket.accept();
        System.out.println("Connected to user at: "+socketClient.getInetAddress());
        socs.add(socketClient);
        t1=new Thread(this);
        t1.start();     //to receive data

        }
    } catch (IOException e) {

        e.printStackTrace();
    }
}
//registration for the client
public void registration(String name,String id) throws IOException
{   
if(users.contains(name))
    {
        ps=new PrintWriter(socketClient.getOutputStream());
         ps.println("duplicate"+"\n");
         ps.flush();
    }
    else
     {
    users.add(name);
    socket_id.put(socketClient,id);
    id_name.put(id,name);
    }
}

    public void run() {
    int count=0;
    try {
        br=new BufferedReader(new InputStreamReader(socketClient.getInputStream()));
        do
        {
        message=br.readLine();
        if(count==0)
        {
            UUID id=UUID.randomUUID();
            String id_client=id.toString();
            registration(message.substring(0,message.indexOf(':')),id_client);
            count++;
        }
        for(Socket s:socs)
            {
            ps=new PrintWriter(s.getOutputStream());
            ps.println(message+"\n");
            ps.flush();
            }
        }while(br.readLine()!=null);
    }
    catch(SocketException e)
    {   
        System.out.println("A user left");


    }
    catch (IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }




}
    public static void main(String args[])
    {
    Server server=new Server();
    }


}

这是我的客户端类的发送和接收函数:

private void send_data()  {

    if(textField.getText().length()!=0)
    {   if(textField.getText().equals("!clear")) //command to clear the chat histroy
        {
        textArea.setText("");
        textField.setText("");
        }
        else
        {   
        ps.println(this.name+": "+textField.getText()+"\n");
        ps.flush();
        }
    }


}


public  void receive_data(){
    try {
        br=new BufferedReader(new InputStreamReader(socket.getInputStream()));
        do
        {   String message=br.readLine();
            if(message.length()!=0)
            console(message);
        }while(br.readLine()!=null);

    } catch (IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }


}

//这个函数检查重复的用户名。

public void check() throws IOException
{
    BufferedReader b=new BufferedReader(new InputStreamReader(socket.getInputStream()));
    if(b.readLine().equals("duplicate"))
    {   JOptionPane.showMessageDialog(null, "Username taken");
        socket.close();
        b.close();
        dispose();
        new Login().setVisible(true);

    }
}

现在,问题来了:

1.当第一个客户端连接时,一切正常。消息按预期显示到控制台。

2.当第二个用户加入时,第一个用户无法向服务器发送任何消息。最新的客户端运行顺利,但之前连接的所有客户端根本无法向服务器发送任何消息。或者服务器可能没有将消息转发给他们。

3.当用户被告知用户名已被使用并被发送回登录屏幕时,所有其他客户端的聊天记录开始显示为空。

4.客户端发送给服务器的第一条消息没有显示在聊天记录中。从第二条消息开始,一切正常,直到任何其他客户端连接。

请提前帮助和感谢。这个问题已经困扰我很长一段时间了,尽管尝试了很多次,但我无法调试它。

有什么建议吗?

【问题讨论】:

    标签: java sockets client-server chat


    【解决方案1】:
    private static Socket socketClient;
    

    问题就在这里。该数据项不应该是静态的,并且根本不应该在Server 类中。它应该在另一个类中,通常是 Runnable,每个接受的客户端都会对其进行实例化,并用作相应线程的基础。

    关联的流和任何其他每个客户端的状态也是如此。

    这些非最终数据项实际上没有任何充分的理由是静态的。除非您知道原因,否则不要让事情变得一成不变。

    【讨论】:

    • 我会试一试告诉你。
    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 2016-11-07
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2014-05-17
    相关资源
    最近更新 更多