2. 程式人生 > >Apache mina2 使用者指南（五）過濾器

Apache mina2 使用者指南（五）過濾器

阿新 • • 發佈：2019-01-23
IoFilter 扮演著很重要角色，它是 MINA 的核心結構之一。它過濾 IoService 和 IoHandler 之間的所有 I/O 事件和請求。如果你有網路應用程式設計的經驗，你完全可以把它當成 Servlet 過濾器的表兄弟。許多開箱即用的過濾器通過使用類似以下的開箱即用過濾器簡化橫切注入用來提升網路應用的開發速度：
  • LoggingFilter 記錄所有事件和請求
  • ProtocolCodecFilter 將一個連入的 ByteBuffer 轉化為訊息 POJO，反之亦然
  • CompressionFilter 壓縮所有資料
  • SSLFilter 新增 SSL - TLS - StartTLS 支援
  • 不止如此！
        本文我們將瞭解如何為一個真實案例實現一個 IoFilter。通常實現一個 IoFilter 是很簡單的，但你也需要 MINA 的內部細節。本文將對這些相關內部細節進行解釋。
現有的過濾器
        我們已經有很多寫好的過濾器了。下表列出了所有現有的過濾器，並在他們的用途方面進行簡要說明。



選擇事件重寫
        你可以對 IoAdapter 重寫以取代直接實現 IoFilter 的做法。除非重寫，否則所有接收到的事件將被直接轉發給下一個過濾器。
[java] view plain copy  print?在CODE上檢視程式碼片派生到我的程式碼片
  1. publicclass MyFilter extends
     IoFilterAdapter {  
  2.     @Override
  3.     publicvoid sessionOpened(NextFilter nextFilter, IoSession session) throws Exception {  
  4.         // Some logic here...
  5.         nextFilter.sessionOpened(session);  
  6.         // Some other logic here...
  7.     }  
  8. }  

轉換寫請求
        如果你要通過 IoSession.write() 對一個連入的寫請求進行轉換，事情可能會變得相當棘手。例如，假設你的過濾器在一個 HighLevelMessage 物件呼叫 IoSession.write() 時將 HighLevelMessage 轉換為 LowLevelMessage。你可以在你的過濾器的 filterWrite() 方法裡新增適當的轉換程式碼並認為一切就這樣了。但是你也需要注意 messageSent 事件，因為一個 IoHandler 或者任何之後的過濾器會期望 messageSent() 方法以 HighLevelMessage 作為引數呼叫，因為讓呼叫者在寫 HighLevelMessage 的時候被通知到 HighLevelMessage 已傳送是不合理的。因此，如果你的過濾器負責轉換時你最好同時實現 filterWrite() 和 messageSent()。

        另外還要注意的是，你仍舊需要實現類似的機制，即使輸入物件和輸出物件的型別是一樣的，因為 IoSession.write() 的呼叫者期望它的 messageSent() 處理器方法有一個具體物件。
        假定你在實現一個將字串轉換為字元陣列的過濾器。你的過濾器的 filterWrite() 將會類似於：
[java] view plain copy  print?在CODE上檢視程式碼片派生到我的程式碼片
  1. publicvoid filterWrite(NextFilter nextFilter, IoSession session, WriteRequest request) {  
  2.     nextFilter.filterWrite(  
  3.         session, new DefaultWriteRequest(  
  4.                 ((String) request.getMessage()).toCharArray(), request.getFuture(), request.getDestination()));  
  5. }  

        現在我們需要在 messageSent() 中做相反的事情：
[java] view plain copy  print?在CODE上檢視程式碼片派生到我的程式碼片
  1. publicvoid messageSent(NextFilter nextFilter, IoSession session, Object message) {  
  2.     nextFilter.messageSent(session, new String((char[]) message));  
  3. }  

        字串到位元組快取的轉換怎麼樣？這樣我們會更加高效，我們不在需要重建原始訊息 (字串)。但是，這比前面的例子複雜：
[java] view plain copy  print?在CODE上檢視程式碼片派生到我的程式碼片
  1. publicvoid filterWrite(NextFilter nextFilter, IoSession session, WriteRequest request) {  
  2.     String m = (String) request.getMessage();  
  3.     ByteBuffer newBuffer = new MyByteBuffer(m, ByteBuffer.wrap(m.getBytes());  
  4.     nextFilter.filterWrite(  
  5.             session, new WriteRequest(newBuffer, request.getFuture(), request.getDestination()));  
  6. }  
  7. publicvoid messageSent(NextFilter nextFilter, IoSession session, Object message) {  
  8.     if (message instanceof MyByteBuffer) {  
  9.         nextFilter.messageSent(session, ((MyByteBuffer) message).originalValue);  
  10.     } else {  
  11.         nextFilter.messageSent(session, message);  
  12.     }  
  13. }  
  14. privatestaticclass MyByteBuffer extends ByteBufferProxy {  
  15.     privatefinal Object originalValue;  
  16.     private MyByteBuffer(Object originalValue, ByteBuffer encodedValue) {  
  17.         super(encodedValue);  
  18.         this.originalValue = originalValue;  
  19.     }  
  20. }  

        如果你使用的是 MINA 2.0，這將跟 1.0 和 1.1 有所不同。同時也參考一下 CompressionFilter 和 RequestResponseFilter。
過濾 sessionCreated 事件時須謹慎
        sessionCreated 是一個特殊事件，它必須在 I/O 處理程式中執行 (參考 執行緒模型的配置)。決不允許將 sessionCreated 事件轉發給其他執行緒。
[java] view plain copy  print?在CODE上檢視程式碼片派生到我的程式碼片
  1. publicvoid sessionCreated(NextFilter nextFilter, IoSession session) throws Exception {  
  2.     // ...
  3.     nextFilter.sessionCreated(session);  
  4. }  
  5. // DON'T DO THIS!
  6. publicvoid sessionCreated(final NextFilter nextFilter, final IoSession session) throws Exception {  
  7.     Executor executor = ...;  
  8.     executor.execute(new Runnable() {  
  9.         nextFilter.sessionCreated(session);  
  10.         });  
  11.     }  

提防空快取！
        在一些案例中 MINA 使用了一個空的緩衝區作為一個內部訊號。空快取有時會成為一個問題，因為它可能會造成各種各樣的異常，比如 IndexOutOfBoundsException。這裡我們介紹如何避免類似於這種難以預料的情況。
        ProtocolCodecFilter 使用了一個空快取 (比如 buf.hasRemaining() = 0) 來標記訊息的結束部分。如果你的過濾器放在 ProtocolCodecFilter 之前，如果你的過濾器實現在快取為空時能丟擲一個異常的話，請確認你的過濾器將空快取轉發給了下一個過濾器：
[java] view plain copy  print?在CODE上檢視程式碼片派生到我的程式碼片
  1. publicvoid messageSent(NextFilter nextFilter, IoSession session, Object message) {  
  2.     if (message instanceof ByteBuffer && !((ByteBuffer) message).hasRemaining()) {  
  3.         nextFilter.messageSent(nextFilter, session, message);  
  4.         return;  
  5.     }  
  6.     ...  
  7. }  
  8. publicvoid filterWrite(NextFilter nextFilter, IoSession session, WriteRequest request) {  
  9.     Object message = request.getMessage();  
  10.     if (message instanceof ByteBuffer && !((ByteBuffer) message).hasRemaining()) {  
  11.         nextFilter.filterWrite(nextFilter, session, request);  
  12.         return;  
  13.     }  
  14.     ...  
  15. }  

        這樣的話，我們是否總是要為每個過濾器插入 if 塊？幸運的是，不需要。這是處理空快取的黃金法則：
  • 如果你的過濾器及時在快取為空時也能正常工作，你就完全不需要新增 if 塊了
  • 如果你的過濾器放在 ProtocolCodecFilter 之後，你也不需要新增 if 塊
  • 除此之外的話你就需要 if 塊了
        如果你需要加 if 塊，記著你不總是需要遵循上面例子所講的。你可以在任何地方檢查快取是否為空，只要你的過濾器不會丟擲異常。譯者注：之所以如此這般謹慎處理，是因為一旦在過濾器中丟擲異常，當前執行緒即消亡，負責該項業務處理的邏輯將會出席問題，因為後續過濾器無法對其進行繼續處理。
原文連結：http://mina.apache.org/mina-project/userguide/ch5-filters/ch5-filters.html。

相關推薦

Apache mina2 使用者指南（五）過濾器

IoFilter 扮演著很重要角色，它是 MINA 的核心結構之一。它過濾 IoService 和 IoHandler 之間的所有 I/O 事件和請求。如果你有網路應用程式設計的經驗，你完全可以把它當成 Servlet 過濾器的表兄弟。許多開箱即用的過濾器通過使用類似以下的

Apache mina2使用者指南（一）

Apache MINA 2.0 使用者指南》系列部落格總序         《Apache MINA 2.0 使用者指南》取材自 Apache 官方指南，共分十七章，此係列部落格完本後，筆者會整理一份中英文對照閱讀的 PDF 文件，屆時將公佈下載地址。敬請期待。 《Apa

小橙書閱讀指南（五）——歸並排序的兩種實現

system .so generator tor ide ret style 鏈接 步長 算法描述：將兩個較小的有序數組合並成為一個較大的有序數組是比較容易的事情。我們只需要按照相同的順序依次比較最左側的元素，然後交替的放進新數組即可。這就是自頂向下的歸並排序的實現思路。與

Vue初體驗（五）過濾器的使用

Vue.js 允許你自定義過濾器，被用作一些常見的文字格式化。使用格式為： <!-- 在兩個大括號中 -->{{ me

AngularJS學習（五）——過濾器

angular過濾器：可以用一個管道字元（|）新增到指令或表示式中，進行篩選而且可以為表示式或指令新增多個過濾器 內建過濾器： （1）currency：格式化數字或貨幣形式 （2）lowercase：轉為字串小寫 （3）uppercase：字串大寫 （4）order

Sqlmap使用指南（五）

本文是使用指南四的簡化版 基本步驟 sqlmap -u “http://url/news?id=1” –current-user #獲取當前使用者名稱稱 sqlmap -u “http://www.xxoo.com/news?id=1” –current-

圖解HTTP權威指南（五） | HTTP快取

作者簡介 李先生（Lemon），高階運維工程師（自稱），SRE專家（目標），夢想在35歲買一輛保時捷。喜歡鑽研底層技術，認為底層基礎才是王道。一切新技術都離不開作業系統（CPU、記憶體、磁碟）、網路等。堅持輸入輸出，記錄自己學習的點滴，在平凡中堅持前行，總有一天會遇見不一樣的自己。公眾號：運維汪（ID

設計模式學習總結（五）創建者模式(Builder)

lose etl bfc .get splay hid 定義 string ogr 　　創建者模式，主要針對某些產品有類似的生產步驟，且有需要有先後順序的進行各個部件的生成。 　　一、示例展示： 　　通過學習及總結，以下是我完成的創建者模式的示例： 　　1.創建產品類：La

C#設計模式之五創建者模式（Builder）【創建型】

包含 direct linq 自然 解釋 並且 宋體 主板 但是 一、引言 今天我們要講講Builder模式，也就是建造者模式，當然也有叫生成器模式的。在現實生活中，我們經常會遇到一些構成比較復雜的物品，比如：電腦，它就是一個復雜的物品，它主要是由CPU、主板、硬盤、顯卡

Vue教程：過濾器filters（五）

字符 語法 number vue mat params ber ssa for Vue.js 允許你自定義過濾器，可被用於一些常見的文本格式化。過濾器可以用在兩個地方：雙花括號插值和 v-bind 表達式 (後者從 2.1.0+ 開始支持)。過濾器應該被添加在 JavaSc

Apache Shiro（五）——Shiro會話管理

一、概述 Shiro 提供了完整的企業級會話管理功能，不依賴於底層容器（如web容器tomcat），不管 JavaSE 還是 JavaEE 環境都可以使用，提供了會話管理、會話事件監聽、會話儲存/持久化、容器無關的叢集、失效/過期支援、對Web 的透明支援、SSO 單點登入的支援等特

設計模式（五）Builder Pattern建造者模式

在我們日常生活中，如構建一個飛船，一個手機，一棟建築，都會有非常複雜的組裝，這時候應該用到建造者模式 以建造一個飛船為例  案例：造小頁飛船 1.飛船各部分元件 package com.littlepage.BuilderPattern; public interface AirSh

Java原始碼分析——java.util工具包解析（五）——UUID、Base64、內建觀察者模式Observer介面、EventListener、RandomAccess

UUID     關於UUID，我們需要知道它最重要的一點，就是它會生成全地球唯一的一個id，它可以作為資料庫的主鍵存在，標識各個元組。 UUID保證對在同一時空中的所有機器都是唯一的，利用機器的當前日期和時間、時鐘序列、全域性唯一的IEEE機

STM32開發筆記51：STM32F4+DP83848乙太網通訊指南系列（五）：MAC+DMA配置

本章為系列指南的第五章，講述STM32F407上MAC層以及其DMA的配置。我們在第一章知識儲備章節說到，STM32F407會在168MHz主頻之外分配一定的時間釋放匯流排資料用來處理DMA，這其中就包含MAC層的DMA，複習一下STM32F4的匯流排架構圖，（圖片來自RM0090ST中文STM32

（五）Vue動畫操作和過濾器

一：CSS的動畫 (1) 操作 css 的 trasition 或 animation (2) vue 會給目標元素新增/移除特定的 class (3) 過渡的相關類名 xxx-enter-active: 指定顯示的 transition xxx-leave-active: 指定隱藏的 transi

爬蟲入門系列（五）：正則表示式完全指南（上）

爬蟲入門系列目錄： 正則表示式處理文字有如疾風掃秋葉，絕大部分程式語言都內建支援正則表示式，它應用在諸如表單驗證、文字提取、替換等場景。爬蟲系統更是離不開正則表示式，用好正則表示式往往能收到事半功倍的效果。 介紹正則表示式前，先來看一個問題，下面這段文字來自豆瓣的某個網頁連結，我對內容

設計模式（五）——建造者模式

1. 定義 建造者模式是將一個複雜物件的構建與它的表示分離，使得同樣的構建過程可以建立不同的表示。 在使用者不知道物件的建造過程和細節的情況下就可以直接建立複雜的物件。 2. 建造者模式通常包括下面幾個角色： （1）Builder：給出一個抽象介面，以規範產品物件的各個組成成分的建造

Python自學指南---基礎篇（五）資料型別-Number

前一節中，我們對Python中的物件有了一個基本的瞭解。從本節開始，我們將分別瞭解不同型別的物件，並且對不同物件的特點，特別是物件有關的函式進行介紹。 本節將會介紹數字型別，也就是Number型別，在Python中是一種不可變型別。 5.1 整數 Python能

《技術人求職指南》（五）如何高效面試

作者：方騰飛  原文首發於極客時間 方 騰飛花名清英，併發網(ifeve.com)創始人，暢銷書《Java併發程式設計的藝術》作者，螞蟻金服技術專家。目前工作於支付寶微貸

python手記（四）：pillow（五）最後一篇：過濾器，截圖。

人生不易且無趣，一起找點樂子吧。歡迎評論，和文章無關也可以。       這篇就當pillow的最後一篇好了，後面的模組沒有前面的有趣，主要是一些細節上的處理，例如圖片的文字啊，文字的型別啊。 無非就是告訴你很多東西都可以自定義，建立你自己的個性