Java SocketChannel 读取ByteBuffer字节的处理模型

时间:2021-11-14 19:40:17

在JAVA中的流分为字节流或字符流,一般来说采用字符流处理起来更加方便。字节流处理起来相对麻烦,SocketChannel中将数据读取到ByteBuffer中,如何取出完整的一行数据(使用CRLF分隔)?

例如:

Socket收到的内容为:

1234567890CRLF

0123456789CRLF

注意:CRLF为回车换行符号

如果使用 SocketChannel.read(ByteBuffer buff)读取数据,如果buff的capatity为12, 则第一次读取的数据为 “1234567890CRLF” 刚好为一行,但是如果buff的capatity小于12,则要读取两次以上才能读到CRLF回车换行符号。如果buff.capatity大于12,则会读取到第二行的数据,那么下次读取操作时,如何处理第一次多读到的数据?  这个问题与 "回推流" 类似。

为解决此问题,并实现与“回推流”类似的功能。建立如下的处理模型

Java SocketChannel 读取ByteBuffer字节的处理模型

Source、Cursor接口实现从Channel中读取字节,并实现回推功能。

Source.ready() 函数返回已经从Channel中读取的数据。如果Buffer中还有数据,则返回Buffer中剩余的自己数,如果Buffer中的字节都已经读取了,则重新从Channel中读取数据到Buffer中。如果没有数据可以读取了,则返回-1;

Source.ready(byte[] dst, int off, int len) 函数重Buffer中读取数据到 dst中。

Source.reset(int len) 函数在Buffer层面上实现回退,即设置Buffer.position。

Cursor接口对Source接口进一步封装,同时提供push函数扩展了reset的回推功能。

Cursor.push(byte[] src, int off, int len) 将byte[]中的数据回推到Cursor中,下次读取操作时将把push进去的数据读取出来。

Consumer接口使用consumer函数从Cursor中读取数据,并进行相应的处理。根据不同的业务逻辑继承Consumer接口处理Cursor中的数据。