csusky

          常用鏈接

          統計

          最新評論

          2008年10月27日 #

          異步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 曉宇 閱讀(425) | 評論 (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 曉宇 閱讀(1560) | 評論 (0)編輯 收藏

          ORACLE的塊大小

          參數db_block_size;
          這個參數只能設置成底層操作系統物理塊大小的整數倍,最好是2的n次方倍。
          如WINDOWS下4KB,8KB,16KB
          且該參數需要在建庫的時候指定,一旦指定不能更改。
          雖然在ORACLE9I以上可以指定表空間的數據庫大小,允許同時使用包括非默認大小在內的數據庫塊大小。不過需要設置指定大小數據塊的buffer_cache.

          小的塊:
          小的塊降低塊競爭,因為每個塊中的行較少.
          小的塊對于小的行有益.
          小的塊對于隨意的訪問較好.如果一個塊不太可能在讀入內存后被修改,那么塊的大小越小使用buffer cache越有效率。當內存資源很珍貴時尤為重要,因為數據庫的buffer cache是被限制大小的。
          劣勢:
          小塊的管理消費相對大.
          因為行的大小你可能只在塊中存儲很小數目的行,這可能導致額外的I/O。
          小塊可能導致更多的索引塊被讀取

          大的塊
          好處:
          更少的管理消費和更多存儲數據的空間.
          大塊對于有順序的讀取較好.  譬如說全表掃描
          大塊對很大的行較好
          大塊改進了索引讀取的性能.大的塊可以在一個塊中容納更多的索引條目,降低了大的索引級的數量.越少的index level意味著在遍歷索引分支的時候越少的I/O。
          劣勢:
          大塊不適合在OLTP中用作索引塊,因為它們增加了在索引葉塊上的塊競爭。
          如果你是隨意的訪問小的行并有大的塊,buffer cache就被浪費了。例如,8 KB的block size 和50 byte row size,你浪費了7,950



           

          posted @ 2008-11-25 15:45 曉宇 閱讀(1769) | 評論 (0)編輯 收藏

          TIPS

          將進酒  杯莫停  -------> 亭名:  悲默亭

          全球通史

          《詩經·采薇》

          昔我往矣,楊柳依依 今我來思,雨雪霏霏

          posted @ 2008-11-10 16:31 曉宇 閱讀(186) | 評論 (0)編輯 收藏

          SPRING整合IBMMQ實現全局事物

               摘要: <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans"     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance...  閱讀全文

          posted @ 2008-10-27 17:01 曉宇 閱讀(2414) | 評論 (0)編輯 收藏

          主站蜘蛛池模板: 辽宁省| 双桥区| 大宁县| 洪江市| 迭部县| 微山县| 安陆市| 辰溪县| 广昌县| 五台县| 宕昌县| 黑水县| 临海市| 津南区| 大荔县| 扶绥县| 昌宁县| 莱阳市| 星座| 盐山县| 临桂县| 福清市| 札达县| 页游| 建湖县| 勐海县| 克东县| 三明市| 三门县| 涡阳县| 普宁市| 陵川县| 武宁县| 双牌县| 茶陵县| 乌兰浩特市| 万安县| 漳平市| 耿马| 长寿区| 南通市|