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
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類