`

从Socket中读取指定长度数据问题

阅读更多

InputStream is = .....
...................
byte[] bs = new byte[10];
int readed = is.read(bs);
is.close();
我们知道上面的代码可以从输入流里读取readed个字节的数据(readed范围为-1到10),readed==-1表示流已读完,那么什么时候会出现readed为0-9的情况呢?
答案:输入流中剩余内容不足10个字节(如is为FileInputStream表示文件剩余内容不足10个字节)

但对于套接字读取我们要注意,代码如下:

InputStream is = socket.getInputStream();
is.read...
....
byte[] bs = new byte[10];
is.read(bs);
String A=new String(bs);
byte[] bs2 = new byte[60];
is.read(bs2);
String B=new String(bs2);
上面对例子表示从套接字中接收数据,先接收10个字节的字段A,然后再接收60个字节的字段B,但实际is.read(bs)却有可能读取的数据不足10个字节,从而导致is.read(bs2)的时候却读到了字段A的一部分数据,这样就出错了,所以理论上上面这种写法是不正确不严谨的(小数据时也许在大多数情况下没问题,但不能保证一定没问题)。

对于套接字读取需要这样写:
// 从套接字缓冲区is中读取length长度的数据
private byte[] recvBytes(InputStream is, int length) throws IOException {
int tmpLength = 512; // 每次读取最大缓冲区大小
byte[] ret = new byte[length];
int readed = 0, offset = 0, left = length;
byte[] bs = new byte[tmpLength];
while (left > 0) {
try {
readed = is.read(bs, 0, Math.min(tmpLength, left));
if (readed == -1)
break;
System.arraycopy(bs, 0, ret, offset, readed);
} finally {
offset += readed;
left -= readed;
}
}
return ret;
}
byte[] bs = recvBytes(is, 10);
byte[] bs2 = recvBytes(is, 60);


分享到:
评论

相关推荐

    C#TCP\Socket粘包处理(加长度头)

    - 接收端:首先接收长度头,转换为整数,然后循环接收数据直到达到指定长度,完成一个数据包的接收。 5. **其他解决方案** - 固定长度的数据包:如果每个数据包的大小是固定的,那么可以简单地按照固定长度来读取...

    C# 读取PLC DB块数据DEMO

    接着,我们定义了要读取的数据范围,并使用`ReadArea()`方法读取指定DB块的数据。最后,记得在操作完成后断开连接,确保资源被正确释放。 读取到的数据通常以字节形式存在,因此需要根据DB块内的数据结构进行解析。...

    liunx下使用socket实现can总线数据接收

    `struct can_frame`包含了CAN帧的所有信息,如ID、数据长度和数据本身。你可以根据这些信息解析和处理接收到的数据。 此外,`can-utils`是一个非常有用的工具集,包含了用于CAN总线测试和诊断的各种实用程序。例如...

    socket客户端长连接实现以及xml文件解析

    在IT领域,Socket编程是网络通信的基础,而XML(Extensible Markup Language)则是...在xfunds-socket-price这个项目中,可能涉及到通过Socket连接获取价格数据,这些数据以XML格式传输,然后在客户端进行解析和处理。

    C# Socket 分包传送数据

    2. **文件读取与分块**:使用`FileStream`读取图片文件,然后利用`Read`方法按需读取指定大小的数据块。每个数据块的大小应考虑网络传输效率,通常不宜过大,以免增加丢包概率。 3. **数据包封装**:将每个数据块...

    java 使用socked接收chunck分块数据

    Java的Socket API提供了一个InputStream,我们可以从这个输入流中读取接收到的数据。在chunked模式下,数据被分为多个块,每个块都有一个十六进制的大小前缀,后面跟着块的实际内容,最后是一块大小为0的块表示数据...

    python使用socket 先读取长度,在读取报文内容示例

    在Python的socket编程中,可以通过指定接收数据的长度来实现这一功能。 下面,我们将会介绍在Python中使用socket模块先读取长度,然后再读取报文内容的方法,并提供示例代码以说明如何实现这一过程。 Python的...

    ios bsd socket 客户端发送和接收数据

    GCD可以创建一个后台队列来处理socket的数据读写,而NSRunLoop则可以在指定的运行循环中处理流的事件,避免阻塞主线程。 此外,为了优化性能和用户体验,我们可能需要实现数据的缓存策略,比如使用NSInputStream和...

    IP包读取分析(raw socket)

    压缩包中的"IP包读取分析(raw socket)"可能包含了一个完整的示例程序,展示如何创建、绑定和接收IP包,以及如何解析包头和数据。通过研究这个例子,你可以更直观地了解raw socket的工作机制,并动手实践,加深理解...

    vc实现向指定ip端口发送数据或文件,获取本机ip

    在VC++环境中,实现向指定IP和端口发送数据或文件以及获取本机IP的功能,主要涉及网络编程、多线程技术以及对话框界面设计。下面将详细解释这些知识点。 1. **网络编程基础**: 网络编程是通过网络在不同设备间...

    Android_Socket_客户端和服务器端,支持多张图片同时传送,自定义协议头

    在Android平台上,Socket通信是应用程序之间进行数据交换的重要方式,特别是在客户端和服务器端的数据交互中。本项目"Android_Socket_客户端和服务器端,支持多张图片同时传送,自定义协议头"着重解决了如何通过...

    服务端,,客户端通过socket传送图像

    3. 图像数据准备:将图像文件读取到内存中,转换成适合网络传输的格式,如JPEG或PNG。 4. 数据发送:使用`send`函数分块发送图像数据。 服务器端(Server)的工作流程如下: 1. 启动监听:调用`listen`函数,设置...

    C#用Socket发送和接收文件的源代码

    在IT行业中,网络通信是不可或缺的一部分,而Socket编程则是实现客户端和服务器间通信的基础。C#作为.NET框架下的主要编程语言,提供了丰富的类库来支持Socket编程,使得开发者能够轻松地构建网络应用,包括发送和...

    C# socket 通信 允许发送图片,文字,文件!可以指定用户

    为了确保数据的完整性和正确性,我们可能还需要添加额外的头部信息,比如数据长度,以便接收端知道何时停止读取。 为了指定用户,服务器需要维护一个用户列表,其中包含每个用户的昵称和与其关联的Socket对象。当...

    Java Socket编程笔记_动力节点Java学院整理

    - 告知读取长度,预先发送数据长度信息,读取指定长度的数据。 - 读取所有可用数据,直到无数据可读。 - 关闭Socket时,其输入输出流会被自动关闭。 ServerSocket的构造函数允许指定监听的端口、最大连接队列长度和...

    socket传输图片包括服务器客户端

    - 定义一个接收数据的方法,循环读取Socket的接收到的数据,每次读取时先读取长度标识,然后根据长度读取相应数量的数据,确保完整接收。 - 接收到图片数据后,将其保存为文件。 2. **客户端**: - 创建...

    封装Socket

    Socket编程是计算机网络编程中的重要组成部分,主要用于实现进程间的通信。在Java中,Socket是基于TCP/IP协议的网络通信方式,提供了服务器端和客户端之间的双向通信。本篇将详细讲解Socket的基本概念、工作原理以及...

    Socket连接-TCP测试

    4. 在此案例中,客户端将图片文件读入字节数组,然后通过输出流写入,服务器端则从输入流读取这些字节,写入到本地文件,完成图片的传输。 5. 数据交换完成后,客户端和服务器都需要关闭Socket和ServerSocket,释放...

    java socket通信自定义消息协议

    3. `ServerThread`继承`Thread`,在`run()`方法中处理Socket通信,包括读取客户端发送的数据和响应。 4. 服务器端同样获取InputStream,通过`Socket.getInputStream()`。 5. 接收到字节流后,按照自定义协议解析消息...

Global site tag (gtag.js) - Google Analytics