socket InputStream available()lock的问题
在socket InputStream读取数据的问题记录一文中介绍通过input.available()检测是否有可读的字节,上线之后发现服务器load过高,通过jstack发现大量线程都lock在在SocketInputStream.available()上,见截图:
?
之前以为input.available()会很耗时,通过打点发现原来是调用input.available()过于频繁导致:
?
解决这个问题有一个方案,不要调用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);}
?
?修复之后的情况:
?
后续发现还有问题:
?
?