csusky

留言簿(2)

隨筆分類

隨筆檔案

閱讀排行榜

評論排行榜

常用鏈接

統計

隨筆 - 32
文章 - 0
評論 - 5
引用 - 0

異步IO的關閉事件

JAVA SOCKET只定義了四種事件

public static final int OP_READ = 1 << 0;

public static final int OP_WRITE = 1 << 2;

public static final int OP_CONNECT = 1 << 3;

public static final int OP_ACCEPT = 1 << 4;

是沒有關閉事件的，我們怎么判斷一個連接是否關閉呢？
如果你的selector注冊了一個OP_READ事件，那么在連接關閉的時候將會產生一個OP_READ事件
也就是說本來阻塞的selector此時將會被喚醒，但是如果試圖在此事件的通道中讀取數據將會返回-1
如下：

Set<SelectionKey> readyKeys = selector.selectedKeys();

i = readyKeys.iterator()

SelectionKey key = (SelectionKey)i.next();

if (operation == SelectionKey.OP_READ &&

key.isReadable())

{

ReadableByteChannel incomingChannel = (ReadableByteChannel)key.channel();

//此時將會得到-1，表明該鏈接已關閉

int n = incomingChannel.read(readBuffer);

}

此時我們需要取消該KEY 如下：

if (n == -1)

{

                key.cancel();
                  //關閉輸入輸出
                  sc.socket().shutdownOutput();
                  sc.socket().shutdownInput();
                   //關閉SOCKET
                   sc.socket().close();
                  //關閉通道
                   incomingChannel.close();

}

posted @ 2009-11-10 22:28 曉宇閱讀(431) | 評論 (1) | 編輯收藏

ExecutorFilter

1 . 用Executors構造一個新的線程池

ExecutorService executor = Executors.newCachedThreadPool();

方法 newCachedThreadPool();
創建一個可根據需要創建新線程的線程池，但是在以前構造的線程可用時將重用它們，并在需要時使用提供的 ThreadFactory 創建新線程。
2. 用構造的線程池創建ExecutorFilter

ExecutorFilter es= new ExecutorFilter(executor));

在ExecutorFilter內部:
只需要將相應的事件分發到到線程池的相應線程即可，但是SessionCreated事件只能在主線程中，不能分發
觸發方法
1 .
首先構造一個IoFilterEvent，這個IoFilterEvent包含1、事件的類型，2、下一個過濾器
然后觸發該時間的處理方法。

if (eventTypes.contains(IoEventType.SESSION_OPENED)) {

fireEvent(new IoFilterEvent(nextFilter, IoEventType.SESSION_OPENED,

session, null));

}

2 .
從線程池中取出一個線程執行事件處理

protected void fireEvent(IoFilterEvent event) {

getExecutor().execute(event);

}

在構造ExecutorFilter 時如果沒有傳入IoEventType則默認只對如下幾種幾件感興趣
EXCEPTION_CAUGHT
MESSAGE_RECEIVED
MESSAGE_SENT
SESSION_CLOSED
SESSION_IDLE
SESSION_OPENED
當然還需要覆蓋相應的事件處理方法如上所示

posted @ 2008-12-12 11:33 曉宇閱讀(1566) | 評論 (0) | 編輯收藏