多用戶即時通訊系統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.運行服務端：