[网络协议]多线程TCP网络即时通讯项目

多线程TCP网络即时通讯项目

1、需求：

2、界面设计：

3、功能说明：

①.用户登录：

②.拉取在线用户列表：

③.无异常退出:

• 客户端结束线程，并向服务端发送message，关闭其在服务端所对应的线程，并释放资源

④.私聊：

⑤.群聊：

⑥.服务端推送消息：

• 服务端另外开启一个线程

⑦.离线留言：

• 维护离线消息队列

⑧.离线发送文件：

4、客户端项目结构：

5、客户端项目代码：

①.ClientConnectThread

package qqclient.service;

import qqcommon.Message;
import qqcommon.MessageType;

import java.io.*;
import java.net.Socket;

//客户端线程类
public class ClientConnectThread extends Thread {
    //    由于在业务逻辑上需要用到该线程对应的socket和user，因此定义为成员属性
//    持有与服务端通信的socket对象
    private Socket socket;

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

    //    获取当前线程对应的socket
    public Socket getSocket() {
        return socket;
    }


    //客户端的业务逻辑
    @Override
    public void run() {
        while (true) {
            try {
//                监听当前线程对应socket从服务端发来的信息，若无信息，则阻塞
                ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());//当客户端服务端退出时，线程卡阻塞在此处

                Message message = (Message) ois.readObject();
//                根据消息种类跳转
                switch (message.getMesType()) {
                    case MessageType.MESSAGE_RET_ONLINE_FRIEND://获取服务端返回的在线用户列表
                        //                    在线用户由服务端线程集合中获取，理论上一定不为空，至少为1个用户
                        String[] s = message.getContent().split(" ");
                        if (s.length > 0) {
                            System.out.println("\n===当前在线用户列表====");
                            for (int i = 0; i < s.length; i++) {
                                System.out.println("用户" + i + ": " + s[i]);
                            }
                        }
                        break;
                    case MessageType.MESSAGE_TO_ONE_MES://从服务端接收到私聊信息
                        System.out.println("\n用户" + message.getSender() + "对你说：" + message.getContent());
                        break;
                    case MessageType.MESSAGE_TO_ALL_MES://从服务端接收到群聊消息
                        System.out.println("\n用户" + message.getSender() + "群发了：" + message.getContent());
                        break;
                    case MessageType.MESSAGE_FILE_TO_ONE_MES://从服务端接收到文件消息
                        System.out.println("\n用户" + message.getSender() + "向你发送了文件：" + message.getFileName() + ",文件大小为：" + message.getFileSize()+"KB");
                        FileOutputStream fos = new FileOutputStream(new File(message.getFileDes(),message.getFileName()));
                        fos.write(message.getFileContent());//将文件字节数组写入到输出流中
                        System.out.println("文件传输完毕");
                        fos.close();//关闭文件输出流
                        break;
                    case MessageType.MESSAGE_SEVER_MES://服务端推送的消息
                        System.out.println("\n服务端向你推送了消息：" + message.getContent());
                        break;
                }
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
}

②.ManageClientConnectThread

package qqclient.service;

import java.util.concurrent.ConcurrentHashMap;


//客户端线程管理类
public class ManageClientConnectThread {
    //    用ConcurrentHashMap<String, ClientConnectThread>对客户端线程进行管理
    private static ConcurrentHashMap<String, ClientConnectThread> hsm = new ConcurrentHashMap<>(16);//初始容量为16

    /**
     * 将客户端对应的线程添加到集合中
     * @param userid 用户id
     * @param clientThread 客户端与服务端通讯的线程
     */
    public static void addClientConnectThread(String userid, ClientConnectThread clientThread){
        hsm.put(userid, clientThread);
    }

    /**
     * 获取用户对应的线程
     * @param userid 用户id
     * @return 用户正在执行的线程
     */
    public static ClientConnectThread getClientConnectThread(String userid){
        return hsm.get(userid);
    }


    /**
     * 从线程集合中移除用户对应线程
     * @param userid
     */
    public static void removeClientConnectThread(String userid){
        hsm.remove(userid);
    }
}

③.UserClientService

package qqclient.service;

import qqcommon.Message;
import qqcommon.MessageType;
import qqcommon.User;
import utils.Utility;

import java.io.*;
import java.net.InetAddress;
import java.net.Socket;

//用户在客户端涉及到的服务
public class UserClientService {

    //    当前服务持有socket和user属性，便于在其他服务中使用
    private Socket socket;
    private User user;

    //构造器
    public UserClientService() {

    }

    /**
     * 客户端退出，给服务端发送信息，释放资源
     */
    public void logout() {
        try {
            Message message = new Message();//创建信息对象
            message.setMesType(MessageType.MESSAGE_CLIENT_EXIT);//设置信息类型为客户端退出
            message.setSender(user.getId());//设置发送者
//            根据当前服务对应socket向服务端传输数据包
            ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
            oos.writeObject(message);
//            从客户端线程集合移除当前用户对应的线程
            ManageClientConnectThread.removeClientConnectThread(user.getId());
            System.out.println(user.getId() + "在客户端退出");
            System.exit(0);//进程结束指令，将会导致当前客户端运行的线程结束
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    /**
     * 获取在线用户列表，客户端向服务端发送数据包
     */
    public void getOnlineUsers() {
        try {
            Message message = new Message();//创建信息对象
            message.setMesType(MessageType.MESSAGE_GET_ONLINE_FRIEND);//设置信息类型为客户端获取在线用户列表
            message.setSender(user.getId());//设置发送者
//            根据当前服务对应socket向服务端传输数据包
            ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
            oos.writeObject(message);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }


    /**
     * 当前用户向服务端发送群聊消息
     */
    public void sendAllMessage() {
        System.out.println("请输入你要群发的消息：");
        String allMes = Utility.readString(100);
        try {
            Message message = new Message();//创建信息对象
            message.setMesType(MessageType.MESSAGE_TO_ALL_MES);//设置信息类型为客户端获取在线用户列表
            message.setSender(user.getId());//设置发送者
            message.setContent(allMes);//设置群聊消息的内容
//            根据当前服务对应socket向服务端传输数据包
            ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
            oos.writeObject(message);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }


    /**
     * 当前用户向服务端发送私聊消息
     */
    public void sendOneMessage() {
        System.out.print("请输入你要私聊的对象：");
        String receiver = Utility.readString(50);
        System.out.print("请输入私聊的内容：");
        String content = Utility.readString(100);
        try {
            Message message = new Message();//创建信息对象
            message.setMesType(MessageType.MESSAGE_TO_ONE_MES);//设置信息类型为客户端获取在线用户列表
            message.setSender(user.getId());//设置发送者
            message.setReceiver(receiver);//设置接收者
            message.setContent(content);//设置私聊消息的内容
//            根据当前服务对应socket向服务端传输数据包
            ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
            oos.writeObject(message);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    /**
     * 当前用户向服务端发送私聊消息
     */
    public void sendFileToOne() {
        System.out.print("请输入你发送文件的对象：");
        String receiver = Utility.readString(50);
        System.out.print("请输入发送文件的源路径：");
        String fileSrcPath = Utility.readString(100);
        System.out.print("请输入发送文件的目标路径：");
        String fileDesPath = Utility.readString(100);
        File file = new File(fileSrcPath);
        if (!file.exists()) {
            System.out.println("文件不存在");
            return;
        }

        try {
            byte[] bytes = new byte[(int) file.length()];
            FileInputStream fis = new FileInputStream(file);
            int fileSize = fis.read(bytes);//将文件内容读取到字节数组中，并获取文件字节数
            String fileName = fileSrcPath.substring(fileSrcPath.lastIndexOf("\\") + 1);

            Message message = new Message();//创建信息对象
            message.setFileSize(fileSize);//设置文件大小
            message.setFileSrc(fileSrcPath);//设置文件源路径
            message.setFileDes(fileDesPath);//设置文件目标路径
            message.setFileContent(bytes);//设置文件字节内容
            message.setFileName(fileName);//设置文件名


            message.setMesType(MessageType.MESSAGE_FILE_TO_ONE_MES);//设置信息类型为客户端发送文件
            message.setSender(user.getId());//设置发送者
            message.setReceiver(receiver);//设置接收者

//            根据当前服务对应socket向服务端传输数据包
            ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
            oos.writeObject(message);
        } catch (Exception e) {
            e.printStackTrace();
        }

    }


    /**
     * 用户登录校验，与服务端建立socket，获取服务端的校验结果
     *
     * @param userid
     * @param userpsw
     * @return
     */
    public boolean login(String userid, String userpsw) {
//         创建登录用的用户对象
        user = new User(userid, userpsw);
//         创建socket对象，第一次与服务端通信，传user去后端校验,可以指定通讯后端ip地址
        try {
            socket = new Socket(InetAddress.getByName("127.0.0.1"), 9999);

//          创建对象流
            ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
//          传输登录对象到服务端校验
            oos.writeObject(user);

//          接受后端的校验反馈
            ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());
            Message message = (Message) ois.readObject();

//          根据校验结果判断是否登录成功
            if (MessageType.MESSAGE_LOGIN_SUCCESS.equals(message.getMesType())) {//登录成功
//               创建客户端线程，用ConcurrentHashMap<String, ClientConnectThread>进行管理
                ClientConnectThread clientConnectThread = new ClientConnectThread(socket);
                //开启客户端线程
                clientConnectThread.start();
                //线程添加到集合中进行管理
                ManageClientConnectThread.addClientConnectThread(userid, clientConnectThread);
                return true;//返回登录成功
            } else {
                socket.close();
                return false;
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        return false;//返回登录失败
    }


}

④.QQView

package qqclient.view;

import qqclient.service.UserClientService;
import utils.Utility;

//显示界面
public class QQView {
    private boolean loop = true;//控制一级菜单是否循环
    private UserClientService userClientService = new UserClientService();//用于登录和注册等客户端服务


    public void mainMenu() {
        while (loop) {
            System.out.println("========欢迎登录网络通讯系统========");
            System.out.println("\t\t1.登录系统");
            System.out.println("\t\t9.退出系统");
            System.out.print("请输入你的选择：");
            switch (Utility.readString(1)) {
                case "1":
//                输入账号密码
                    System.out.print("请输入账号：");
                    String userid = Utility.readString(50);
                    System.out.print("请输入密码：");
                    String userpsw = Utility.readString(50);
//                        根据校验结果判断是否登录成功
                    if (userClientService.login(userid, userpsw)) {//登录成功
//                            进入二级菜单页面
                        System.out.println("========欢迎您， " + userid + " 登录成功========");
                        while (loop) {
                            System.out.println("========网络通信系统二级菜单(" + userid + ")========");
                            System.out.println("\t\t1.显示在线用户列表");
                            System.out.println("\t\t2.群发消息");
                            System.out.println("\t\t3.私聊消息");
                            System.out.println("\t\t4.发送文件");
                            System.out.println("\t\t9.退出系统");
                            System.out.print("请输入你的选择：");
                            switch (Utility.readString(1)) {
                                case "1":
                                    userClientService.getOnlineUsers();
                                    break;
                                case "2":
                                    userClientService.sendAllMessage();
                                    break;
                                case "3":
                                    userClientService.sendOneMessage();
                                    break;
                                case "4":
                                    userClientService.sendFileToOne();
                                    break;
                                case "9":
                                    userClientService.logout();
                                    loop = false;
                                    break;
                            }
                        }
                    } else {
                        System.out.println("登录失败");
                    }
                    break;
                case "9":
                    System.out.println("退出系统");
                    loop = false;//结束一级菜单循环
                    break;
            }
        }
    }
}

⑤.Message

package qqcommon;

import java.io.Serializable;

//通讯信息类
public class Message implements Serializable {
    private static final long serialVersionUID = 1L;//增加对象序列化的兼容性标记
    private String sender;//发送者
    private String receiver;//接受者
    private String content;//通讯内容
    private String time;//通讯时间
    private String mesType;//消息类型【可以在接口中定义】

//    文件相关属性
    private String fileSrc;//文件源路径
    private String fileDes;//文件目标路径
    private int fileSize;//文件字节数
    private String fileName;//文件名
    private byte[] fileContent;//文件字节内容

    public byte[] getFileContent() {
        return fileContent;
    }

    public void setFileContent(byte[] fileContent) {
        this.fileContent = fileContent;
    }



    public String getFileSrc() {
        return fileSrc;
    }

    public void setFileSrc(String fileSrc) {
        this.fileSrc = fileSrc;
    }

    public String getFileDes() {
        return fileDes;
    }

    public void setFileDes(String fileDes) {
        this.fileDes = fileDes;
    }

    public int getFileSize() {
        return fileSize;
    }

    public void setFileSize(int fileSize) {
        this.fileSize = fileSize;
    }

    public String getFileName() {
        return fileName;
    }

    public void setFileName(String fileName) {
        this.fileName = fileName;
    }

    public Message() {
    }

    public String getSender() {
        return sender;
    }

    public void setSender(String sender) {
        this.sender = sender;
    }

    public String getReceiver() {
        return receiver;
    }

    public void setReceiver(String receiver) {
        this.receiver = receiver;
    }

    public String getContent() {
        return content;
    }

    public void setContent(String content) {
        this.content = content;
    }

    public String getTime() {
        return time;
    }

    public void setTime(String time) {
        this.time = time;
    }

    public String getMesType() {
        return mesType;
    }

    public void setMesType(String mesType) {
        this.mesType = mesType;
    }
}

⑥.MessageType

package qqcommon;

public interface MessageType {
    String MESSAGE_LOGIN_SUCCESS = "1";//登录成功
    String MESSAGE_LOGIN_FAIL = "2";//登录失败
    String MESSAGE_TO_ONE_MES = "3";//私聊信息
    String MESSAGE_GET_ONLINE_FRIEND = "4";//获取在线用户列表
    String MESSAGE_RET_ONLINE_FRIEND = "5";//返回在线用户列表
    String MESSAGE_CLIENT_EXIT = "6";//客户端退出
    String MESSAGE_TO_ALL_MES = "7";//群发消息
    String MESSAGE_FILE_TO_ONE_MES = "8";//发送文件

    String MESSAGE_SEVER_MES = "9";//服务端推送的消息
}

⑦.User

package qqcommon;

import java.io.Serializable;

//登录用户的信息类
public class User implements Serializable {
    private static final long serialVersionUID = 1L;//增加对象序列化的兼容性标记
    private String id;//账号
    private String passWord;//密码



    public User(String id, String passWord) {
        this.id = id;
        this.passWord = passWord;
    }

    public User() {

    }

    public String getId() {
        return id;
    }

    public void setId(String id) {
        this.id = id;
    }

    public String getPassWord() {
        return passWord;
    }

    public void setPassWord(String passWord) {
        this.passWord = passWord;
    }
}

⑧.QQFrame

package qqframe;

import qqclient.view.QQView;

public class QQFrame {
    public static void main(String[] args) {
        new QQView().mainMenu();//开启窗口
    }
}

⑨.Utility

package utils;


/**
   工具类的作用:
   处理各种情况的用户输入，并且能够按照程序员的需求，得到用户的控制台输入。
*/

import java.util.Scanner;

/**

   
*/
public class Utility {
   //静态属性。。。
    private static Scanner scanner = new Scanner(System.in);

    
    /**
     * 功能：读取键盘输入的一个菜单选项，值：1——5的范围
     * @return 1——5
     */
   public static char readMenuSelection() {
        char c;
        for (; ; ) {
            String str = readKeyBoard(1, false);//包含一个字符的字符串
            c = str.charAt(0);//将字符串转换成字符char类型
            if (c != '1' && c != '2' && 
                c != '3' && c != '4' && c != '5') {
                System.out.print("选择错误，请重新输入：");
            } else break;
        }
        return c;
    }

   /**
    * 功能：读取键盘输入的一个字符
    * @return 一个字符
    */
    public static char readChar() {
        String str = readKeyBoard(1, false);//就是一个字符
        return str.charAt(0);
    }
    /**
     * 功能：读取键盘输入的一个字符，如果直接按回车，则返回指定的默认值；否则返回输入的那个字符
     * @param defaultValue 指定的默认值
     * @return 默认值或输入的字符
     */
    
    public static char readChar(char defaultValue) {
        String str = readKeyBoard(1, true);//要么是空字符串，要么是一个字符
        return (str.length() == 0) ? defaultValue : str.charAt(0);
    }
   
    /**
     * 功能：读取键盘输入的整型，长度小于2位
     * @return 整数
     */
    public static int readInt() {
        int n;
        for (; ; ) {
            String str = readKeyBoard(10, false);//一个整数，长度<=10位
            try {
                n = Integer.parseInt(str);//将字符串转换成整数
                break;
            } catch (NumberFormatException e) {
                System.out.print("数字输入错误，请重新输入：");
            }
        }
        return n;
    }
    /**
     * 功能：读取键盘输入的 整数或默认值，如果直接回车，则返回默认值，否则返回输入的整数
     * @param defaultValue 指定的默认值
     * @return 整数或默认值
     */
    public static int readInt(int defaultValue) {
        int n;
        for (; ; ) {
            String str = readKeyBoard(10, true);
            if (str.equals("")) {
                return defaultValue;
            }
         
         //异常处理...
            try {
                n = Integer.parseInt(str);
                break;
            } catch (NumberFormatException e) {
                System.out.print("数字输入错误，请重新输入：");
            }
        }
        return n;
    }

    /**
     * 功能：读取键盘输入的指定长度的字符串
     * @param limit 限制的长度
     * @return 指定长度的字符串
     */

    public static String readString(int limit) {
        return readKeyBoard(limit, false);
    }

    /**
     * 功能：读取键盘输入的指定长度的字符串或默认值，如果直接回车，返回默认值，否则返回字符串
     * @param limit 限制的长度
     * @param defaultValue 指定的默认值
     * @return 指定长度的字符串
     */
   
    public static String readString(int limit, String defaultValue) {
        String str = readKeyBoard(limit, true);
        return str.equals("")? defaultValue : str;
    }


   /**
    * 功能：读取键盘输入的确认选项，Y或N
    * 将小的功能，封装到一个方法中.
    * @return Y或N
    */
    public static char readConfirmSelection() {
        System.out.println("请输入你的选择(Y/N): 请小心选择");
        char c;
        for (; ; ) {//无限循环
           //在这里，将接受到字符，转成了大写字母
           //y => Y n=>N
            String str = readKeyBoard(1, false).toUpperCase();
            c = str.charAt(0);
            if (c == 'Y' || c == 'N') {
                break;
            } else {
                System.out.print("选择错误，请重新输入：");
            }
        }
        return c;
    }

    /**
     * 功能： 读取一个字符串
     * @param limit 读取的长度
     * @param blankReturn 如果为true ,表示 可以读空字符串。 
     *                   如果为false表示 不能读空字符串。
     *           
    * 如果输入为空，或者输入大于limit的长度，就会提示重新输入。
     * @return
     */
    private static String readKeyBoard(int limit, boolean blankReturn) {
        
      //定义了字符串
      String line = "";

      //scanner.hasNextLine() 判断有没有下一行
        while (scanner.hasNextLine()) {
            line = scanner.nextLine();//读取这一行
           
         //如果line.length=0, 即用户没有输入任何内容，直接回车
         if (line.length() == 0) {
                if (blankReturn) return line;//如果blankReturn=true,可以返回空串
                else continue; //如果blankReturn=false,不接受空串，必须输入内容
            }

         //如果用户输入的内容大于了 limit，就提示重写输入  
         //如果用户如的内容 >0 <= limit ,我就接受
            if (line.length() < 1 || line.length() > limit) {
                System.out.print("输入长度（不能大于" + limit + "）错误，请重新输入：");
                continue;
            }
            break;
        }

        return line;
    }
}

6、服务端项目结构：

7、服务端项目代码：

①.与客户端共有的类省略：

• Message
• MessageType
• User
• Utility

②.QQFrame

package qqframe;

import qqserver.service.QQServer;

public class QQFrame {
    public static void main(String[] args) {
        new QQServer();//开启服务端服务
        System.out.println("服务端退出");
    }
}

③.ManageServerConnectThread

package qqserver.service;

import java.util.concurrent.ConcurrentHashMap;

// 服务端线程管理类
public class ManageServerConnectThread {

//    用集合管理
        private static ConcurrentHashMap<String, ServerConnectThread> hsm = new ConcurrentHashMap<>(16);


        public static ConcurrentHashMap<String, ServerConnectThread> getHsm() {
                return hsm;
        }

        /**
         * 添加服务端线程到集合中
         * @param userid
         * @param sct
         */
        public static void addServerConnectThread(String userid, ServerConnectThread sct){
                hsm.put(userid,sct);
        }

        /**
         * 获取服务端对应的线程
         * @param userid
         * @return
         */
        public static ServerConnectThread getServerConnectThread(String userid){
                return hsm.get(userid);
        }


        /**
         * 将用户在服务端对应的线程从集合中移除
         * @param userid
         */
        public static void removeUserThread(String userid){
                hsm.remove(userid);
        }
}

④.QQServer

package qqserver.service;

import qqcommon.Message;
import qqcommon.MessageType;
import qqcommon.User;

import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Enumeration;
import java.util.Iterator;
import java.util.concurrent.ConcurrentHashMap;

//客户端服务
public class QQServer {
    private ServerSocket serverSocket = null;
    //    构造器
    public QQServer() {
        try {
//            监听本机的9999端口
            serverSocket = new ServerSocket(9999);
            System.out.println("服务端启动，监听本机的9999端口");
            new SendServerMessageThread().start();//开启服务端消息推送服务
//            循环监听
            while (true) {
//                如果客户端有连接服务端的此端口，则会创建socket对象，否则服务端会阻塞
                Socket socket = serverSocket.accept();
//                获取客户端发来的user对象
                ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());
                User user = (User) ois.readObject();
//                 创建校验登录反馈的Message
                Message message = new Message();

//                校验登录的用户
                if (checkUser(user)) {//用户信息校验成功
                    message.setMesType(MessageType.MESSAGE_LOGIN_SUCCESS);
                } else {
                    message.setMesType(MessageType.MESSAGE_LOGIN_FAIL);
                }
                //                    反馈用户登录校验结果
                ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
                oos.writeObject(message);

//                登录成功的业务逻辑
                if (MessageType.MESSAGE_LOGIN_SUCCESS.equals(message.getMesType())) {
//                创建服务端的线程
                    ServerConnectThread serverConnecThread = new ServerConnectThread(socket);
                    serverConnecThread.start();//开启服务端线程
//                    将服务端线程添加到集合中进行管理
                    ManageServerConnectThread.addServerConnectThread(user.getId(), serverConnecThread);
                }else{
                    socket.close();//登录失败，关闭socket
                }
            }

        } catch (Exception e) {
            e.printStackTrace();
        }finally {
            try {
                serverSocket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

    //    用集合模拟用户数据库,存储数据表中的用户的账号和密码
    private static ConcurrentHashMap<String, String> users = new ConcurrentHashMap<>(16);

    static {
        users.put("100", "123456");
        users.put("200", "123456");
        users.put("300", "123456");
        users.put("400", "123456");
        users.put("哈哈", "123456");
    }

    /**
     * 校验要登录的用户是否存在
     *
     * @param user
     * @return 校验结果
     */
    public boolean checkUser(User user) {
        if (user == null) {
            return false;
        } else if (users.get(user.getId()) == null) {
            System.out.println("用户：" + user.getId() + " 不存在");
            return false;
        } else if (!users.get(user.getId()).equals(user.getPassWord())) {
            System.out.println("用户：" + user.getId() + " 的密码校验错误");
            return false;
        }
        System.out.println("用户：" + user.getId() + " 登录成功");
        return true;
    }


    /**
     * 由线程集合获取在线用户列表
     * @return
     */
    public static String getOnlineUser() {
        Enumeration<String> userids = ManageServerConnectThread.getHsm().keys();
        Iterator<String> it = userids.asIterator();
        StringBuilder str = new StringBuilder();
        while (it.hasNext()) {
            str.append(it.next() + " ");
        }
        return new String(str);//返回在线用户列表，用户之间由空格分隔
    }


}

⑤.SendServerMessageThread

package qqserver.service;

import qqcommon.Message;
import qqcommon.MessageType;
import utils.Utility;

import java.io.IOException;
import java.io.ObjectOutputStream;
import java.util.Collection;
import java.util.Iterator;

public class SendServerMessageThread extends Thread {

    @Override
    public void run() {
        while (true) {
            System.out.println("是否推送消息(Y/N),输入exit退出消息推送服务：");
            String isSendMes = Utility.readString(10);
            if ("Y".equals(isSendMes) || "y".equals(isSendMes)) {
                System.out.print("请输入服务端要推送的消息内容：");
                String content = Utility.readString(100);
                Message message1 = new Message();//服务端要发送回客户端的message1
                message1.setMesType(MessageType.MESSAGE_SEVER_MES);//设置推送消息的类型
                message1.setContent(content);//设置推送消息的内容

                ObjectOutputStream oos;
                Collection<ServerConnectThread> threads = ManageServerConnectThread.getHsm().values();//获取在线用户的所有线程
                Iterator<ServerConnectThread> it = threads.iterator();//在线用户线程集合
                while (it.hasNext()) {//遍历线程集合
                    try {
                        oos = new ObjectOutputStream(it.next().getSocket().getOutputStream());
                        oos.writeObject(message1);
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                }
                System.out.println("向" + threads.size() + "个在线用户推送了消息");
            } else if ("exit".equals(isSendMes)) {
                System.out.println("消息推送服务关闭");
                break;//服务推送线程
            }
        }
    }
}

⑥.ServerConnectThread

package qqserver.service;

import qqcommon.Message;
import qqcommon.MessageType;

import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.Socket;
import java.util.Collection;
import java.util.Iterator;

//服务端线程
public class ServerConnectThread extends Thread {
    //    持有服务端socket对象
    private Socket socket;

    //    线程的构造器
    public ServerConnectThread(Socket socket) {
        this.socket = socket;
    }

    /**
     * 获取服务端对应的socket
     *
     * @return
     */
    public Socket getSocket() {
        return socket;
    }


    //    服务端的业务逻辑
    @Override
    public void run() {
        boolean loop = true;
        while (loop) {
            try {
//                获取客户端发来的数据
                ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());
                Message message = (Message) ois.readObject();
//                根据消息种类跳转
                Message message1 = new Message();//服务端要发送回客户端的message
                ObjectOutputStream oos;
                switch (message.getMesType()) {
                    case MessageType.MESSAGE_GET_ONLINE_FRIEND://客户端要在线用户列表
                        System.out.println("用户 " + message.getSender() + " 要在线用户列表");
                        message1.setMesType(MessageType.MESSAGE_RET_ONLINE_FRIEND);//设置信息类型
                        message1.setContent(QQServer.getOnlineUser());//设置信息内容为在线用户列表
                        oos = new ObjectOutputStream(socket.getOutputStream());//向当前线程对应客户端回送消息
                        oos.writeObject(message1);//向客户端传输数据
                        break;
                    case MessageType.MESSAGE_TO_ONE_MES://私聊信息
                        System.out.println("用户 " + message.getSender() + " 向用户" + message.getReceiver() + "私聊了消息：" + message.getContent());
                        message1.setMesType(MessageType.MESSAGE_TO_ONE_MES);//设置信息类型
                        message1.setContent(message.getContent());//设置信息内容为要转发的消息内容
                        message1.setSender(message.getSender());//设置私聊信息发送者
                        message1.setReceiver(message.getReceiver());//设置私聊信息接收者（可省略）
//                        找到接收者对应线程中的socket，创建输出流发送(可能对应用户不存在，可以空处理)
                        ServerConnectThread receiverThread1 = ManageServerConnectThread.getServerConnectThread(message.getReceiver());
                        if (receiverThread1 == null) {
                            System.out.println("用户" + message.getReceiver() + " 不存在，私聊失败");
                        } else {
                            oos = new ObjectOutputStream(receiverThread1.getSocket().getOutputStream());
                            oos.writeObject(message1);//向客户端传输数据
                        }
                        break;
                    case MessageType.MESSAGE_TO_ALL_MES://群聊消息
                        System.out.println("用户 " + message.getSender() + " 其他用户群发了消息：" + message.getContent());
                        message1.setMesType(MessageType.MESSAGE_TO_ALL_MES);//设置群里消息的类型
                        message1.setSender(message.getSender());//设置群里消息的发送者
                        message1.setContent(message.getContent());//设置群里消息的内容
                        Collection<ServerConnectThread> threads = ManageServerConnectThread.getHsm().values();//获取在线用户的所有线程
                        ServerConnectThread senderThread = ManageServerConnectThread.getServerConnectThread(message.getSender());//发送者的线程
                        Iterator<ServerConnectThread> it = threads.iterator();//在线用户线程集合
                        ServerConnectThread receiverThread = null;//接收者的线程
                        while (it.hasNext()) {//遍历线程集合
                            receiverThread = it.next();
                            if (receiverThread != senderThread) {//除去当前用户对应线程，其他线程群发消息
                                oos = new ObjectOutputStream(receiverThread.getSocket().getOutputStream());
                                oos.writeObject(message1);
                            }
                        }
                        break;
                    case MessageType.MESSAGE_FILE_TO_ONE_MES://文件消息
                        System.out.println("用户" + message.getSender() + " 向 用户" + message.getReceiver() + "发送了文件" + message.getFileName() + ",文件大小为：" + message.getFileSize() + "KB");
                        message1.setMesType(MessageType.MESSAGE_FILE_TO_ONE_MES);//设置消息类型为文件
                        message1.setFileContent(message.getFileContent());//设置文件字节内容
                        message1.setFileSrc(message.getFileSrc());//设置文件源路径
                        message1.setFileDes(message.getFileDes());//设置文件目标路径
                        message1.setFileSize(message.getFileSize());//设置文件大小
                        message1.setSender(message.getSender());//设置发送者
                        message1.setReceiver(message.getReceiver());//设置接收者
                        message1.setFileName(message.getFileName());//设置文件名
                        //                        找到接收者对应线程中的socket，创建输出流发送(可能对应用户不存在，可以空处理)
                        ServerConnectThread receiverThread2 = ManageServerConnectThread.getServerConnectThread(message.getReceiver());
                        if (receiverThread2 == null) {
                            System.out.println("用户" + message.getReceiver() + " 不存在，文件发送失败");
                        } else {
                            oos = new ObjectOutputStream(receiverThread2.getSocket().getOutputStream());
                            oos.writeObject(message1);//向客户端传输数据
                        }
                        break;
                    case MessageType.MESSAGE_CLIENT_EXIT://客户端要退出
                        System.out.println(message.getSender() + "在服务端退出");
                        ManageServerConnectThread.removeUserThread(message.getSender());//移除线程
                        socket.close();
                        loop = false;//退出当前线程
                        break;
                }

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

B站韩顺平教程
服务端源码：https://gitee.com/Kevin_Hunter/Java-TCP
客户端源码：https://gitee.com/Kevin_Hunter/Java-TCP-Client