class Handler implements Runnable {
    private Socket socket;

    public Handler(Socket socket) {
        this.socket = socket;
    }

    public void run() {
        //本地服务器控制台显示客户端连接的用户信息
        System.out.println("New connection accept:" + socket.getInetAddress().getHostAddress());
        try {
            BufferedReader br = getReader(socket);
            PrintWriter pw = getWriter(socket);

            pw.println("From 服务器：欢迎使用服务！");
            pw.println("请输入用户名：");
            String localName = null;
            while ((hostName=br.readLine())!=null){
                users.forEach((k,v)->{
                    if (v.equals(hostName))
                        flag=true;//线程修改了全局变量
                });

                if (!flag){
                    localName=hostName;
                    users.put(socket,hostName);
                    flag=false;//可能找出不一致问题
                    break;
                }
                else{
                    flag=false;
                    pw.println("该用户名已存在，请修改！");
                }
            }

//                System.out.println(hostName+": "+socket);
            sendToMembers("我已上线",localName,socket);
            pw.println("输入命令功能：(1)L(list):查看当前上线用户;(2)G(group):进入群聊;(3)O(one-one):私信;(4)E(exit):退出当前聊天状态;(5)bye:离线;(6)H(help):帮助");

            String msg = null;
            //用户连接服务器上线，进入聊天选择状态
            while ((msg = br.readLine()) != null) {
                if (msg.trim().equalsIgnoreCase("bye")) {
                    pw.println("From 服务器：服务器已断开连接，结束服务！");

                    users.remove(socket,localName);

                    sendToMembers("我下线了",localName,socket);
                    System.out.println("客户端离开。");//加当前用户名
                    break;
                }
                else if (msg.trim().equalsIgnoreCase("H")){
                    pw.println("输入命令功能：(1)L(list):查看当前上线用户;(2)G(group):进入群聊;(3)O(one-one):私信;(4)E(exit):退出当前聊天状态;(5)bye:离线;(6)H(help):帮助");
                    continue;//返回循环
                }
                else if (msg.trim().equalsIgnoreCase("L")){
                    users.forEach((k,v)->{
                        pw.println("用户:"+v);
                    });
                    continue;
                }
                //一对一私聊
                else if (msg.trim().equalsIgnoreCase("O")){
                    pw.println("请输入私信人的用户名：");
                    String name=br.readLine();

                    //查找map中匹配的socket，与之建立通信
                    users.forEach((k, v)->{
                        if (v.equals(name)) {
                            isExist=true;//全局变量与线程修改问题
                        }

                    });
                    //已修复用户不存在的处理逻辑
                    Socket temp=null;
                    for(Map.Entry<Socket,String> mapEntry : users.entrySet()){
                        if(mapEntry.getValue().equals(name))
                            temp = mapEntry.getKey();
                    }
                    if (isExist){
                        isExist=false;
                        //私信后有一方用户离开，另一方未知，仍然发信息而未收到回复，未处理这种情况
                        while ((msg=br.readLine())!=null){
                            if (!msg.equals("E")&&!isLeaved(temp))
                                sendToOne(msg,localName,temp);
                            else if (isLeaved(temp)){
                                pw.println("对方已经离开，已断开连接！");
                                break;
                            }
                            else{
                                pw.println("您已退出私信模式！");
                                break;
                            }
                        }
                    }
                    else
                        pw.println("用户不存在！");
                }
                //选择群聊
                else if (msg.trim().equals("G")){
                    pw.println("您已进入群聊。");
                    while ((msg=br.readLine())!=null){
                        if (!msg.equals("E")&&users.size()!=1)
                            sendToMembers(msg,localName,socket);
                        else if (users.size()==1){
                            pw.println("当前群聊无其他用户在线，已自动退出！");
                            break;
                        }
                        else {
                            pw.println("您已退出群组聊天室！");
                            break;
                        }
                    }

                }
                else
                    pw.println("请选择聊天状态！");
            }
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            try {
                if (socket != null)
                    socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

六、效果演示：基于TCP的网络实时聊天室

首先，开启多个客户端，连接服务器开始进入通信状态。

下面动图演示了几个基本功能，可以看到三个用户实现了实时通信聊天，包括群聊和私聊功能。其他功能就留给大家去探索。

结语

系列文章从入门开始，不断完善C/S架构的Socket通信，回忆一下，首先是实现了Server和Client的互相通信，在这个过程发现问题，接着就使用多线程技术解决客户端实时接收信息的问题，后来到了服务器端，发现多用户连接服务器的“先到先得”问题，“后到者”无法正常通信，所以再使用线程池技术解决了多用户服务器的问题。

本篇基本实现了一个简单的客户端-服务器应用，使用客户端-服务器（C/S架构），结合多线程技术，模拟类似QQ、微信聊天功能，实现一个网络实时聊天室。

学习到的知识有：多线程、线程池、Socket通信、TCP协议、HashMap、JavaFX等，所有知识的结合运用，并通过实战练习，一步步理解知识！

如果觉得不错欢迎“一键三连”哦，点赞收藏关注，有问题直接评论，交流学习！

Java实现socket通信网络编程系列文章：

1. 基于UDP协议网络Socket编程(java实现C/S通信案例)【https://blog.csdn.net/Charzous/article/details/109016215】
2. 基于TCP协议网络socket编程(java实现C/S通信)【https://blog.csdn.net/Charzous/article/details/109016215】
3. Java多线程实现TCP网络Socket编程(C/S通信)【https://blog.csdn.net/Charzous/article/details/109283697】
4. Java多线程实现多用户与服务端Socket通信【https://blog.csdn.net/Charzous/article/details/109440277】

我的CSDN博客：https://blog.csdn.net/Charzous/article/details/109540279