<rt id="bn8ez"></rt>
<label id="bn8ez"></label>

  • <span id="bn8ez"></span>

    <label id="bn8ez"><meter id="bn8ez"></meter></label>

    csusky

    常用鏈接

    統計

    最新評論

    2008年12月12日 #

    異步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();

    = 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 曉宇 閱讀(424) | 評論 (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 曉宇 閱讀(1557) | 評論 (0)編輯 收藏

    主站蜘蛛池模板: 69成人免费视频| 全亚洲最新黄色特级网站 | 亚洲欧洲自拍拍偷午夜色无码| 大地影院MV在线观看视频免费| 亚洲AV综合永久无码精品天堂 | 国内精自视频品线六区免费 | 免费看黄网站在线看| 国产成人免费ā片在线观看老同学| 在线观看免费播放av片| 亚洲一区二区三区自拍公司| 中文字幕在线观看免费| 四色在线精品免费观看| 亚洲国产精品久久久久婷婷老年 | 亚洲午夜AV无码专区在线播放 | 国内永久免费crm系统z在线| 亚洲午夜无码久久久久| 国产一区二区免费视频| 免费a级黄色毛片| 亚洲不卡中文字幕| 91视频精品全国免费观看| 免费国产在线观看| 一个人看的免费高清视频日本| 国产高清对白在线观看免费91| 一级免费黄色大片| 亚洲欧洲精品无码AV| 免费无码一区二区三区| 亚洲中文字幕视频国产| 免费无码av片在线观看| 337p欧洲亚洲大胆艺术| 免费国产成人18在线观看| 亚洲精品一区二区三区四区乱码| 最新国产成人亚洲精品影院| 久久国产免费观看精品| 亚洲白嫩在线观看| 国产在线19禁免费观看国产| 亚洲精品无码高潮喷水A片软| 91av免费在线视频| 亚洲综合精品一二三区在线| 88xx成人永久免费观看| 亚洲国产精品线在线观看| 免费看黄视频网站|