java socket长连接中解决read阻塞的3个办法
更新时间：2014年08月05日 11:31:49 投稿：junjie
这篇文章主要介绍了java socket长连接中解决read阻塞的3个办法,本文取了折中的一个方法,并给出代码实例,需要的朋友可以参考下
解决的方法有3个 :
1 约定发送的数据长度，比如 http的 keepAlive 就是必须依赖这个的 Content-Length
2 设置超时的时间，根据我的经验，只有在Socket级别设置才有效.
复制代码 代码如下:
Socket socket = new Socket(host,port);
socket.setSoTimeout(100); // 如果超过100毫秒还没有数据，则抛出 SocketTimeoutException
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);
相关文章
最近在开发中遇到一个关于Java方法重写的一些问题，对于方法重写的用法以及可能导致的问题产生了一些思考，本文用于记录下这些想法，希望对大家也有所帮助2023-05-05
Spring Cloud 通过 Gateway webflux实现网关异常处理
在某一个服务中出现异常,通过@ControllerAdvice + @ExceptionHandler 统一异常处理,即使在微服务架构中,也可以将上述统一异常处理放入到公共的微服务中,这样哪一个微服务需要,直接引入模块,本文重点介绍Spring Cloud 通过 Gateway webflux实现网关异常处理,一起看看吧2023-11-11
javaweb 国际化：DateFormat，NumberFormat，MessageFormat，ResourceBu
本文主要介绍javaWEB国际化的知识，这里整理了详细的资料及实现代码，有兴趣的小伙伴可以参考下2016-09-09
这篇文章主要介绍了Java包装类的缓存机制原理实例详解,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2019-12-12
java实现TCP socket和UDP socket的实例
这篇文章主要介绍了本文主要介绍了java实现TCP socket和UDP socket的实例，文中通过示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2022-02-02
Java观察者设计模式（Observable和Observer）
这篇文章主要介绍了 Java观察者设计模式（Observable和Observer）的相关资料,需要的朋友可以参考下2015-12-12
这篇文章主要介绍了Java 负载均衡算法作用详细解析，负载均衡在Java领域中有着广泛深入的应用，不管是大名鼎鼎的nginx，还是微服务治理组件如dubbo，feign等，负载均衡的算法在其中都有着实际的使用2022-07-07
这篇文章主要介绍了如何对quartz定时任务设置结束时间问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2023-12-12
Spring ApplicationListener源码解析
这篇文章主要为大家介绍了Spring ApplicationListener源码解析，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪2023-01-01
这篇文章主要介绍了JAVA文件扫描（递归）的实例代码 ,代码简单易懂，非常不错，具有一定的参考借鉴价值，需要的朋友可以参考下2019-06-06
最新评论