首页 诗词 字典 板报 句子 名言 友答 励志 学校 网站地图
当前位置: 首页 > 教程频道 > 网络技术 > 网络基础 >

socket InputStream available()lock的有关问题

2013-04-02 
socket InputStream available()lock的问题在socket InputStream读取数据的问题记录一文中介绍通过input.a

socket InputStream available()lock的问题

在socket InputStream读取数据的问题记录一文中介绍通过input.available()检测是否有可读的字节,上线之后发现服务器load过高,通过jstack发现大量线程都lock在在SocketInputStream.available()上,见截图:


socket InputStream available()lock的有关问题
?

之前以为input.available()会很耗时,通过打点发现原来是调用input.available()过于频繁导致:


socket InputStream available()lock的有关问题
?

解决这个问题有一个方案,不要调用input.available(),通过bufferInputStream不停的尝试read(),通过研究netty的代码发现有更好的方案,先检测input.available(),如果数据没有准备好,则挂起不占用cpu,这种方案是通过PushbackInputStream实现的:

?

public String readLine(int length) throws IOException {String buf = "";PushbackInputStream input = new PushbackInputStream(socket.getInputStream(), 1);int index = 0;while (true) {index = buf.indexOf("\r\n");if (index >= 0) {break;}int bytesToRead = Math.min(input.available(), length);if(bytesToRead>0){    byte[] data = new byte[bytesToRead];            input.read(data);            String line = new String(data, Protocol.ENCODE);            buf += line;    }else{    int b = input.read(); //此操作会阻塞,直到有数据被读到                if (b < 0) {                    break;                }                input.unread(b);                continue;}}return buf.substring(0, index);}

?

?修复之后的情况:


socket InputStream available()lock的有关问题
?

后续发现还有问题:


socket InputStream available()lock的有关问题
?
socket InputStream available()lock的有关问题
?

热点排行