0基础学java-day22(多用户即时通信系统）

一、QQ 聊天项目演示

?在运运行过程出现的异常，应该是类的序列化不一致导致的

1 项目 QQ 演示

?

2 为什么选择这个项目?

只做核心部分，界面相对弱化

3?项目开发流程?

?3.1?需求分析

3.2??界面设计?

3.2.1 用户登录?

?3.2.2 拉取在线用户列表

3.2.3私聊?

?3.2.4 群聊

3.2.5 发文件?

3.2.6 文件服务器推送新闻?

二、功能实现

?1.功能实现-用户登录

?

2.功能实现-拉取在线用户列表

思路：客户端向服务器发送消息，消息类型为拉取在线用户列表，服务器识别，返回线程管理集合中的所有用户ID，并会回送给客户端，客户端接收后向用户输出

?

3 功能实现-无异常退出

4?功能实现-私聊

5.功能实现-群聊

群聊思路跟私聊差不多，就是在私聊的代码上更改，遍历服务器管理的线程集合【排除自己就欧克】?

6 功能说明-发文件

7?功能实现-服务器推送新闻

三、代码

服务端

1.【package com.hspedu.qq.service;】?

1.1【class ManageClientThreads】

package com.hspedu.qq.service;

import java.util.HashMap;
import java.util.Set;

/**
 * @author 林然
 * @version 1.0
 * 管理和客户端通讯的线程
 */
public class ManageClientThreads {
    private static HashMap<String,ServerConnnectClientThread> hm=new HashMap<>();
    //添加线程对象到hm集合
    public static void add_(String userId,ServerConnnectClientThread serverConnnectClientThread){
        hm.put(userId,serverConnnectClientThread);

    }
    //获取 根据一个userid获取对应的线程
    public static ServerConnnectClientThread get_Thread(String userId){
        return hm.get(userId);
    }
    //从集合中移除某个线程对象
    public static void remove_Thread(String userId){
        hm.remove(userId);
    }
    //编写一个方法，返回在线用户列表
    public static String getOnlineUsers(){
        Set<String> keys=hm.keySet();
        String onlineUserList="";
        for (Object key:keys){
            onlineUserList+=key+" ";
        }
        return onlineUserList;
    }
}

1.2【class QQServer】

package com.hspedu.qq.service;



import com.hspedu.qqcommon.*;


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

/**
 * @author 林然
 * @version 1.0
 * 这是服务器，在监听9999端口，等待客户端的连接，并保持通讯
 */
public class QQServer {
    private ServerSocket serverSocket =null;
    //创建一个集合，存放多个用户，如果是这些用户登录就认为是合法的
    //这里我们也可以使用concurrentHashMap,可以处理并发的集合，
    // HashMap没有线程安全,因此在多线程情况下不安全

    private static ConcurrentHashMap<String,User> vaildUsers =new ConcurrentHashMap<>();
    static {//在静态代码块初始化vaildUsers
        vaildUsers.put("100",new User("100","123456"));
        vaildUsers.put("200",new User("200","123456"));
        vaildUsers.put("300",new User("300","123456"));
        vaildUsers.put("至尊宝",new User("至尊宝","123456"));
        vaildUsers.put("紫霞仙子",new User("紫霞仙子","123456"));
        vaildUsers.put("菩提老祖",new User("菩提老祖","123456"));
    }
    //验证用户是否有效的方法
    private boolean checkUser(String userId,String passwd){
        User user = vaildUsers.get(userId);
        if(user==null){
            //说明userId没有存在
            return false;
        }
        if(!(user.getPassword().equals(passwd))){
            return false;
        }
        return true;
    }
    public QQServer(){
        System.out.println("服务器在9999端口监听。。。。。");

        try {
            sendNewsToall sendNewsToall = new sendNewsToall();
            new Thread(sendNewsToall).start();
            serverSocket=new ServerSocket(9999);
            while (true){//当和某个客户端会继续监听，因此使用while循环
                Socket socket= serverSocket.accept();//如果没有客户端连接，就会阻塞
                //得到socket关联的对象输入流
                ObjectInputStream objectInputStream = new ObjectInputStream(socket.getInputStream());
                User user=(User)objectInputStream.readObject();//读取相关的对象输入流
                //得到socket对象关联的输出流
                ObjectOutputStream objectOutputStream = new ObjectOutputStream(socket.getOutputStream());
                //创建一个message对象。准备回复客户端
                Message message =new Message();
                 //验证
                if(checkUser(user.getUserid(),user.getPassword())){
                    //登录成功
                    message.setMessageType(MessageType.MESSAGE_LOGIN_SUCCEED);
                    //将message对象回复客户端
                    objectOutputStream.writeObject(message);
                    //创建一个线程和客户端保持通讯，该线程需要持有socket对象
                    ServerConnnectClientThread serverConnnectClientThread = new ServerConnnectClientThread(socket, user.getUserid());
                    serverConnnectClientThread.start();
                    //将线程对象加入到集合中进行管理
                    ManageClientThreads.add_(user.getUserid(),serverConnnectClientThread);
                }else {
                    //登录失败
                    System.out.println("用户 id="+user.getUserid()+"  pw="+user.getPassword()+"验证失败");
                    message.setMessageType(MessageType.MESSAGE_LOGIN_FAIL);
                    //将message对象回复客户端
                    objectOutputStream.writeObject(message);
                    //关闭socket
                    socket.close();
                }


            }

        } catch (IOException | ClassNotFoundException e) {
            e.printStackTrace();
        }finally {
            try {//如果服务端退出while，那么说明服务端不在监听，因此关闭serverSocket
                serverSocket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

1.3【class sendNewsToall】

package com.hspedu.qq.service;


import com.hspedu.qqcommon.*;

import com.hspedu.utils.Utility;

import java.io.IOException;
import java.io.ObjectOutputStream;
import java.util.Date;
import java.util.Scanner;

/**
 * @author 林然
 * @version 1.0
 */
public class sendNewsToall implements Runnable {
    private Scanner scanner =new Scanner(System.in);

    @Override
    public void run() {
        while (true){
            System.out.println("请输入服务器要发送的新闻/消息【输入exit】表示退出推送服务");
            String news = Utility.readString(1000);
            //构建一个消息，群发消息
            if(news.equals("exit")){
                System.out.println("推送服务已关闭");
                break;
            }
            Message message =new Message();
            message.setSender("服务器");
            message.setContent(news);
            message.setSendTime(new Date().toString());
            message.setMessageType(MessageType.MESSAGE_ALL_MES);
            System.out.println("服务器推送消息："+news);

            //遍历
            String [] userList =ManageClientThreads.getOnlineUsers().split(" ");
            for(int i=0;i<userList.length;i++)
            {
                try {
                    ObjectOutputStream objectOutputStream =new ObjectOutputStream
                            (ManageClientThreads.get_Thread(userList[i]).getSocket().getOutputStream());
                    objectOutputStream.writeObject(message);
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }


        }
    }
}

1.4【class ServerConnnectClientThread】

package com.hspedu.qq.service;


import com.hspedu.qqcommon.*;
import com.hspedu.qqcommon.MessageType;

import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.Socket;

/**
 * @author 林然
 * @version 1.0
 * 该类对应的对象和某个客户端保持通讯
 */
public class ServerConnnectClientThread extends Thread{

    private Socket socket;
    private String useId;//连接到服务端的用户id

    public ServerConnnectClientThread(Socket socket, String useId) {
        this.socket = socket;
        this.useId = useId;
    }

    public Socket getSocket() {
        return socket;
    }

    @Override
    public void run() {//线程处于run的状态，可以发送/接收消息
        while (true){
            System.out.println("服务端和客户端"+useId+"保持通讯，读取数据.....");
            try {
                ObjectInputStream objectInputStream = new ObjectInputStream(socket.getInputStream());
                Message message=(Message) objectInputStream.readObject();

                if(message.getMessageType().equals(MessageType.MESSAGE_GET_ONLINE_FRIEND)){
                    //客户端需要在线用户列表
                    System.out.println(message.getSender()+"需要在线用户列表");
                    String onlineFriendList =ManageClientThreads.getOnlineUsers();
                    Message rs =new Message();
                    rs.setContent(onlineFriendList);
                    rs.setMessageType(MessageType.MESSAGE_RETURN_ONLINE_FRIEND);
                    rs.setGetter("服务端");
                    //写入到数据通道返回给客户端
                    ObjectOutputStream objectOutputStream = new ObjectOutputStream(socket.getOutputStream());
                    objectOutputStream.writeObject(rs);

                }else if(message.getMessageType().equals(MessageType.MESSAGE_CLIENT_EXIT)){
                    System.out.println(message.getSender()+"退出系统");
                    //将客户端对应的线程，从集合删除
                    ManageClientThreads.remove_Thread(useId);
                    socket.close();
                    //退出线程
                    break;
                }else if(message.getMessageType().equals(MessageType.MESSAGE_COMM_MES)){//发送消息类
                    ObjectOutputStream objectOutputStream =new ObjectOutputStream
                            (ManageClientThreads.get_Thread(message.getGetter()).getSocket().getOutputStream());
                    objectOutputStream.writeObject(message);//转发，如果客户不在线可以保存到数据库，这样就可以实现离线留言


                }else if(message.getMessageType().equals(MessageType.MESSAGE_ALL_MES)){
                    String [] userLine =ManageClientThreads.getOnlineUsers().split(" ");
                    for(int i=0;i<userLine.length;i++){
                        if(!userLine[i].equals(message.getSender())){
                            ObjectOutputStream objectOutputStream =new ObjectOutputStream
                                    (ManageClientThreads.get_Thread(userLine[i]).getSocket().getOutputStream());
                            objectOutputStream.writeObject(message);
                        }
                    }

                }else if(message.getMessageType().equals(MessageType.MESSAGE_FILE_MES)){
                    //根据getId获取对应的线程
                    ObjectOutputStream objectOutputStream =new ObjectOutputStream
                            (ManageClientThreads.get_Thread(message.getGetter()).getSocket().getOutputStream());
                    objectOutputStream.writeObject(message);

                }
                else {
                    System.out.println("如果是其他类型的message,暂时不处理");
                }

            } catch (IOException | ClassNotFoundException e) {
                e.printStackTrace();
            }
        }
    }
}

2【package com.hspedu.qqcommon;】

2.1【class Message】

package com.hspedu.qqcommon;

import java.io.Serializable;

/**
 * @author 林然
 * @version 1.0
 */
public class Message implements Serializable {
    //序列化后为了增强兼容性
    private static final long serialVersionID=1L;
    private String sender;//表示发送者
    private String getter;//表示接收者
    private String content;//表示发送内容
    private String sendTime;//表示发送时间
    private String messageType;//表示消息类型【可以在接口中定义消息类型】
    //消息类进行扩展和文件相关的字段和成员
    private byte [] fileBytes ;
    private int fileLength =0;
    private String dest;//将文件传输到哪里
    private String src;//源文件路径

    public byte[] getFileBytes() {
        return fileBytes;
    }

    public void setFileBytes(byte[] fileBytes) {
        this.fileBytes = fileBytes;
    }

    public int getFileLength() {
        return fileLength;
    }

    public void setFileLength(int fileLength) {
        this.fileLength = fileLength;
    }

    public String getDest() {
        return dest;
    }

    public void setDest(String dest) {
        this.dest = dest;
    }

    public String getSrc() {
        return src;
    }

    public void setSrc(String src) {
        this.src = src;
    }

    public String getSender() {
        return sender;
    }

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

    public String getGetter() {
        return getter;
    }

    public void setGetter(String getter) {
        this.getter = getter;
    }

    public String getContent() {
        return content;
    }

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

    public String getSendTime() {
        return sendTime;
    }

    public void setSendTime(String sendTime) {
        this.sendTime = sendTime;
    }

    public String getMessageType() {
        return messageType;
    }

    public void setMessageType(String messageType) {
        this.messageType = messageType;
    }
}

?2.2【interface MessageType】

package com.hspedu.qqcommon;

/**
 * @author 林然
 * @version 1.0
 * 表示消息类型
 */
public interface MessageType {
    //在接口中定义了一些常量，不同常量的值，表示不同的消息类型
    String MESSAGE_LOGIN_SUCCEED ="1";//表示登录成功
    String MESSAGE_LOGIN_FAIL ="2";//表示登录失败
    String MESSAGE_COMM_MES ="3";//普通信息对象
    String MESSAGE_GET_ONLINE_FRIEND="4";//要求返回在线用户列表
    String MESSAGE_RETURN_ONLINE_FRIEND="5";//要求返回在线用户列表
    String MESSAGE_CLIENT_EXIT="6";//客户端请求退出
    String MESSAGE_ALL_MES ="7";//群发信息对象
    String MESSAGE_FILE_MES ="8";//发送文件

}

?2.3【class User】

package com.hspedu.qqcommon;

import java.io.Serializable;

/**
 * @author 林然
 * @version 1.0
 * 表示一个用户/客户信息
 */
public class User implements Serializable {

    //序列化后为了增强兼容性
    private static final long serialVersionID=2L;
    private String userid;//用户id
    private String password ;//用户密码
    public User() {
    }
    public User(String userid, String password) {
        this.userid = userid;
        this.password = password;
    }

    public String getUserid() {
        return userid;
    }

    public void setUserid(String userid) {
        this.userid = userid;
    }

    public String getPassword() {
        return password;
    }

    public void setPassword(String password) {
        this.password = password;
    }
}

?3【com.hspedu.qqframe;】

package com.hspedu.qqframe;

import com.hspedu.qq.service.QQServer;

/**
 * @author 林然
 * @version 1.0
 * 该类创建一个QQServer对象
 */
public class QQFrame {
    public static void main(String[] args) {
        new QQServer();
    }
}

?4【com.hspedu.utils】

package com.hspedu.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(2, false);//一个整数，长度<=2位
            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;
    }
}

客户端

1.【package com.hspedu.qqclient.service】?

1.1【class ClientConnectServerThread】?

package com.hspedu.qqclient.service;

import com.hspedu.qqcommon.Message;
import com.hspedu.qqcommon.MessageType;

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

/**
 * @author 林然
 * @version 1.0
 */
public class ClientConnectServerThread extends Thread {
    //该线程需要持有Socket
    private Socket socket;

    //构造器可以接受一个socket对象
    public ClientConnectServerThread(Socket socket){
        this.socket=socket;
    }

    @Override
    public void run() {
        //因为Thread需要在后台和服务器通讯，因此我们做成一个while循环
        while (true){
            System.out.println("客户端线程，等待读取从服务器端发送的消息");
            try {
                ObjectInputStream objectInputStream = new ObjectInputStream(socket.getInputStream());
                //如果服务器没有信息发送，会一直阻塞在这里
                Message ms=(Message)objectInputStream.readObject();
                //在这里判断message类型，然后做相应的处理
                //如果是服务端的拉去好友在线列表
                if(ms.getMessageType().equals(MessageType.MESSAGE_RETURN_ONLINE_FRIEND)){
                    //取出在线列表信息，并显示
                    //规定
                    String [] online_users=ms.getContent().split(" ");
                    System.out.println("==========在线用户列表如下");
                    for (int i = 0; i < online_users.length; i++) {
                        System.out.println("用户："+online_users[i]);
                    }
                }else if(ms.getMessageType().equals(MessageType.MESSAGE_COMM_MES)){
                    //显示即可
                    System.out.println(ms.getSendTime());
                    System.out.println("\n"+ms.getSender()+" 对你说："+ms.getContent());
                }else if(ms.getMessageType().equals(MessageType.MESSAGE_ALL_MES)){
                    System.out.println(ms.getSendTime());
                    System.out.println("\n"+ms.getSender()+" 对大家说："+ms.getContent());
                }else if(ms.getMessageType().equals(MessageType.MESSAGE_FILE_MES)){
                    //提示信息
                    System.out.println("\n"+ms.getSender()+" 发送文件 "+ms.getSrc()+" 到 "+" 电脑目录 "+ms.getDest());
                    File file =new File(ms.getDest());
                    FileOutputStream fileOutputStream =new FileOutputStream(file);
                    fileOutputStream.write(ms.getFileBytes());
                    fileOutputStream.close();
                    System.out.println("\n保存文件成功");
                }

                else {
                    System.out.println("如果是其他类型的message,暂时不处理");
                }
            } catch (IOException | ClassNotFoundException e) {
                e.printStackTrace();
            }
        }
    }

    //为了更方便得到socket

    public Socket getSocket() {
        return socket;
    }

    public void setSocket(Socket socket) {
        this.socket = socket;
    }
}

?1.2【class FileClientService 】

package com.hspedu.qqclient.service;

import com.hspedu.qqclient.utils.Utility;
import com.hspedu.qqcommon.Message;
import com.hspedu.qqcommon.MessageType;

import java.io.*;

/**
 * @author 林然
 * @version 1.0
 * 该类完成文件传输
 */
public class FileClientService {
    public void sendFileOne(String sendId){
        System.out.println(" 请输入想要发送文件的用户名（在线）：");
        String getterId= Utility.readString(50);
        System.out.println(" 请输入传输的本地文件路径(形式d:\\xx.jpg)：");
        String src=Utility.readString(100);
        System.out.println(" 请输入对方文件存储的本地文件路径(形式d:\\xx.jpg)：");
        String dest=Utility.readString(100);
        Message message =new Message();
        message.setSender(sendId);
        message.setMessageType(MessageType.MESSAGE_FILE_MES);
        message.setGetter(getterId);
        message.setDest(dest);
        message.setSrc(src);
        //需要将文件进行读取

        File file =new File(src);
        byte [] filebytes =new byte[(int)(file.length())];

        try {
            FileInputStream fileInputStream =new FileInputStream(file);
            fileInputStream.read(filebytes);//将src文件读取到程序的字节数组

            //将文件字节数组设置到message对象中
            message.setFileBytes(filebytes);

            if(fileInputStream!=null)
            {
                fileInputStream.close();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }finally {

        }
        //提示信息
        System.out.println("\n"+" 发送文件 "+src+" 到 "+getterId+" 的电脑目录 "+dest);

        //发送时。获取对象输出流

        try {
            ObjectOutputStream objectOutputStream =new ObjectOutputStream
                    (ManageClientConnectSerVerThread.get_Thread(sendId).getSocket().getOutputStream());
            objectOutputStream.writeObject(message);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

}

1.3【class ManageClientConnectSerVerThread】?

package com.hspedu.qqclient.service;

import java.util.HashMap;

/**
 * @author 林然
 * @version 1.0
 * 该类管理客户端连接到服务端的线程的类
 */
public class ManageClientConnectSerVerThread {
    //我们把多个线程，放入到hashmap集合，key就是用户id，val就是线程
    private static HashMap<String,ClientConnectServerThread> hm=new HashMap<>();
    //将某个线程加入集合
    public static  void add_Thread(String userId,ClientConnectServerThread clientConnectServerThread){
        hm.put(userId,clientConnectServerThread);
    }
    //通过一个userId可以得到对应的线程
    public static ClientConnectServerThread get_Thread(String userId){
        return hm.get(userId);
    }
    //从集合中移除某个线程对象
    public static void remove_Thread(String userId){
        hm.remove(userId);
    }

}

1.4【class MessageClientSrevice】

package com.hspedu.qqclient.service;

import com.hspedu.qqclient.utils.Utility;
import com.hspedu.qqcommon.Message;
import com.hspedu.qqcommon.MessageType;

import java.io.IOException;
import java.io.ObjectOutputStream;

/**
 * @author 林然
 * @version 1.0
 * 该类提供和消息相关的服务方法
 */
public class MessageClientSrevice {
    public void sendMessageToAll(String sendId){
        System.out.print(" 请输入想要说的话：");
        String content=Utility.readString(100);
        Message message =new Message();
        message.setMessageType(MessageType.MESSAGE_ALL_MES);
        message.setSender(sendId);
        message.setContent(content);
        message.setSendTime(new java.util.Date().toString());//发送时间
        try {
            ObjectOutputStream objectOutputStream =new ObjectOutputStream
                    (ManageClientConnectSerVerThread.get_Thread(sendId).getSocket().getOutputStream());
            objectOutputStream.writeObject(message);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    public  void sendMessageToOne(String sendId){
        System.out.print(" 请输入想要聊天的用户名（在线）：");
        String getterId= Utility.readString(50);
        System.out.print(" 请输入想要说的话：");
        String content=Utility.readString(100);
        //构建message
        Message message=new Message();
        message.setSender(sendId);
        message.setGetter(getterId);
        message.setContent(content);
        message.setSendTime(new java.util.Date().toString());//发送时间
        message.setMessageType(MessageType.MESSAGE_COMM_MES);
        System.out.println(sendId+"对"+getterId+"说了一句话");

        //发送给服务端
        try {
            ObjectOutputStream objectOutputStream = new ObjectOutputStream
                    (ManageClientConnectSerVerThread.get_Thread(sendId).getSocket().getOutputStream());
            objectOutputStream.writeObject(message);
        } catch (IOException e) {
            e.printStackTrace();
        }

    }
}

?1.5【class UserClientService】

package com.hspedu.qqclient.service;

import com.hspedu.qqcommon.Message;
import com.hspedu.qqcommon.MessageType;
import com.hspedu.qqcommon.User;


import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.InetAddress;
import java.net.Socket;

/**
 * @author 林然
 * @version 1.0
 * 该类完成用户登录验证注册等功能
 */
public class UserClientService {
    //根据Userid和pwd验证该用户是否合法
    //因为我们可能在其他地方要使用user信息，所以做成属性
    private User u =new User();
    //因为Socket在其他地方也可能要使用，所以我们也做成属性
    private Socket socket;

    public boolean checkUser(String userId,String pwd) throws IOException, ClassNotFoundException {
        boolean b=false;
        u.setPassword(pwd);
        u.setUserid(userId);
        //连接服务端，发送user对象

        Socket socket = new Socket(InetAddress.getLocalHost(), 9999);
        //得到ObjectOutput对象
        ObjectOutputStream objectOutputStream = new ObjectOutputStream(socket.getOutputStream());
        //发送user对象
        objectOutputStream.writeObject(u);

        //读取从服务端回复的message对象
        ObjectInputStream objectInputStream =new ObjectInputStream(socket.getInputStream());
        Message ms=(Message) objectInputStream.readObject();

        if(ms.getMessageType().equals(MessageType.MESSAGE_LOGIN_SUCCEED)){//登录ok

            //创建一个和服务器端保持通讯的线程->创建一个类 ClientConnectServerThread
            //等待....
            ClientConnectServerThread clientConnectServerThread=new ClientConnectServerThread(socket);
            //启动客户端的线程
            clientConnectServerThread.start();
            //这里为了后面客户端的扩展，我们将线程放入到集合中进行管理
            ManageClientConnectSerVerThread.add_Thread(userId,clientConnectServerThread);
            b=true;
        }else {//登录失败
            socket.close();
        }
        return b;
    }
    //向服务端请求在线用户列表
    public void onlineFriendList(){
        Message message =new Message();
        message.setMessageType(MessageType.MESSAGE_GET_ONLINE_FRIEND);
        message.setSender(u.getUserid());

        //发送给服务器，应该得到当前线程对象的socket对应的objectOutputstream
        try {
            ObjectOutputStream objectOutputStream =new ObjectOutputStream
                    (ManageClientConnectSerVerThread.get_Thread(u.getUserid()).getSocket().getOutputStream());
            objectOutputStream.writeObject(message);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    //编写方法。退出2客户端，并给服务端发送一个退出系统的message对象
    public void Logout(){
        Message message =new Message();
        message.setMessageType(MessageType.MESSAGE_CLIENT_EXIT);
        message.setSender(u.getUserid());

        //发送message
        try {
            ObjectOutputStream objectOutputStream = new ObjectOutputStream
                    (ManageClientConnectSerVerThread.get_Thread(u.getUserid()).getSocket().getOutputStream());
            objectOutputStream.writeObject(message);


            System.out.println(u.getUserid()+"退出系统");
            System.exit(0);//结束
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

}

?2【package com.hspedu.qqclient.utils;】

package com.hspedu.qqclient.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(2, false);//一个整数，长度<=2位
            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;
    }
}

?3【package com.hspedu.qqclient.view;】

package com.hspedu.qqclient.view;

import com.hspedu.qqclient.service.FileClientService;
import com.hspedu.qqclient.service.MessageClientSrevice;
import com.hspedu.qqclient.service.UserClientService;
import com.hspedu.qqclient.utils.Utility;

import java.io.IOException;

/**
 * @author 林然
 * @version 1.0
 * 客户端菜单界面
 */
public class QQView {
    private boolean loop = true;//控制是否显示菜单
    private String key = "";//接受用户输入
    private UserClientService userClientService=new UserClientService();//用于登录注册服务
    private MessageClientSrevice messageClientSrevice =new MessageClientSrevice();//消息服务
    private FileClientService fileClientService =new FileClientService();//传输文件服务
    public static void main(String[] args) throws IOException, ClassNotFoundException {
        new QQView().mainMenu();
        System.out.println("客户端退出系统");

    }
    //显示主菜单
    private void mainMenu() throws IOException, ClassNotFoundException {
        while (loop) {
            System.out.println("===========================欢迎登录网络通信系统===================================");
            System.out.println("\t\t 1 登录系统");
            System.out.println("\t\t 9 退出系统");
            System.out.println("请输入你的选择");
            key = Utility.readString(1);

            //根据用户不同的输入来处理不同的逻辑
            switch (key){
                case "1":
                    System.out.println("请输入用户号：");
                    String userId = Utility.readString(50);
                    System.out.println("请输入密码：");
                    String pwd = Utility.readString(50);
                    //这里就比较麻烦了，需要到服务端去验证用户是否合法
                    //这里有很多代码，我们需要编写一个类UserClientService【用户登录等
                    if(userClientService.checkUser(userId,pwd)){//还没有写完，先把整个逻辑打通
                        System.out.println("===========================欢迎(用户"+userId+")登录成功===================================");
                        //进入二级菜单
                        while (loop){
                            System.out.println("\n=====================网络通信系统二级菜单（用户"+userId+"===================");
                            System.out.println("\t\t 1 显示在线用户列表");
                            System.out.println("\t\t 2 群发消息");
                            System.out.println("\t\t 3 私聊消息");
                            System.out.println("\t\t 4 发送文件");
                            System.out.println("\t\t 9 退出系统");
                            System.out.println("请输入你的选择");
                            key = Utility.readString(1);
                            switch (key){
                                case "1":
                                    //System.out.println(" 1 显示在线用户列表");
                                    //这里准备写一个方法来获取在线用户列表
                                    userClientService.onlineFriendList();
                                    break;
                                case "2":
                                    //System.out.println(" 2 群发消息");
                                    messageClientSrevice.sendMessageToAll(userId);
                                    break;
                                case "3":
                                    messageClientSrevice.sendMessageToOne(userId);
                                    //调用一个方法
                                    break;
                                case "4":
                                    //System.out.println(" 4 发送文件");
                                    fileClientService.sendFileOne(userId);
                                    break;
                                case "9":
                                    //调用一个方法给服务器发送一个退出系统的message
                                    //System.out.println(" 9 退出系统");
                                    userClientService.Logout();
                                    loop=false;
                                    break;

                            }
                        }
                    }else {
                        System.out.println(" 登录失败");
                    }
                    break;
                case "9":
                    loop=false;
                    userClientService.Logout();
                    break;
            }

        }
    }
}

?4【package com.hspedu.qqcommon;】

4.1【class Message】

package com.hspedu.qqcommon;

import java.io.Serializable;

/**
 * @author 林然
 * @version 1.0
 * 表示客户端和服务器端通讯的消息
 */
public class Message implements Serializable {

    //序列化后为了增强兼容性
    private static final long serialVersionID=1L;
    private String sender;//表示发送者
    private String getter;//表示接收者
    private String content;//表示发送内容
    private String sendTime;//表示发送时间
    private String messageType;//表示消息类型【可以在接口中定义消息类型】
    //消息类进行扩展和文件相关的字段和成员
    private byte [] fileBytes ;
    private int fileLength =0;
    private String dest;//将文件传输到哪里
    private String src;//源文件路径

    public byte[] getFileBytes() {
        return fileBytes;
    }

    public void setFileBytes(byte[] fileBytes) {
        this.fileBytes = fileBytes;
    }

    public int getFileLength() {
        return fileLength;
    }

    public void setFileLength(int fileLength) {
        this.fileLength = fileLength;
    }

    public String getDest() {
        return dest;
    }

    public void setDest(String dest) {
        this.dest = dest;
    }

    public String getSrc() {
        return src;
    }

    public void setSrc(String src) {
        this.src = src;
    }

    public String getSender() {
        return sender;
    }

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

    public String getGetter() {
        return getter;
    }

    public void setGetter(String getter) {
        this.getter = getter;
    }

    public String getContent() {
        return content;
    }

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

    public String getSendTime() {
        return sendTime;
    }

    public void setSendTime(String sendTime) {
        this.sendTime = sendTime;
    }

    public String getMessageType() {
        return messageType;
    }

    public void setMessageType(String messageType) {
        this.messageType = messageType;
    }
}

4.2 【interface MessageType】

package com.hspedu.qqcommon;

/**
 * @author 林然
 * @version 1.0
 * 表示消息类型
 */
public interface MessageType {
    //在接口中定义了一些常量，不同常量的值，表示不同的消息类型
    String MESSAGE_LOGIN_SUCCEED ="1";//表示登录成功
    String MESSAGE_LOGIN_FAIL ="2";//表示登录失败
    String MESSAGE_COMM_MES ="3";//普通信息对象
    String MESSAGE_GET_ONLINE_FRIEND="4";//要求返回在线用户列表
    String MESSAGE_RETURN_ONLINE_FRIEND="5";//要求返回在线用户列表
    String MESSAGE_CLIENT_EXIT="6";//客户端请求退出
    String MESSAGE_ALL_MES ="7";//群发信息对象
    String MESSAGE_FILE_MES ="8";//发送文件
}

?4.3【class User】

package com.hspedu.qqcommon;

import java.io.Serializable;

/**
 * @author 林然
 * @version 1.0
 * 表示一个用户/客户信息
 */
public class User implements Serializable {
    //序列化后为了增强兼容性
    private static final long serialVersionID=2L;

    private String userid;//用户id
    private String password ;//用户密码

    public User() {
    }

    public User(String userid, String password) {
        this.userid = userid;
        this.password = password;
    }

    public String getUserid() {
        return userid;
    }

    public void setUserid(String userid) {
        this.userid = userid;
    }

    public String getPassword() {
        return password;
    }

    public void setPassword(String password) {
        this.password = password;
    }
}