上文的內容還有一些沒有結尾,這篇補上。在expiringmap類中,使用了乙個私有內部類expiringobject來表示待檢查超時的物件,它包括三個域,鍵,值,上次訪問時間,以及用於上次訪問時間這個域的讀寫鎖:
private k key;
private v value;
private long lastaccesstime;
private final readwritelock lastaccesstimelock = new reentrantreadwritelock();
而expiringmap中包括了下述幾個變數:
private final concurrenthashmapdelegate;//超時**集合,儲存待檢查物件
private final copyonwritearraylist> expirationlisteners;//超時監聽者
private final expirer expirer;//超時檢查執行緒
現在再來看看iosession的乙個抽象實現類abstractiosession。這是它的幾個重要的成員變數:
private iosessionattributemap attributes;//會話屬性對映圖
private writerequestqueue writerequestqueue;//寫請求佇列
private writerequest currentwriterequest;//當前寫請求
當要結束當前會話時,會傳送乙個乙個寫請求close_request。而closefuture這個closefuture會在連線關閉時狀態被設定為」closed」,它的***是scheduled_counter_resetter。
close和closeonflush都是非同步的關閉操作,區別是前者立即關閉連線,而後者是在寫請求佇列中放入乙個close_request,並將其即時重新整理出去,若要真正等待關閉完成,需要呼叫方在返回的closefuture等待
public final closefuture close() else
}getfilterchain().firefilterclose();//fire出關閉事件
return closefuture;
}public final closefuture closeonflush()
下面來看看讀資料的過程:
public final closefuture close() else
}getfilterchain().firefilterclose();//fire出關閉事件
return closefuture;
}public final closefuture closeonflush()
private queuegetreadyreadfutures()
}return readyreadfutures;
}public final readfuture read()
queuereadyreadfutures = getreadyreadfutures();//獲取已經可被讀資料佇列
readfuture future;
synchronized (readyreadfutures)
} else
}return future;
}
public final writefuture write(object message, socketaddress remoteaddress)
else if (message instanceof filechannel)
else if (message instanceof file)
} catch (ioexception e)
writefuture future = new defaultwritefuture(this);
getfilterchain().firefilterwrite(
new defaultwriterequest(message, future, remoteaddress)); //構造寫請求,通過過濾器鏈傳送出去,寫請求中指明了要傳送的訊息,目的位址,以及返回的結果
//如果開啟了乙個檔案通道(傳送的檔案的部分區域或全部),就必須在寫請求完成時關閉檔案通道
if (openedfilechannel != null) catch (ioexception e)
}});
}return future;//寫請求成功完成
}
最後,來看看乙個writerequestqueue的實現,唯一加入的乙個功能就是若在隊頭發現是請求關閉,則會去關閉會話。
private class closerequestawarewriterequestqueue implements writerequestqueue
public synchronized writerequest poll(iosession session)
return answer;
}public void offer(iosession session, writerequest e)
public boolean isempty(iosession session)
public void clear(iosession session)
public void dispose(iosession session)
}
出處:
Mina2 0框架原始碼剖析(六)
上文的內容還有一些沒有結尾,這篇補上。在expiringmap類中,使用了乙個私有內部類expiringobject來表示待檢查超時的物件,它包括三個域,鍵,值,上次訪問時間,以及用於上次訪問時間這個域的讀寫鎖 private kkey private vvalue private long las...
Mina2 0框架原始碼剖析(二)
其中有乙個idlestatuschecker成員,它用來對服務的空閒狀態進行檢查,在乙個服務啟用時會將服務納入到檢查名單中,而在服務失效時會將服務從名單中剔除。會單獨開乙個執行緒進行具體的空閒檢查,這是通過下面這個執行緒類來負責的 具體的空閒檢查 如下,超過能容忍的最大空閒時間,就會fire出ses...
Mina2 0框架原始碼剖析(三)
abstractioacceptor類繼承自abstractioservice基類,並實現了ioacceptor介面,它主要的成員變數是本地繫結位址。在呼叫bind或unbind方法時需要先獲取繫結鎖bindlock,具體的繫結操作還是在bind0這個方法中實現的。一旦繫結成功後,就會向服務監聽者發...