MINA框架原始碼分析(二)

上一篇我們通過例項學習了MINA框架的用法，發現用起來還是挺方便的，就那麼幾步就可以了，本著學東西必知其原理的觀念，決定看看MINA的原始碼實現，好了，我們開始吧！

MINA原始碼對於客戶端和服務端來說基本上差別不是很大的，所以我計劃主要還是分析服務端的原始碼，在正式分析之前，我們需要對MINA有一個整體的瞭解；

MINA中涉及到了這麼幾個物件：

IoService：用於提供連線，他是IoAcceptor和IoConnector的父介面；

IoBuffer：訊息快取區；

IoSession：在每一次連線建立成功之後都會建立一個IoSession物件出來，並且在建立該物件的時候建立一個IoFilter物件出來，通過IoSession的session id來為當前IoSession設定處理他的IoProcessor;

IoProcessor：用於檢查是否有資料在通道上面進行讀寫，在我們建立Acceptor或者Connector的時候，預設會建立一個執行緒池，裡面儲存的就是IoProcessor執行緒，該執行緒裡面是擁有自己的Selector的，這個是MINA為我們做的一點優化，我們通常使用NIO的話是隻有一個Selector的，而MINA中的

IoFilter：用於定義攔截器，這些攔截器可以包括日誌輸出、資料編解碼等等，只要用於二進位制資料和物件之間的轉換；

IoHandler：處於IoFilter的尾部，用於真正的業務邏輯處理，所以我們在使用MINA的時候是必須要提供IoHandler物件的，因為是靠他來進行真正業務處理的；

接下來我們看看上篇部落格中我們用到的MINA中涉及到的這幾個物件的類結構圖：

NioSocketAcceptor類結構圖：

NioSocketConnector類結構圖：

NioSocketSession類結構圖：

NioProcessor類結構圖：

好了，開始我們真正的原始碼分析了(服務端)；

首先我們通過NioSocketAcceptor acceptor = new NioSocketAcceptor();建立了一個NioSocketAcceptor物件出來，那我們就得看看NioSocketAcceptor的建構函式裡面做了些什麼事了；

NioSocketAcceptor$NioSocketAcceptor()

public NioSocketAcceptor() {
super(new DefaultSocketSessionConfig(), NioProcessor.class);
((DefaultSocketSessionConfig) getSessionConfig()).init(this);
}

可以看到首先呼叫了父類的建構函式，也就是AbstractPollingIoAcceptor的建構函式，並且傳入了NioProcessor的Class物件，這裡我們可以想象一下後面肯定會用這個NioProcessor的Class物件進行一些與反射有關的操作；

AbstractPollingIoAcceptor$AbstractPollingIoAcceptor()

protected AbstractPollingIoAcceptor(IoSessionConfig sessionConfig, Class<? extends IoProcessor<S>> processorClass) {
this(sessionConfig, null, new SimpleIoProcessorPool<S>(processorClass), true, null);
}

可以看到實際上呼叫的是5個引數的建構函式，在看這個建構函式之前，我們看到第三個引數利用我們從NioSocketAcceptor建構函式中傳進來的NioProcessor物件，建立了一個SimpleIoProcessorPool物件，我們來看看SimpleIoProcessorPool的建構函式；
SimpleIoProcessorPool$SimpleIoProcessorPool()

public SimpleIoProcessorPool(Class<? extends IoProcessor<S>> processorType) {
this(processorType, null, DEFAULT_SIZE, null);
}

發現他接著呼叫的是SimpleIoProcessorPool四個引數的建構函式，並且添加了一個DEFAULT_SIZE引數，這個值的大小等於我們CPU的核數+1，這也是我們在建立NioSocketAcceptor的時候預設建立的NioProcessor的執行緒個數，來看看SimpleIoProcessorPool四個引數的建構函式：

public SimpleIoProcessorPool(Class<? extends IoProcessor<S>> processorType, Executor executor, int size,
SelectorProvider selectorProvider) {
if (processorType == null) {
thrownew IllegalArgumentException("processorType");
}
if (size <= 0) {
thrownew IllegalArgumentException("size: " + size + " (expected: positive integer)");
}
// Create the executor if none is provided
createdExecutor = (executor == null);
if (createdExecutor) {
this.executor = Executors.newCachedThreadPool();
// Set a default reject handler
((ThreadPoolExecutor) this.executor).setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
} else {
this.executor = executor;
}
pool = new IoProcessor[size];
boolean success = false;
Constructor<? extends IoProcessor<S>> processorConstructor = null;
boolean usesExecutorArg = true;
try {
// We create at least one processor
try {
try {
processorConstructor = processorType.getConstructor(ExecutorService.class);
pool[0] = processorConstructor.newInstance(this.executor);
} catch (NoSuchMethodException e1) {
// To the next step...
try {
if(selectorProvider==null) {
processorConstructor = processorType.getConstructor(Executor.class);
pool[0] = processorConstructor.newInstance(this.executor);
} else {
processorConstructor = processorType.getConstructor(Executor.class, SelectorProvider.class);
pool[0] = processorConstructor.newInstance(this.executor,selectorProvider);
}
} catch (NoSuchMethodException e2) {
// To the next step...
try {
processorConstructor = processorType.getConstructor();
usesExecutorArg = false;
pool[0] = processorConstructor.newInstance();
} catch (NoSuchMethodException e3) {
// To the next step...
}
}
}
} catch (RuntimeException re) {
LOGGER.error("Cannot create an IoProcessor :{}", re.getMessage());
throw re;
} catch (Exception e) {
String msg = "Failed to create a new instance of " + processorType.getName() + ":" + e.getMessage();
LOGGER.error(msg, e);
thrownew RuntimeIoException(msg, e);
}
if (processorConstructor == null) {
// Raise an exception if no proper constructor is found.
String msg = String.valueOf(processorType) + " must have a public constructor with one "
+ ExecutorService.class.getSimpleName() + " parameter, a public constructor with one "
+ Executor.class.getSimpleName() + " parameter or a public default constructor.";
LOGGER.error(msg);
thrownew IllegalArgumentException(msg);
}
// Constructor found now use it for all subsequent instantiations
for (int i = 1; i < pool.length; i++) {
try {
if (usesExecutorArg) {
if(selectorProvider==null) {
pool[i] = processorConstructor.newInstance(this.executor);
} else {
pool[i] = processorConstructor.newInstance(this.executor, selectorProvider);
}
                    } else {

相關推薦

MINA框架原始碼分析(二)

上一篇我們通過例項學習了MINA框架的用法，發現用起來還是挺方便的，就那麼幾步就可以了，本著學東西必知其原理的觀念，決定看看MINA的原始碼實現，好了，我們開始吧！        MINA原始碼對於客戶端和服務端來說基本上差別不是很大的，所以我計劃主要還是分析服務端的原始碼

JDK1.8集合框架原始碼分析二-------------LinkedList

0.LinkedList特點 0.1) 刪除或新增效率高：不會移動資料元素，只會維護內部節點的關係 0.2) 查詢慢: 在其內部沒有下標，也即沒有索引，需要使用for迴圈遍歷,LInkedList為了提高效率，

Spark RPC 框架原始碼分析（二）執行時序

前情提要： Spark RPC 框架原始碼分析（一）簡述一. Spark RPC 概述概述上一篇我們已經說明了 Spark RPC 框架的一個簡單例子，以及一些基本概念的說明。這一篇我們主要講述其執行時序，從而揭露 Spark RPC 框架的執行原理。我們將分為兩部分，分別從服務端和客戶端

ABP原始碼分析二十六：核心框架中的一些其他功能

本文是ABP核心專案原始碼分析的最後一篇，介紹一些前面遺漏的功能 AbpSession AbpSession: 目前這個和CLR的Session沒有什麼直接的聯絡。當然可以自定義的去實現IAbpSession使之與CLR的Session關聯 IAbpSession：定義如下圖中的四個屬性。 NullA

InstantRun框架原始碼分析之二

4, onCreate BootstrapApplication的onCreate方法如下, public void onCreate() { if (!AppInfo.usingApkSplits) { MonkeyPatcher.monkeyPatchApp

NSQ原始碼分析(二）—— Topic

Topic是NSQ非常重要的概念，本次主要講述Topic的獲取、新建、Topic中訊息的輪詢、Topic中訊息的來源、Topic的刪除和退出以及Topic的暫停和取消暫停 topic的相關操作主要在nsq/nsqd/topic.go中首先看下Topic結構體 type Topic st

Django rest framework 許可權操作(原始碼分析二)

知識回顧這一篇是基於上一篇寫的，上一篇謝了認證的具體流程，看懂了上一篇這一篇才能看懂，當用戶訪問是首先執行dispatch函式，當執行當第二部時： #2.處理版本資訊處理認證資訊處理許可權資訊對使用者的訪問頻率進行限制 self

spring原始碼分析(二):外部配置檔案的載入

@PropertySource 和@Profile 簡介： @PropertySource：用在類上，載入一個（*.properties）的配置檔案 @Profile:用在類或者方法上，指定元件在哪個環境的情況下才能被註冊到容器中，不指定，任何環境下都能註冊這個元件使用案例1-

spring原始碼分析(二):bean元件賦值

文章目錄常用註解 @Value和@PropertySource 介紹使用案例 @AutoWired、@Qulifer 、@Primary 介紹使用總結

laravel框架原始碼分析（一）自動載入

一、前言　　使用php已有好幾年，laravel的使用也是有好長時間，但是一直對於框架原始碼的理解不深，原因很多，歸根到底還是php基礎不紮實，所以原始碼看起來也比較吃力。最近有時間，所以開啟第5、6遍的框架原始碼探索之旅，前面幾次都是看了一些就放棄，希望這次能夠看完。每一次看原始碼都會有新的收穫，因為框

RxJava2原始碼分析二之just、fromArray、fromIterable

Observable.just：接收1個以上,10個以下的引數，然後逐個發射。 Observable.fromArray：接收一個數組，從陣列中一個一個取出來發射。

最新版ffmpeg原始碼分析二:transcode()函式

還是先看一下主函式吧:(省略了很多無關大雅的程式碼) int main(int argc, char **argv) { OptionsContext o = { 0 }; int64_t ti; //與命令列分析有關

JDK1.8集合框架原始碼分析一-------------ArrayList

1.ArrayList初始化 1.1 無參建構函式，預設一個空陣列 1.2 帶容量的有參建構函式：根據容量引數的值範圍來初始化 1.3 原始碼中陣列預設的初始容量

Glide原始碼分析(二)---執行

吐槽為啥csdn的排名一直沒有什麼變化啊emmmmm，這幾天5公里夜跑跑的越來越快，越來越接近25分鐘了，趕緊學習啊啊啊啊，自己真的還差好遠啊啊啊看原始碼的感想看到郭神部落格上面的寫的：那麼，雖然原始碼的複雜程度是外在的不可變條件，但我們卻可以通過一些

ArrayList的原始碼分析(二)

上篇文章給大家介紹了arraylist集合原始碼的一些屬性和擴容方式add方法,接下來再和大家來聊聊這個集合的一些原始碼首先看看remove的方法,這個方法有兩個,一個是根據下標刪除物件,一個是根據物件刪除 rangeCheck(index);是一個判斷index引數的規範的,如果太長或者

java集合原始碼分析(二)---ListIterator與Iterator

吐槽早上起來刷牙洗臉洗頭髮後，正準備去上課，然後發現今天早上好像不上課emmmmmm，然後就早上繼續看下java集合方面的原始碼了吼吼吼 Iterator 上次好像說過一點這個，然後繼續複習下這個還是先看下官方文件然後我們發現這個東西就是個功能很少但很

React原始碼分析(二)-元件的初始渲染

上一篇文章講到了React 呼叫ReactDOM.render首次渲染元件的前幾個過程的原始碼, 包括建立元素、根據元素例項化對應元件, 利用事務來進行批量更新. 我們還穿插介紹了React 事務的實現以及如何利用事務進行批量更新的實現. 這篇文章我們接著分析後面的過程,

原始碼分析篇之String原始碼分析二

    前面已經分析過String原始碼為什麼是不可變的，同時通過我們常用的String的相關的類StringBuffer和StringBuilder，我們可以發現String類中欄位名被定義為了final型別，這樣的話將只能被賦值一次。接下來，繼續看String原始碼實現的

JDK1.8集合框架原始碼分析三-------------HashMap

1.HashMap的一些重要成員屬性 1.1) 預設的初始容量 DEFAULT_INITIAL_CAPACITY = 1 << 4，官方建議必須時2的次方數   1.2) 負載因子

Spring 原始碼分析(二) —— 核心容器

容器概述   IoC也被稱作依賴注入(DI)。它是一個處理物件依賴項的過程，也就是將他們一起工作的其他的物件，只有通過構造引數、工廠方法引數或者（屬性注入）通過構造引數例項化或通過工廠方法返回物件後再設定屬性。當建立bean後，IoC容器再將這些依賴項注入進去。這個

MINA框架原始碼分析(二)

相關推薦