多用户即时通讯系统03

4.编码实现02

4.3功能实现-无异常退出系统

4.3.1思路分析

上述代码运行时，在客户端选择退出系统的时候，可以发现程序并没有停止运行，原因是：

退出时，程序将循环标志loop设为false，退出了内层循环，而外层循环因为也用了loop来作为循环条件，外层循环也同样退出。此时在客户端类QQView中的主线程已经结束，但是在循环过程中，因为与服务端连接而产生的线程并没有结束，整个进程也就没有结束，因此程序仍在运行中。

解决方法：

客户端：在main线程中调用方法，给服务端发送一个退出系统的message对象，然后调用System.exit(0)指令，正常退出。这样整个进程就可以关闭。

服务器端：在服务器这边，接收到一个退出系统的message对象后，把这个客户端对应的线程所持有的socket关闭，然后退出该线程

4.3.2代码实现

1.客户端：

1.修改:UserClientService类

在该类中增加logout()方法

//编写方法，退出客户端，并给服务器端发送一个退出系统的message对象
public void logout(){
    Message message = new Message();
    message.setMesType(MessageType.MESSAGE_CLIENT_EXIT);
    message.setSender(u.getUserId());//一定要指定是那个客户端，服务端要根据这个userId移除集合中的线程

    //发送message
    try {
        //从管理线程的集合里面，通过userId，得到这个线程对象
        ClientConnectServerThread clientConnectServerThread =
                ManageClientConnectServerThread.getClientConnectServerThread(u.getUserId());
        //通过这个线程中获取关联的socket
        Socket socket = clientConnectServerThread.getSocket();
        //得到当前线程的Socket对应的ObjectOutputStream对象
        ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
        oos.writeObject(message);
        System.out.println(u.getUserId()+"退出系统");
        System.exit(0);
    } catch (IOException e) {
        e.printStackTrace();
    }
}

2.修改：QQView类

在该类中的内层循环中，调用logout方法：

//调用方法，给服务器发送一个退出系统的message
userClientService.logout();

2.服务端：

1.修改：ManageClientThreads类

在该类中增加removeServerConnectClientThread()方法

//增加一个方法，从集合中移除某个对象
public static void removeServerConnectClientThread(String userId){
    hm.remove(userId);
}

2.修改：ServerConnectClientThread类

在该类的run方法中增加业务二操作：

public void run() {//这里线程处于run的状态，可以发送/接收消息

    while (true) {
        try {
            System.out.println("服务端和客户端" + userId + "保持通信，读取数据...");
            ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());
            Message message = (Message) ois.readObject();

            //后面会使用message,根据message的类型，做相应的业务处理

            //业务一：客户请求拉取在线用户列表
            if (message.getMesType().equals(MessageType.MESSAGE_GET_ONLINE_FRIEND)) {
                //客户请求拉取在线用户列表
                //假定返回的用户列表是用空格隔开的id名（如：100 200 紫霞仙子 至尊宝 唐僧）
                System.out.println(message.getSender() + " 要在线用户列表");
                String onlineUser = ManageClientThreads.getOnlineUser();

                //返回message
                //构建一个Message对象（这个Message对象包含了在线用户列表信息），返回给客户端
                Message message2 = new Message();
                //设置消息类型--返回的在线用户列表类型-客户端会根据返回的消息类型来进行相应的业务处理
                message2.setMesType(MessageType.MESSAGE_RET_ONLINE_FRIEND);
                message2.setContent(onlineUser);//返回用户消息列表
                //服务器发送的消息的接收者Getter 就是服务器接收的信息 的发送者Sender
                message2.setGetter(message.getSender());

                //返回给客户端
                ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
                oos.writeObject(message2);

            } else if (message.getMesType().equals(MessageType.MESSAGE_CLIENT_EXIT)) {
                //业务二：客户请求退出系统
                System.out.println(message.getSender() + " 退出");
                //将客户端对应的线程从集合中删除
                ManageClientThreads.removeServerConnectClientThread(message.getSender());
                socket.close();//关闭的是当前的线程持有的socket属性
                //退出线程的循环
                break;
            } else {
                System.out.println("其他类型的message，暂时不处理");
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

运行：

1.运行服务端：