最近在做java接收二进制流的测试,一个服务端一个客户,服务端接收到客户端的请求后,向客户端一次性发送50kB左右的二进制数据包;包头占四个字节,指示了数据包的长度;客户端收到四个字节的包头后,打印包体的长度length,正确,于是分配50kb的buff,byte[] buff=new byte[length];int canread=socket.avaliable();
//canread的大小也是正常的;int readlen=socket.getinputstream().read(buff,0,length);
//readlen的长度为length的大小,按API的说法是读到了length个字节,但缓冲区中却没有那么多数据;
//如果readlen不可靠,那么如何才能获得可靠的接收到的数据?
//因为50kb不可能在一个TCP包中传过来,肯定分成多包来传的,我想知道我具体已经接收了多少了,给我的感觉是socket.getinputstream().read()的返回值是不可靠的;感谢大侠的指点!
//canread的大小也是正常的;int readlen=socket.getinputstream().read(buff,0,length);
//readlen的长度为length的大小,按API的说法是读到了length个字节,但缓冲区中却没有那么多数据;
//如果readlen不可靠,那么如何才能获得可靠的接收到的数据?
//因为50kb不可能在一个TCP包中传过来,肯定分成多包来传的,我想知道我具体已经接收了多少了,给我的感觉是socket.getinputstream().read()的返回值是不可靠的;感谢大侠的指点!
看下真实的长度是多少,如何真的不对,你去看一下你的服务器端发送数据的时候有没有
flush();
如果还不行我就没办法了。
看了buf的数据,不对,从客户端抓包了,抓到了服务器发送过来的所有的包(所有的分片组合到一起是一个完整的服务器的包)
非常感谢你的关注
byte[] buff=new byte[length];
int pos = 0;
while (pos < length) {
pos += is.read(buff, pos, length-pos);
}
使用循环读了,但pos返回了读的长度,但这个长度和buf中写入的数据长度不一致,
我也遇到过这种情况,具体原因当时也没仔细查,不过只要把服务器端程序改成每发送一次就休眠几十毫秒就没问题了。
不过休眠几十毫秒又觉得太浪费时间,最终决定把所要发送的字节数组包装成了一个对象:
class sendObj {
byte[] bytes;
}
然后使用objectoutputstream 和 objectinputstream,以对象的方式发送和接受也就没问题了。