当前位置: 代码迷 >> 综合 >> socket InputStream available()lock的问题
  详细解决方案

socket InputStream available()lock的问题

热度:61   发布时间:2023-12-21 17:12:59.0

在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);}

 

 修复之后的情况:



 

后续发现还有问题:



 

 

  相关解决方案