欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

java socket长连接中解决read阻塞的3个办法

程序员文章站 2024-02-29 18:45:10
解决的方法有3个 : 1 约定发送的数据长度,比如 http的 keepalive 就是必须依赖这个的 content-length 2 设置超时的时间,根据我的经验,...

解决的方法有3个 :

1 约定发送的数据长度,比如 http的 keepalive 就是必须依赖这个的 content-length
2 设置超时的时间,根据我的经验,只有在socket级别设置才有效.

复制代码 代码如下:
socket socket = new socket(host,port);
socket.setsotimeout(100); // 如果超过100毫秒还没有数据,则抛出 sockettimeoutexception

3 让发送端发送完数据后,关闭连接。 这个在http的操作时很常见。

(inputstream如何判断数据已经读取结束)

某些时候无法修改客户端的情况下情况一就只有pass掉了,情况二相对来说比较适合,当阻塞后直接抛出一个异常。情况三不适合长连接,因为整个通信过程中链路是不能中断的,也不能调shutdown结束。其实还有第四种方法:当读取到某些字符就不在往下读取了,比如读取到byebye就break。但是这也需要改客户端代码。选了一种折中的办法-设置超时:

stringbuilder sb = new stringbuilder();
try {
  client.setsotimeout(500);
  while ((a = client.getinputstream().read(buf)) != -1) {
    sb.append(new string(buf, 0, a));
    if (a != size) {
      break;
    }
  }
} catch (exception e) {
}
system.out.println(sb);