北國狼人的部落格

隨筆-159 評論-114 文章-7 trackbacks-0

用戶NIO寫服務器，必須多加處理OP_WRITE，不會丟包

服務器往外發數據包，不是光一個socketChannel.write(bb); 就完事了

那是理想狀態。。

用我方法才能保證發出，即使客戶端連接很濫

public static long flushChannel(SocketChannel socketChannel,ByteBuffer bb, long writeTimeout) throws IOException

{

SelectionKey key = null;

Selector writeSelector = null;

int attempts = 0;

int bytesProduced = 0;

try {

while (bb.hasRemaining()) {

int len = socketChannel.write(bb);

attempts++;

if (len < 0){

throw new EOFException();

}

bytesProduced += len;

if (len == 0) {

if (writeSelector == null){

writeSelector = Selector.open();

if (writeSelector == null){

// Continue using the main one

continue;

}

key = socketChannel.register(writeSelector, key.OP_WRITE);

if (writeSelector.select(writeTimeout) == 0) {

if (attempts > 2)

throw new IOException("Client disconnected");

} else {

attempts--;

}

} else {

attempts = 0;

}

} finally {

if (key != null) {

key.cancel();

key = null;

}

if (writeSelector != null) {

// Cancel the key.

writeSelector.selectNow();

writeSelector.close();

}

return bytesProduced;

}

posted on 2008-11-19 12:08 北國狼人的BloG 閱讀(1448) 評論(1) 編輯收藏

評論:

# re: 用戶NIO寫服務器，必須多加處理OP_WRITE，不會丟包 2010-11-09 16:14 | raymond

好用，頂一個！回復更多評論

新用戶注冊刷新評論列表


只有注冊用戶登錄后才能發表評論。




網站導航: 博客園 IT新聞 Chat2DB C++博客博問管理

<

2008年11月

>

日

一

二

三

四

五

六

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

6

常用鏈接

留言簿(33)

隨筆分類

隨筆檔案

文章分類

文章檔案

Java學習論壇

3D至尊寶

常用鏈接

留言簿(33)

隨筆分類

隨筆檔案

文章分類

文章檔案

Java學習論壇

Java最牛網站

搜索

最新評論

閱讀排行榜

評論排行榜