Java 網路編程 —— 客戶端協議處理框架

来源:https://www.cnblogs.com/Yee-Q/archive/2023/06/03/17453172.html
-Advertisement-
Play Games

## 概述 Java 對客戶程式的通信過程進行了抽象，提供了通用的協議處理框架，該框架封裝了 Socket，主要包括以下類： - URL 類：統一資源定位符，表示客戶程式要訪問的遠程資源 - URLConnection 類：表示客戶程式與遠程伺服器的連接，客戶程式可以從 URLConnection ...


概述

Java 對客戶程式的通信過程進行了抽象，提供了通用的協議處理框架，該框架封裝了 Socket，主要包括以下類：

  • URL 類：統一資源定位符，表示客戶程式要訪問的遠程資源
  • URLConnection 類：表示客戶程式與遠程伺服器的連接，客戶程式可以從 URLConnection 獲得數據輸入流和輸出流
  • URLStreamHandler 類：協議處理器，主要負責創建與協議相關的 URLConnection 對象
  • ContentHandler 類：內容處理器，負責解析伺服器發送的數據，把它轉換為相應的 Java 對象

以上類都位於 java.net 包，除 URL 類為具體類，其餘的都是抽象類，對於一種具體的協議，需要創建相應的具體子類。Oracle 公司為協議處理框架提供了基於 HTTP 的實現，它們都位於 JDK 類庫的 sun.net.www 包或者其子包


URL 類的用法

下例的 HtpClient 類利用 URL 類創建了一個簡單的 HTTP 客戶程式，先創建了一個 URL 對象，然後通過它的 openStream() 方法獲得一個輸入流，接下來就從這個輸入流中讀取伺服器發送的響應結果

public class HttpClient {
    
    public static void main(String args[]) throws IOException {
        //http是協議符號
        URI url = new URL("http://www.javathinker.net/hello.htm");
        //接收響應結果
        InputStream in = url.openStream();
        ByteArrayOutputStream buffer = new ByteArrayOutputStream();
        bytel] buff = new byte[1024];
        int len = -l;
        
        while((len = in.read(buff)) != -1) {
            buffer.write(buff, 0, len);
        }
        //把位元組數組轉換為字元串
        System.out.println(new String(buffer.toByteArray()));
    }
}

URL 類的構造方法創建 URLStreamHandler 實例的流程如下：

  1. 如果在 URL 緩存已經存在這樣的 URLStreamHandler 實例，則無須再創建，否則繼續執行下一步

  2. 如果程式通過 URL 類的靜態 setURLStreamHandlerFactory() 方法設置了 URLStreamHandlerFactory 介面的具體實現類，那麼就通過這個工廠類的 createURLStreamHandler() 方法來構造 URLStreamHandler 實例，否則繼續執行下一步

  3. 根據系統屬性 java.prolocol.handler.pkgs 來決定 URLStreamHandler 具體子類的名字，然後對其實例化，假定運行 HttpClient 的命令為：

    java -Djava.protocol.handler.pkgs=com.abc.net.www | net.javathinker.protocols HttpClient

    以上命令中的 -D 選項設定系統屬性，會先查找並試圖實例化 com.abc.net.www.http.Handler 類，如果失敗，再試圖實例化 net.javathinkerprotocols.http.Handler 類，如果以上操作都失敗，那麼繼續執行下一步

  4. 試圖實例化位於 sun.net.www.prolocol 包的 sun.netwww.protocol.協議名.Handler 類，如果失敗，URL 構造方法就會拋出 MalforedURLException。在本例協議名是 http，會試圖實例化 sun.net.www.protocol.http.Handler 類

URL 類具有以下方法：

  • openConnection()：創建並返回一個 URLConnection 對象，這個 openConnection() 方法實際上是通過調用 URLStreamHandler 類的 openConnection() 方法，來創建 URLConnection 對象
  • openStream()：返回用於讀取伺服器發送數據的輸入流，該方法實際上通過調用 URLConnection 類的 getInputStream() 方法來獲得輸入流
  • getContent()：返回包裝了伺服器發送數據的 Java 對象，該方法實際上調用 URLConnection 類的 getContent) 方法，而 URLConnection 類的 getContent() 方法又調用了 ContentHandler 類的 getContent() 方法

URLConnection 類的用法

URLConnection 類表示客戶程式與遠程伺服器的連接，URLConnection 有兩個 boolean 類型的屬性以及相應的 get 和 set 方法：

  • dolnput：如果取值為 true，表示允許獲得輸入流，讀取遠程伺服器發送的數據該屬性的預設值為 true。程式可通過 getDolnput() 和 setDolnput() 方法來讀取和設置該屬性
  • doOutput：如果取值為 true，表示允許獲得輸出流，向遠程伺服器發送數據該屬性的預設值為 false。程式可通過 getDoOutput() 和 setDoOutput() 方法來讀取和設置該屬性

URLConnection 類提供了讀取遠程伺服器的響應數據的一系列方法：

  • getHeaderField(String name)：返迴響應頭中參數 name 指定的屬性的值
  • getContentType()：返迴響應正文的類型，如果無法獲取響應正文的類型就返回 null
  • getContentLength()：返迴響應正文的長度，如果無法獲取響應正文的長度，就返回 -1
  • getContentEncoding()：返迴響應正文的編碼類型，如果無法獲取響應正文的編碼類型，就返回 null

下例的 HtpClient 類利用 URLConnection 類來讀取伺服器的響應結果

public class HttpClient {
    
    public static void main(String args[]) throws IOException {
        URL url = new URL("http://www,javathinkernet/hello.htm");
        URLConnection connection = url.openConnection();
        //接收響應結果
        System.out.printIn("正文類型:" + connection.getContentType());
        System.out.printIn("正文長度:" + connection.getContentLength());
        //讀取響應正文
        InputStream in = connection.getInputStream();
        
        ByteArrayOutputStream buffer = new ByteArrayOutputStream();
        byte[] buff = new byte[1024];
        int len = -l;
        
        while((len = in.read(buff)) != -1) {
            buffer.write(buff, 0, len);
        }
        
        //把位元組數組轉換為字元串
        System.out.println(new String(buffer.toByteArray()));
    }
}

實現協議處理框架

本節將為用戶自定義的 ECHO 協議實現處理框架，共創建了以下類：

  • EchoURLConnection 類：繼承自 URLConnection 類
  • EchoURLStreamHandler 類：繼承自 URLStreamHandler 類
  • EchoURLStreamHandlerFactory 類：實現 URLStreamHandlerFactory 介面
  • EchoContentHandler 類：繼承自 ContentHandler 類
  • EchoContentHandlerFactory 類：實現 ContentHandlerFactory 介面

1. 創建 EchoURLConnection 類

EchoURLConnection 類封裝了一個 Socket，在 connect() 方法中創建與遠程伺服器連接的 Socket 對象

public class EchoURLConnection extends URLConnection {
    
    private Socket connection = null;
    public final static int DEFAULT PORT = 8000;
    
    public EchoURLConnection(URL url) {
        super(url);
    }
    
    public synchronized InputStream getInputStream() throws IOException {
        if(!connected) connect();
        return connection.getInputStream();
    }
    
    public synchronized OutputStream getOutputStream() throws IOException {
        if(!connected) connect();
        return connection.getOutputStream();
    }
    
    public String getContentType() {
        return "text/plain";
    }
    
    public synchronized void connect() throws IOException {
        if(!connected) {
            int port = url.getPort();
            if(port < 0 || port > 65535) port = DEFAULT_PORT;
            this.connection = new Socket(url.getHost(), port);
            this.connected = true;
        }
    }
    
    public synchronized void disconnect() throws IOException {
        if(connected) {
            //斷開連接
            this.connection.close();
            this.connected = false;
        }
    }
}

2. 創建 EchoURLStreamHandler 及工廠類

EchoURLStreamHandler 類的 openConnection() 方法負責創建一個 EchoURLConnection 對象

public class EchoURLStreamHandler extends URLStreamHandler {
    
    public int getDefaultPort() {
        return 8000;
    }
    
    protected URLConnection openConnection(URL url) throws IOException {
        return new EchoURLConnection(url);
    }
}

EchoURLStreamHandlerFactory 類的 createURLStreamHandle() 方法負責構造 EchoURLStreamHandler 實例

public class EchoURLStreamHandlerFactory implements URLStreamhandlerFactory {
    
    public URLStreamHandler createURLStreamHandler(String protocol) {
        if(protocol.equals("echo"))
            return new EchoURLStreamHandler();
        else
            return null;
    }
}

在客戶程式中，可以通過以下方式設置 EchoURLStreamHandlerFactory

URL.setURLStreamHandlerFactory(new EchoURLStreamHandlerFactory());
URL url=new URL("echo://localhost:8000");

3. 創建 EchoContentHandler 類及工廠類

URLConnection 類還提供了 getContent() 方法，它有兩種重載形式：

public Object getContent();
public Object getContent(Class[] classes);

第二個 getContent() 方法把伺服器發送的數據優先轉換為 classes 數組第一個元素指定的類型，如果轉換失敗，再嘗試轉換第二個元素指定的類型，以此類推

下例 HttpClient 演示處理伺服器發送的數據

public class HttpClient {
    
    public static void main(String args[]) throws IOException {
        URL url = new URL("http://www,javathinker.net/hello.htm");
        URlConnection connection = url.openConnection();
        //接收響應結果
        InputStream in = connection.getInputStream();
        Class[] types = {String.class, InputStream.class};
        Object obj = connection.getContent(types);
        
        if(obj instanceof String) {
            System.out.println(obj);
        } else if(obj instanceof InputStream) {
            in = (InputStream) obj;
            FileOutputStream file = new FileOutputStream("data");
            byte[] buff = new byte[1024];
            int len = -l;
            
            while((len = in.read(buff)) != -1) {
                file.write(buff, 0 ,len);
            }
            
            System.out.println("正文保存完畢");
        } else {
            System.out.println("未知的響應正文類型");
        }
    }
}

EchoContentHandler 類負責處理 EchoServer 伺服器發送的數據

public class EchoContentHandler extends ContentHandler {
    
    /** 讀取伺服器發送的一行數據，把它轉換為字元串對象 */
    public Object getContent(URLConnection connection) throws IOException {
    	InputStream in = connection.getInputStream();
        BufferedReader br = new BufferedReader(new InputStreamReader(in));
        return br.readLine();
    }
    
    public Object getContent(URLConnection connection, Class[] classes) throws IOException {
        InputStream in = connection.getInputStream();
        for(int i = 0; i < classes.length; i++) {
            if(classes[i] == InputStream.class) {
                return in;
            } else if(classes[i] == String.class) {
                return getContent(connection);
            }
        }
        return null;
    }
}

第二個 getContent() 方法依次遍歷 classes 參數中的元素，判斷元素是否為 InputSuream 類型或 String 類型，如果是，就返回相應類型的對象，它包含了伺服器發送的數據。如果 classes 參數中的元素都不是 InputStream 類型或 String 類型，就返回 null

EchoContentHandlerFactory 類的 createContentHandler() 方法負責創建一個EchoContentHandler 對象

public class EchoContentHandlerFactory implements ContentHandlerFactory {
    
    public ContentHandler createContentHandler(String mimetype) {
        if(mimetype.equals("text/plain")) {
            return new EchoContentHandler();
        } else {
            return null;
        }
    }
}

在客戶程式中，可以通過以下方式設置 EchoContentHandlerFactory

URLConnection.setContentHandlerFactory(new EchoContentHandlerFactory());
URL url = new URL("echo://localhost:8000");
EchoURLConnection connection = (EchoURLConnection)url.openConnection();
...
//讀取伺服器返回的數據，它被包裝為一個字元串對象
String echoMsg = (String)connection.getContent();

4. 在 EchoClient 類運用 ECHO 協議處理框架

public class EchoClient {
    
    public static void main(String args[]) throws IOException {
        //設置URLStreamHandlerFactory
        URL.setURLStreamHandlerFactory(new EchoURLStreamHandlerFactory());
        //設置ContentHandlerFactory
        URLConnection.setContentHandlerFactory(new EchoContentHandlerFactory());
        
        URL url = new URL("echo://localhost:8000");
        EchoURLConnection connection = (EchoURlConnection) url.openConnection();
        //允許獲得輸出流
        connection.setDoOutput(true);
        //獲得輸出流
        PrintWriter pw = new PrintWriter(connection.getOutputStream(), true);
        while(true) {
            BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
            String msg = br.readLine();
            //向伺服器發送消息
            pw.println(msg);
            //讀取伺服器返回的消息
            String echoMsg = (String) connection.getContent();
            System.out.println(echoMsg);
            if(echoMsg.equals("echo:bye")) {
                //斷開連接
                connection.disconnect();
                break;
            }
        }
    }
}


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

-Advertisement-
Play Games
更多相關文章
  • Android strings.xml按照key修改
    ## strings.xml匹配替換 將兩個Android項目中的多語言字元串文件（strings.xml）進行比較，如果其中一個項目中包含另一個項目沒有的字元，則合併到單一的輸出文件，並以 key 在原始 XML 文件中更新 value 值。如果key匹配不准確則忽略它。 具體來說： 1. 引入 ...
  • 記錄--讓URL地址都變成了"ooooooooo"
    這裡給大家分享我在網上總結出來的一些知識，希望對大家有所幫助 發現一個很有創意的小工具網站，如封面圖所示功能很簡單，就是將一個URL地址轉換為都是 ooooooooo 的樣子，通過轉換後的地址訪問可以轉換回到原始地址，簡單流程如下圖所示。轉換的邏輯有點像短鏈平臺一樣，只不過這個是將你的URL地址變的 ...
  • 各大免費托管平臺體驗有感
    **歷時一年多，我也體驗了不少的靜態博客托管服務了，這裡進行一下對比吧。主要列舉一下優缺點，所有的內容基於該平臺免費版，並且不添加任何增值服務的情況。 速度體驗基於浙江電信的個人測試結果。** # GitHub Pages > 速度：尚可，並不很慢，但有時候會抽風。 自定義功能變數名稱：一個。 限制： 單個 ...
  • 各大建站方案
    # 如何在 CloudFlare Pages 上建站？ > 幾分鐘、零基礎搭建個人網頁！- 高速直連，基於Cloudflare Page: `https://zhuanlan.zhihu.com/p/416269228` 使用 Cloudflare Worker 免費搭建網址導航網站 `https: ...
  • 為什麼會出現 setTimeout 倒計時誤差
    setTimeout 倒計時誤差的出現主要與 JavaScript 的事件迴圈機制和計時器的執行方式有關。 在 JavaScript 中，事件迴圈是用於管理和調度代碼執行的機制。setTimeout 函數用於設置一個定時器，在指定的延遲時間後執行回調函數。然而，由於事件迴圈的機制，setTimeou ...
  • 高解析度大圖像可縮放 Web 查看器的實踐
    # 高解析度大圖像可縮放 Web 查看器的實踐 ## 一、使用 vips 將高解析度大圖像轉換為 DZI 1. 安裝 vips 具體安裝步驟請參考[libvips Install](https://www.libvips.org/install.html)。 註意，在 windows 11 中安裝 ...
  • 一文搞懂前端的所有類數組類型
    前面博文有介紹JavaScript中數組的一些特性，通過對這些數組特性的深入梳理，能夠加深我們對數組相關知識的理解，詳見博文： [一文搞懂JavaScript數組的特性](https://www.cnblogs.com/jimojianghu/p/17292277.html) 其實，在前端開發中，除 ...
  • 設計模式詳解之抽象工廠模式--企業的運行模式
    # 前言 本文主要講述設計模式中的**抽象工廠模式**，文中使用通俗易懂的案例，使你更好的學習本章知識點並理解原理，做到有道無術。 # 一.什麼是抽象工廠模式 抽象工廠是23種設計模式中**創建型模式**的一種，抽象工廠是由多個工廠組合而成。 上一章我們提到的工廠模式只存在一個抽象角色，而抽象工廠是 ...
一周排行
    -Advertisement-
    Play Games
  • .NET 6 Entity Framework Core Db First（1） 創建模型
    .Net8.0 Blazor Hybird 桌面端 (WPF/Winform) 實測可以完整運行在 win7sp1/win10/win11. 如果用其他工具打包,還可以運行在mac/linux下, 傳送門BlazorHybrid 發佈為無依賴包方式 安裝 WebView2Runtime 1.57 M ...
  • 資料庫升級PostgreSql+Garnet
    目錄前言PostgreSql安裝測試額外Nuget安裝Person.cs模擬運行Navicate連postgresql解決方案Garnet為什麼要選擇Garnet而不是RedisRedis不再開源Windows版的Redis是由微軟維護的Windows Redis版本老舊，後續可能不再更新Garne ...
  • 如何基於surging架設流媒體視頻推流（視頻講解）
    C#TMS系統代碼-聯表報表學習 領導被裁了之後很快就有人上任了，幾乎是無縫銜接，很難讓我不想到這早就決定好了。我的職責沒有任何變化。感受下來這個系統封裝程度很高，我只要會調用方法就行。這個系統交付之後不會有太多問題，更多應該是做小需求，有大的開發任務應該也是第二期的事，嗯？怎麼感覺我變成運維了？而 ...
  • EAV模型（實體-屬性-值）的設計和低代碼的處理方案（2）--數據的查詢處理
    我在隨筆《EAV模型（實體-屬性-值）的設計和低代碼的處理方案（1）》中介紹了一些基本的EAV模型設計知識和基於Winform場景下低代碼（或者說無代碼）的一些實現思路，在本篇隨筆中，我們來分析一下這種針對通用業務，且只需定義就能構建業務模塊存儲和界面的解決方案，其中的數據查詢處理的操作。 ...
  • C# 程式集、模塊和類型概念及關係
    對某個遠程伺服器啟用和設置NTP服務(Windows系統) 打開註冊表 HKEY_LOCAL_MACHINE\SYSTEM\CurrentControlSet\Services\W32Time\TimeProviders\NtpServer 將 Enabled 的值設置為 1，這將啟用NTP伺服器功 ...
  • Django信號與擴展：深入理解與實踐
    title: Django信號與擴展：深入理解與實踐 date: 2024/5/15 22:40:52 updated: 2024/5/15 22:40:52 categories: 後端開發 tags: Django 信號 松耦合 觀察者 擴展 安全 性能 第一部分：Django信號基礎 Djan ...
  • Django3.2安裝源碼xadmin2步驟以及遇到的問題
    使用xadmin2遇到的問題&解決 環境配置： 使用的模塊版本： 關聯的包 Django 3.2.15 mysqlclient 2.2.4 xadmin 2.0.1 django-crispy-forms >= 1.6.0 django-import-export >= 0.5.1 django-r ...
  • 原創->CommonsCollections1-DefaultMap鏈
    今天我打算整點兒不一樣的內容，通過之前學習的TransformerMap和LazyMap鏈，想搞點不一樣的，所以我關註了另外一條鏈DefaultedMap鏈，主要調用鏈為： 調用鏈詳細描述： ObjectInputStream.readObject() DefaultedMap.readObject ...
  • 05-應用級開發者 AI 時代破局點
    後端應用級開發者該如何擁抱 AI GC？就是在這樣的一個大的浪潮下，我們的傳統的應用級開發者。我們該如何選擇職業或者是如何去快速轉型，跟上這樣的一個行業的一個浪潮? 0 AI金字塔模型 越往上它的整個難度就是職業機會也好，或者說是整個的這個運作也好,它的難度會越大,然後越往下機會就會越多,所以這是一 ...
  • Java面試題：讓依賴註入變得簡單，面對@Autowired和@Resource，該如何選擇？
    @Autowired是Spring框架提供的註解，@Resource是Java EE 5規範提供的註解。 @Autowired預設按照類型自動裝配，而@Resource預設按照名稱自動裝配。 @Autowired支持@Qualifier註解來指定裝配哪一個具有相同類型的bean，而@Resourc... ...
所有分類