java線上聊天項目1.0版 異常處理——開啟多個客戶端，關閉一個客戶端後，在其他客戶端中再發出信息會出現異常的處理

来源:http://www.cnblogs.com/qingyundian/archive/2017/12/06/7995070.html
-Advertisement-
Play Games

異常一 只開啟一個客戶端，輸入信息後關閉，客戶端出現如下異常 根據異常說明 ChatClientFrame客戶端117行 提示原因是Socket關閉 分析原因 客戶端代碼 while (connected) { String str = dis.readUTF(); 當視窗關閉後，Socket已經關 ...


異常一

只開啟一個客戶端，輸入信息後關閉，客戶端出現如下異常

根據異常說明 ChatClientFrame客戶端117行

提示原因是Socket關閉

分析原因

客戶端代碼

while (connected) {
String str = dis.readUTF();

當視窗關閉後，Socket已經關閉，讀的操作還在繼續

處理這個異常，代碼如下

catch (SocketException e) {
System.out.println("a client has been closed!");
}

同時，

服務端出現下邊異常

解決異常

catch(EOFException e) {
System.out.println("a client has been closed,can't read message from it.");
}

  

 異常二

開啟多個客戶端，關閉一個客戶端後，在其他客戶端中再發出信息，伺服器端會出現異常

這個問題是由

for(int i=0;i<clients.size();i++) {
Client c=clients.get(i);
c.send(str);
}

此處產生邏輯bug，當一個客戶端被關閉之後，這個客戶端還在clients集合當中，這個被關閉的客戶端還要再執行send(str)發送信息

造成

private void send(String str) {
try {
dos.writeUTF(str);
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
};
}

產生異常

 解決異常，在集合中把這個客戶端刪除掉

catch(SocketException e) {
clients.remove(this);
}

 

伺服器端完整代碼如下：

package com.swift;

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.EOFException;
import java.io.IOException;
import java.net.BindException;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.SocketException;
import java.util.ArrayList;
import java.util.List;

public class ChatServer {
    
    boolean started = false;
    ServerSocket ss = null;
    Socket s = null;
    List<Client> clients=new ArrayList<Client>();  
    
    public static void main(String[] args) {
        new ChatServer().fun();
    }

    private void fun() {
        try {
            ss = new ServerSocket(8888);
            started = true;
        } catch (BindException e) {
            System.out.println("埠使用中......");
        } catch (IOException e1) {
            e1.printStackTrace();
        }
        try {
            while (started) {
                s = ss.accept();
                System.out.println("a client connected success");
                Client c = new Client(s);
                new Thread(c).start();
                clients.add(c);
            }
        } catch (EOFException e) {
            System.out.println("client has closed.");
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try {
                ss.close();
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
    }

    class Client implements Runnable {

        private Socket s;
        private DataInputStream dis;
        private DataOutputStream dos;
        private boolean connected = false;

        public Client(Socket s) {
            this.s = s;
            try {
                this.dis = new DataInputStream(s.getInputStream());
                this.dos = new DataOutputStream(s.getOutputStream());
                connected = true;
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        private void send(String str) {
            try {
                dos.writeUTF(str);
            } catch(SocketException e) {
                clients.remove(this);
            } catch (IOException e) {
                e.printStackTrace();
            };
        }
        @Override
        public void run() {
            try {//註意:要包括while迴圈，如果try在while迴圈里，則出現socket closed異常
                while (connected) {
                    String str = dis.readUTF();
                    System.out.println(str);
                    for(int i=0;i<clients.size();i++) {
                        Client c=clients.get(i);
                        c.send(str);
                    }
                    
//                     for(Iterator<Client> it=clients.iterator();it.hasNext();) {
//                         Client c=it.next();//方法二，不可取，有同步鎖
//                         c.send(str);
//                     }
                    
//                    Iterator<Client> it=clients.iterator();
//                    while(it.hasNext()) {
//                        Client c=it.next();//方法三，不可取，有同步鎖,修改需要加鎖（此時沒修改）
//                        c.send(str);
//                    }
                     
                }
            } catch(EOFException e) {
                System.out.println("a client has been closed,can't read message from it.");
            } catch (IOException e) {
                e.printStackTrace();
            } finally {
                if (dis != null) {
                    try {
                        dis.close();
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                }
                if(dos!=null) {
                    try {
                        dos.close();
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                }
                if (s != null) {
                    try {
                        s.close();
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                }
            }

        }

    }
}

客戶端完整代碼如下：

package com.swift;

import java.awt.BorderLayout;
import java.awt.Color;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.WindowAdapter;
import java.awt.event.WindowEvent;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.ConnectException;
import java.net.Socket;
import java.net.SocketException;

import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.JPanel;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import javax.swing.JTextField;

public class ChatClientFrame extends JFrame {

    private static final long serialVersionUID = -118470059355655240L;
    Socket s;
    DataOutputStream dos;
    DataInputStream dis;
    private boolean connected = false;
    JLabel label_shang = new JLabel();
    JLabel label_xia = new JLabel();
    JTextField tf = new JTextField(38);
    JTextArea ta = new JTextArea(15, 50);
    JButton button = new JButton();

    public ChatClientFrame() {
        setBounds(200, 200, 500, 400);
        setTitle("客戶端聊天工具 —— 1.0");
        // 對視窗進行大的佈局，分為三行一列，在pBasic面板上添加三個面板shang zhong xia
        JPanel pBasic = new JPanel();
        pBasic.setLayout(new BorderLayout());// 不設置預設也是這種佈局模式
        setContentPane(pBasic);// 把面板放在視窗上，不記得用this.關鍵字
        JPanel shang = new JPanel();
        JPanel zhong = new JPanel();
        JPanel xia = new JPanel();
        // 設置JPanel面板的大小
        shang.setSize(470, 25);
        zhong.setSize(470, 180);
        xia.setSize(470, 40);
        pBasic.add(shang, BorderLayout.NORTH);
        pBasic.add(zhong, BorderLayout.CENTER);
        pBasic.add(xia, BorderLayout.SOUTH);
        shang.setBackground(Color.red);
        zhong.setBackground(Color.yellow);
        xia.setBackground(Color.blue);

        label_shang.setText("聊天記錄");
        shang.add(label_shang);
        ta.setLineWrap(true);// 自動換行
        JScrollPane scroll = new JScrollPane(ta);// 增加滾動條，以便不增加行數
        zhong.add(scroll);
        label_xia.setText("輸入信息");
        xia.add(label_xia, BorderLayout.WEST);
        /*
         * 增加功能，視窗監聽事件，視窗打開時設置游標焦點在tf文本域中
         */
        this.addWindowListener(new WindowAdapter() {
            @Override
            public void windowOpened(WindowEvent e) {
                tf.requestFocus();
            }
        });
        xia.add(tf, BorderLayout.CENTER);
        button.setText("發送");
        xia.add(button, BorderLayout.EAST);

        button.addActionListener(new ShareListener());
        tf.addActionListener(new ShareListener());
        pack();
        this.addWindowListener(new WindowAdapter() {
            @Override
            public void windowClosing(WindowEvent e) {
                disconnect();
                System.exit(0);
            }
        });
        setVisible(true);
        // 創建窗體直接調用連接伺服器
        connect();
        Thread t=new Thread(new ReceiveThread());
        t.start();
    }

    class ShareListener implements ActionListener {

        @Override
        public void actionPerformed(ActionEvent e) {
            String tfText1 = tf.getText();
            tf.setText("");
            // 當回車或發送按鈕時，tfText發送到伺服器
            try {
                dos.writeUTF(tfText1);
                dos.flush();
            } catch (IOException e1) {
                e1.printStackTrace();
            }

        }
    }

    class ReceiveThread implements Runnable {

        @Override
        public void run() {
            try {
                while (connected) {
                    String str = dis.readUTF();
                    System.out.println(str);
                    ta.setText(ta.getText()+str+"\r\n");
                }
            } catch (SocketException e) {
                System.out.println("a client has been closed!");
            } catch (IOException e) {
                e.printStackTrace();
            }
        }

    }

    public void connect() {
        try {
            s = new Socket("127.0.0.1", 8888);
            System.out.println("connected!");
            connected=true;
            dos = new DataOutputStream(s.getOutputStream());
            dis = new DataInputStream(s.getInputStream());

        } catch (ConnectException e) {
            System.out.println("服務端異常.........");
            System.out.println("請確認服務端是否開啟.........");
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    public void disconnect() {
        try {
            if (dos != null)
                dos.close();
            if(dis !=null)
                dis.close();
            if (s != null)
                s.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    public static void main(String[] args) {
        new ChatClientFrame();
    }

}

 


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • Struts 2 入門
    Struts 2 入門： 一：Struts 2執行流程： 1 客戶端發送請求； 2這個請求經過一系列的過濾器（Filter）（這些過濾器中有一個叫做ActionContextCleanUp的可選過濾器，這個過濾器對於Struts2和其他框架的集成很有幫助，例如：SiteMeshPlugin） 3接著 ...
  • 消息機制
    消息的一種開發模式，也是一種設計模式（發佈-訂閱） 中心窗體發消息(不知道消息的接受者)，在中心窗體的事件中綁定的方法的對象接受消息(接受者做進一步處理)。 1.WinFrom(發佈-訂閱) 2.Windows（事件 Event） 3.Android（廣播 Broadcast） 4.Java（觀察者 ...
  • 理論篇：關註點分離(Separation of concerns, SoC)
    概念 關註點分離（Separation of concerns，SOC）是對只與“特定概念、目標”(關註點)相關聯的軟體組成部分進行“標識、封裝和操縱”的能力，即標識、封裝和操縱關註點的能力。 概念 關註點分離（Separation of concerns，SOC）是對只與“特定概念、目標”(關註點 ...
  • 006菜單練習（標記位）
    退出程式不用exit（） #01代碼 1 #__author: _nbloser 2 #date: 2017/12/5 3 4 5 shaoguan = ['仁化', '始興', '樂昌', '南雄'] 6 jiangmeng = ['開平', '蓬江', '台山', '鶴山', '恩平'] 7 g ...
  • 32141324
    21342134123 ...
  • Java IO（2）阻塞式輸入輸出（BIO）
    在上文中《Java IO（1）基礎知識——位元組與字元》瞭解到了什麼是位元組和字元，主要是為了對Java IO中有關位元組流和字元流有一個更好的瞭解。 本文所述的輸出輸出指的是Java中傳統的IO，也就是阻塞式輸入輸出（Blocking I/O， BIO），在JDK1.4之後出現了新的輸入輸出API——N ...
  • 貪心演算法求解背包問題
    貪心演算法（又稱貪婪演算法）是指，在對問題求解時，總是做出在當前看來是最好的選擇。也就是說，不從整體最優上加以考慮，他所做出的僅是在某種意義上的局部最優解。貪心演算法不是對所有問題都能得到整體最優解，但對範圍相當廣泛的許多問題他能產生整體最優解或者是整體最優解的近似解。 ...
  • spring的面試
    Spring註解 Spring的對象訪問 Spring面向切麵編程 Spring MVC框架1.spring的優點輕量級：基礎版本的spring框架大約2mb控制反轉（IOC）：把生成對象的權利反轉給spring框架面向切麵（AOP）：把可重用的功能提取出來，然後再將這些通用的功能在合適的時候織入到 ...
一周排行
    -Advertisement-
    Play Games
  • WPF 已知問題 監聽 WMI 事件導致觸摸失效
    示例項目結構 在 Visual Studio 中創建一個 WinForms 應用程式後，項目結構如下所示： MyWinFormsApp/ │ ├───Properties/ │ └───Settings.settings │ ├───bin/ │ ├───Debug/ │ └───Release/ ...
  • [STAThread]特性
    [STAThread] 特性用於需要與 COM 組件交互的應用程式，尤其是依賴單線程模型（如 Windows Forms 應用程式）的組件。在 STA 模式下，線程擁有自己的消息迴圈，這對於處理用戶界面和某些 COM 組件是必要的。 [STAThread] static void Main(stri ...
  • UWP WinUI3 傳入 AddHandler 的 RoutedEventHandler 類型與事件所需不匹配將拋出參數異常
    在WinForm中使用全局異常捕獲處理 在WinForm應用程式中，全局異常捕獲是確保程式穩定性的關鍵。通過在Program類的Main方法中設置全局異常處理，可以有效地捕獲並處理未預見的異常，從而避免程式崩潰。 註冊全局異常事件 [STAThread] static void Main() { / ...
  • .NET 多版本 WinForm 開源控制項庫 SunnyUI
    前言 給大家推薦一款開源的 Winform 控制項庫，可以幫助我們開發更加美觀、漂亮的 WinForm 界面。 項目介紹 SunnyUI.NET 是一個基於 .NET Framework 4.0+、.NET 6、.NET 7 和 .NET 8 的 WinForm 開源控制項庫，同時也提供了工具類庫、擴展 ...
  • .net core8 使用Swagger（附當前源碼）
    說明 該文章是屬於OverallAuth2.0系列文章，每周更新一篇該系列文章（從0到1完成系統開發）。 該系統文章，我會儘量說的非常詳細，做到不管新手、老手都能看懂。 說明：OverallAuth2.0 是一個簡單、易懂、功能強大的許可權+可視化流程管理系統。 有興趣的朋友，請關註我吧(*^▽^*) ...
  • WPF 什麼時候 VisualTreeHelper.GetDescendantBounds 將返回無窮大
    一、下載安裝 1.下載git 必須先下載並安裝git，再TortoiseGit下載安裝 git安裝參考教程：https://blog.csdn.net/mukes/article/details/115693833 2.TortoiseGit下載與安裝 TortoiseGit，Git客戶端，32/6 ...
  • C# 開源教程帶你輕鬆掌握數據結構與演算法
    前言 在項目開發過程中，理解數據結構和演算法如同掌握蓋房子的秘訣。演算法不僅能幫助我們編寫高效、優質的代碼，還能解決項目中遇到的各種難題。 給大家推薦一個支持C#的開源免費、新手友好的數據結構與演算法入門教程：Hello演算法。 項目介紹 《Hello Algo》是一本開源免費、新手友好的數據結構與演算法入門 ...
  • 第22篇 生成proto文件bat腳本
    1.生成單個Proto.bat內容 @rem Copyright 2016, Google Inc. @rem All rights reserved. @rem @rem Redistribution and use in source and binary forms, with or with ...
  • 記一次 .NET某上位機視覺程式 卡死分析
    一：背景 1. 講故事 前段時間有位朋友找到我，說他的窗體程式在客戶這邊出現了卡死，讓我幫忙看下怎麼回事？dump也生成了，既然有dump了那就上 windbg 分析吧。 二：WinDbg 分析 1. 為什麼會卡死 窗體程式的卡死，入口門檻很低，後續往下分析就不一定了，不管怎麼說先用 !clrsta ...
  • 醫學DICOM文件與PACS系統進行數據傳輸
    前言 人工智慧時代，人臉識別技術已成為安全驗證、身份識別和用戶交互的關鍵工具。 給大家推薦一款.NET 開源提供了強大的人臉識別 API，工具不僅易於集成，還具備高效處理能力。 本文將介紹一款如何利用這些API，為我們的項目添加智能識別的亮點。 項目介紹 GitHub 上擁有 1.2k 星標的 C# ...
所有分類