多用户即时通讯系统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();

        }

    }

}