博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Java中Socket上的Read操作堵塞问题
阅读量:7218 次
发布时间:2019-06-29

本文共 1051 字,大约阅读时间需要 3 分钟。

从Socket上读取对端发过来的数据一般有两种方法:
1)依照字节流读取
BufferedInputStream in = new BufferedInputStream(socket.getInputStream());        int r = -1;        List
l = new LinkedList
(); while ((r = in.read()) != -1) { l.add(Byte.valueOf((byte) r)); }
2)依照字符流读取
BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));                String s;        while ((s = in.readLine()) != null) {            System.out.println("Reveived: " + s);        }
这两个方法read()和readLine()都会读取对端发送过来的数据,假设无数据可读,就会堵塞直到有数据可读。

或者到达流的末尾,这个时候分别返回-1和null。

这个特性使得编程非常方便也非常高效。

可是这样也有一个问题。就是怎样让程序从这两个方法的堵塞调用中返回。
总结一下,有这么几个方法:
1)发送完后调用Socket的shutdownOutput()方法关闭输出流。这样对端的输入流上的read操作就会返回-1。

注意不能调用socket.getInputStream().close()。这样会导致socket被关闭。
当然假设不须要继续在socket上进行读操作,也能够直接关闭socket。
可是这种方法不能用于通信两方须要多次交互的情况。

2)发送数据时。约定数据的首部固定字节数为数据长度。这样读取到这个长度的数据后,就不继续调用read方法。
3)为了防止read操作造成程序永久挂起。还能够给socket设置超时。
假设read()方法在设置时间内没有读取到数据,就会抛出一个java.net.SocketTimeoutException异常。
比如以下的方法设定超时3秒。

socket.setSoTimeout(3000);

转载地址:http://nixym.baihongyu.com/

你可能感兴趣的文章
云计算与虚拟化之后:网络威胁成新挑战
查看>>
50个Demo展示HTML5无穷的魅力
查看>>
chapter 4:贪心
查看>>
批处理学习笔记
查看>>
Linux挂载磁盘
查看>>
Cyclone II RAM ROM设置
查看>>
Ubuntu下实现伪静态
查看>>
python 二维数组遍历
查看>>
第8周课下作业1(补)
查看>>
阿萨斯
查看>>
service启动和停止,绑定和解除绑定
查看>>
elasticsearch开机启动脚本
查看>>
window service 恢复选项卡设置
查看>>
车辆管理系统之编码过程总结(十一)
查看>>
基于AOE网的关键路径的求解
查看>>
2017-5-16 python标准库
查看>>
浅谈游戏的声音处理-流播放文件 source
查看>>
旧版本转换成支持ARC版本
查看>>
创建与服务器的输入输出流
查看>>
string.hのmemmove的实现
查看>>