csusky

導(dǎo)航

<

2009年11月

>

日

一

二

三

四

五

六

25

26

27

28

29

30

31

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

1

2

3

4

5

留言簿(2)

隨筆分類(lèi)

隨筆檔案

閱讀排行榜

評(píng)論排行榜

常用鏈接

統(tǒng)計(jì)

隨筆 - 32
文章 - 0
評(píng)論 - 5
引用 - 0

異步IO的關(guān)閉事件

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;

是沒(méi)有關(guān)閉事件的，我們?cè)趺磁袛嘁粋€(gè)連接是否關(guān)閉呢？
如果你的selector注冊(cè)了一個(gè)OP_READ事件，那么在連接關(guān)閉的時(shí)候?qū)?huì)產(chǎn)生一個(gè)OP_READ事件
也就是說(shuō)本來(lái)阻塞的selector此時(shí)將會(huì)被喚醒，但是如果試圖在此事件的通道中讀取數(shù)據(jù)將會(huì)返回-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();

//此時(shí)將會(huì)得到-1，表明該鏈接已關(guān)閉

int n = incomingChannel.read(readBuffer);

}

此時(shí)我們需要取消該KEY 如下：

if (n == -1)

{

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

}

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