Java ByteBuffer网络编程用法实例解析
作者:cuisuqiang 发布时间:2022-09-17 20:16:22
做tcp网络编程,要解析一批批的数据,可是数据是通过Socket连接的InputStream一次次读取的,读取到的不是需要转换的对象,而是要直接根据字节流和协议来生成自己的数据对象。
按照之前的编程思维,总是请求然后响应,当然Socket也是请求和响应,不过与单纯的请求响应是不同的。
这里Socket连接往往是要保持住的,也就是长连接,然后设置一个缓冲区,网络流不断的追加到缓冲区。然后后台去解析缓冲区的字节流。
如图所示,网络的流一直在传递,我们收到也许是完成的数据流,也可能是没有传递完的。这里就需要监视管道,不断读取管道中的流数据,然后向缓冲区追加。程序从头开始解析,如果目前缓冲区包含了数据,则解析,没有则放弃继续读取管道流。
就算管道中包含了数据,也不一定包含了完成的数据。例如,100个字节是一个数据体,可是目前缓冲区内包含了120个字节,这就是说缓冲区包含了一条数据,但是还有没有传递完的字节流。那么就要把前100个字节拿出来解析,然后从缓冲区清除这100个字节。那缓冲区就剩下20个字节了,这些数据可能在下次流中补充完成。
如何建立缓冲?
/**
* 全局MVB数据缓冲区 占用 1M 内存
*/
private static ByteBuffer bbuf = ByteBuffer.allocate(10240);
/**
* 线程安全的取得缓冲变量
*/
public static synchronized ByteBuffer getByteBuffer() {
return bbuf;
}
写一个Socket客户端,该客户端得到Socket连接,然后读取流,一直向缓冲中追加字节流,每次追加后调用一个方法来解析该流
public void run() {
Socket socket = GlobalClientKeep.mvbSocket;
if (null != socket) {
try {
// 获得mvb连接引用
OutputStream ops = socket.getOutputStream();
InputStream ips = socket.getInputStream();
while (true) {
if (null != ops && null != ips) {
// 接收返回信息
byte[] bt = StreamTool.inputStreamToByte(ips);
ByteBuffer bbuf = GlobalCommonObjectKeep.getByteBuffer();
// 设置到缓冲区中
bbuf.put(bt);
// ////////////////////////////////////////////////////////////////////////
// 拆包解析方法
splitByte(ops);
ops.flush();
}
}
} catch (Exception e) {
e.printStackTrace();
}
} else {
// 如果连接存在问题,则必须重新建立
GlobalClientKeep.initMvbSocket();
}
}
关于如何读取流,我有一篇博客专门讲解了所以这里是直接调用方法
byte[] bt = StreamTool.inputStreamToByte(ips);
那么解析方法是如何做的?
解析方法首先获得该缓冲中的所有可用字节,然后判断是否符合一条数据条件,符合就解析。如果符合两条数据条件,则递归调用自己。其中每次解析一条数据以后,要从缓冲区中清除已经读取的字节信息。
/**
* @说明 拆包解析方法
*/
public static void splitByte(OutputStream ops) {
try {
ByteBuffer bbuf = GlobalCommonObjectKeep.getByteBuffer();
int p = bbuf.position();
int l = bbuf.limit();
// 回绕缓冲区 一是将 curPointer 移到 0, 二是将 endPointer 移到有效数据结尾
bbuf.flip();
byte[] byten = new byte[bbuf.limit()]; // 可用的字节数量
bbuf.get(byten, bbuf.position(), bbuf.limit()); // 得到目前为止缓冲区所有的数据
// 进行基本检查,保证已经包含了一组数据
if (checkByte(byten)) {
byte[] len = new byte[4];
// 数组源,数组源拷贝的开始位子,目标,目标填写的开始位子,拷贝的长度
System.arraycopy(byten, 0, len, 0, 4);
int length = StreamTool.bytesToInt(len); // 每个字节流的最开始肯定是定义本条数据的长度
byte[] deco = new byte[length]; // deco 就是这条数据体
System.arraycopy(byten, 0, deco, 0, length);
// 判断消息类型,这个应该是从 deco 中解析了,但是下面具体的解析内容不再啰嗦
int type = 0;
// 判断类型分类操作
if (type == 1) {
} else if (type == 2) {
} else if (type == 3) {
} else {
System.out.println("未知的消息类型,解析结束!");
// 清空缓存
bbuf.clear();
}
// 如果字节流是多余一组数据则递归
if (byten.length > length) {
byte[] temp = new byte[bbuf.limit() - length];
// 数组源,数组源拷贝的开始位子,目标,目标填写的开始位子,拷贝的长度
System.arraycopy(byten, length, temp, 0, bbuf.limit() - length);
// 情况缓存
bbuf.clear();
// 重新定义缓存
bbuf.put(temp);
// 递归回调
splitByte(ops);
}else if(byten.length == length){ // 如果只有一条数据,则直接重置缓冲就可以了
// 清空缓存
bbuf.clear();
}
} else {
// 如果没有符合格式包含数据,则还原缓冲变量属性
bbuf.position(p);
bbuf.limit(l);
}
} catch (Exception e) {
e.printStackTrace();
}
}
代码只是一个参考,主要讲解如何分解缓冲区,和取得缓冲区的一条数据,然后清除该数据原来站的空间。
至于缓冲区的属性,如何得到缓冲区的数据,为什么要清空,bbuf.flip();是什么意思。下面来说一下关于ByteBuffer 的一下事情。
ByteBuffer 中有几个属性,其中有两个很重要。limit和 position。position开始在0,填充数据后等于数据的长度,而limit是整个缓冲可用的长度。bbuf.flip();之后,position直接变为0,而limit直接等于position。JDK源码如下:
/**
* Flips this buffer. The limit is set to the current position and then
* the position is set to zero. If the mark is defined then it is
* discarded.
*
* <p> After a sequence of channel-read or <i>put</i> operations, invoke
* this method to prepare for a sequence of channel-write or relative
* <i>get</i> operations. For example:
*
* <blockquote><pre>
* buf.put(magic); // Prepend header
* in.read(buf); // Read data into rest of buffer
* buf.flip(); // Flip buffer
* out.write(buf); // Write header + data to channel</pre></blockquote>
*
* <p> This method is often used in conjunction with the {@link
* java.nio.ByteBuffer#compact compact} method when transferring data from
* one place to another. </p>
*
* @return This buffer
*/
public final Buffer flip() {
limit = position;
position = 0;
mark = -1;
return this;
}
这样,在position和limit之间的数据就是我们要的可用数据。
但是position和limit是ByteBuffer在put和get时需要的属性,所以在使用后要么还原,要么像上面代码一样,清除一些字节信息然后重置。
ByteBuffer 的get和put不是我们平常的取值和设值一样,他会操纵一些属性变化。
来源:https://www.iteye.com/blog/cuisuqiang-1443212
猜你喜欢
- 什么是线程池线程池(thread pool)是一种线程使用模式。线程过多或者频繁创建和销毁线程会带来调度开销,进而影响缓存局部性和整体性能。
- 进行双重foreach循环mapname是一个Map<String,Map<String,Object>> 对象&l
- java eclipse经常会用到整个类进行查找,ctrl+f,然后replaceall(XX,toXX)。但是最近要对webservice
- 昨天有个粉丝加了我,问我如何实现类似shiro的资源权限表达式的访问控制。我以前有一个小框架用的就是shiro,权限控制就用了资源权限表达式
- 在java里, 我们可以使用Executors.newFixedThreadPool 来创建线程池, 然后就可以不停的创建新任务,并用线程池
- 问题引出:最近开了新项目,项目中用到了数据字典,列表查询数据返回的时候需要手动将code转换为name,到前台展示。项目经理表示可以封装一个
- 将10个整数按由小到大的顺序排列#include <iostream>using namespace std;int main(
- 相信最近看过我的文章的朋友对于Microsoft.Extensions.ObjectPool不陌生;复用、池化是在很多高性能场景的优化技巧,
- 前言在上一篇学习SpringBoot中,整合了Mybatis、Druid和PageHelper并实现了多数据源的操作。本篇主要是介绍和使用目
- 需求:字符串(字符串只有一位小数)转float进行运算, 将结果转成字符串(保留一位小数)直接上代码:float f1 = 0.1f;Str
- 首先写个单例:public class SingleDemo { private static SingleDemo s =
- 目录一、常用属性、方法和事件1.常用属性2.常用方法3.常用事件二、应用实例1.实例描述2.属性设置3.事件处理4.实现代码总结一、常用属性
- 验证码及它的作用验证码为全自动区分计算机和人类的图灵测试的缩写,是一种区分用户是计算机的公共全自动程序,这个问题可以由计算机生成并评判,但是
- 1、mapper.xml文件中的sql语句不提示1.1 首先,alt+enter,出现如下窗口随后的窗口选择这样在如下窗口中会增加一个upd
- 下面介绍的这个版本搭配是我研究好久好久才跑通的,这在我的电脑上是一组可行的配置,如果你使用了同样的配置跑不通,那可能是环境中某一部分还是有不
- TIOBE 11 月编程语言排行榜,Python 逆袭C#曾经有一段时间,脚本语言因其易于编写和易于运行的特性,被预测在未来将发展强大。因此
- 加载图片openCv有一个名imread的简单函数,用于从文件中读取图像imread 函数位于Imgcodecs类的同名包中。加载图片代码i
- 1.前言(基于JDK1.7)最近想把一些java基础的东西整理一下,但是又不知道从哪里开始!想了好久,还是从最基本的jvm开始吧!这一节就简
- 本文实例讲述了Android编程中EditText限制文字输入的方法。分享给大家供大家参考,具体如下:Android的编辑框控件EditTe
- 本文实例为大家分享了java中文传值乱码问题,以及解决方法,供大家参考,具体内容如下一般编码格式设置:1.可以经过两次编码处理,即设置字符集