C#、Unity网络通信中基于字节码的自定义协议解码，C#版ByteBuffer
2024-08-30 21:39:04
http://www.oschina.net/code/snippet_42170_37516
C#、Unity基于字节的网络通信中字节码解析类，类似java中的ByteBuffer，不过这个实现是参考的netty4中的ByteBuf类。
因为网络通道中是高字节序列，所以本类没有考虑低字节序列。
已在项目中使用，与java通信没问题
using System; public class ByteBuffer
{
//字节缓存区
private byte[] buf;
//读取索引
private int readIndex = 0;
//写入索引
private int writeIndex = 0;
//读取索引标记
private int markReadIndex = 0;
//写入索引标记
private int markWirteIndex = 0;
//缓存区字节数组的长度
private int capacity; /**
* 构造方法
*/
private ByteBuffer(int capacity)
{
buf = new byte[capacity];
this.capacity = capacity;
} /**
* 构造方法
*/
private ByteBuffer(byte[] bytes)
{
buf = bytes;
this.capacity = bytes.Length;
} /**
* 构建一个capacity长度的字节缓存区ByteBuffer对象
*/
public static ByteBuffer Allocate(int capacity)
{
return new ByteBuffer(capacity);
} /**
* 构建一个以bytes为字节缓存区的ByteBuffer对象，一般不推荐使用
*/
public static ByteBuffer Allocate(byte[] bytes)
{
return new ByteBuffer(bytes);
} /**
* 根据length长度，确定大于此leng的最近的2次方数，如length=7，则返回值为8
*/
private int FixLength(int length)
{
int n = 2;
int b = 2;
while( b < length) {
b = 2 << n;
n++;
}
return b;
} /**
* 翻转字节数组，如果本地字节序列为低字节序列，则进行翻转以转换为高字节序列
*/
private byte[] flip(byte[] bytes)
{
if (BitConverter.IsLittleEndian)
{
Array.Reverse(bytes);
}
return bytes;
} /**
* 确定内部字节缓存数组的大小
*/
private int FixSizeAndReset(int currLen, int futureLen)
{
if (futureLen > currLen)
{
//以原大小的2次方数的两倍确定内部字节缓存区大小
int size = FixLength(currLen) * 2;
if (futureLen > size)
{
//以将来的大小的2次方的两倍确定内部字节缓存区大小
size = FixLength(futureLen) * 2;
}
byte[] newbuf = new byte[size];
Array.Copy(buf, 0, newbuf, 0, currLen);
buf = newbuf;
capacity = newbuf.Length;
}
return futureLen;
} /**
* 将bytes字节数组从startIndex开始的length字节写入到此缓存区
*/
public void WriteBytes(byte[] bytes, int startIndex, int length)
{
lock (this)
{
int offset = length - startIndex;
if (offset <= 0) return;
int total = offset + writeIndex;
int len = buf.Length;
FixSizeAndReset(len, total);
for (int i = writeIndex, j = startIndex; i < total; i++, j++)
{
buf[i] = bytes[j];
}
writeIndex = total;
}
} /**
* 将字节数组中从0到length的元素写入缓存区
*/
public void WriteBytes(byte[] bytes, int length)
{
WriteBytes(bytes, 0, length);
} /**
* 将字节数组全部写入缓存区
*/
public void WriteBytes(byte[] bytes)
{
WriteBytes(bytes, bytes.Length);
} /**
* 将一个ByteBuffer的有效字节区写入此缓存区中
*/
public void Write(ByteBuffer buffer)
{
if (buffer == null) return;
if (buffer.ReadableBytes() <= 0) return;
WriteBytes(buffer.ToArray());
} /**
* 写入一个int16数据
*/
public void WriteShort(short value)
{
WriteBytes(flip(BitConverter.GetBytes(value)));
} /**
* 写入一个uint16数据
*/
public void WriteUshort(ushort value)
{
WriteBytes(flip(BitConverter.GetBytes(value)));
} /**
* 写入一个int32数据
*/
public void WriteInt(int value)
{
//byte[] array = new byte[4];
//for (int i = 3; i >= 0; i--)
//{
// array[i] = (byte)(value & 0xff);
// value = value >> 8;
//}
//Array.Reverse(array);
//Write(array);
WriteBytes(flip(BitConverter.GetBytes(value)));
} /**
* 写入一个uint32数据
*/
public void WriteUint(uint value)
{
WriteBytes(flip(BitConverter.GetBytes(value)));
} /**
* 写入一个int64数据
*/
public void WriteLong(long value)
{
WriteBytes(flip(BitConverter.GetBytes(value)));
} /**
* 写入一个uint64数据
*/
public void WriteUlong(ulong value)
{
WriteBytes(flip(BitConverter.GetBytes(value)));
} /**
* 写入一个float数据
*/
public void WriteFloat(float value)
{
WriteBytes(flip(BitConverter.GetBytes(value)));
} /**
* 写入一个byte数据
*/
public void WriteByte(byte value)
{
lock (this)
{
int afterLen = writeIndex + 1;
int len = buf.Length;
FixSizeAndReset(len, afterLen);
buf[writeIndex] = value;
writeIndex = afterLen;
}
} /**
* 写入一个double类型数据
*/
public void WriteDouble(double value)
{
WriteBytes(flip(BitConverter.GetBytes(value)));
} /**
* 读取一个字节
*/
public byte ReadByte()
{
byte b = buf[readIndex];
readIndex++;
return b;
} /**
* 从读取索引位置开始读取len长度的字节数组
*/
private byte[] Read(int len)
{
byte[] bytes = new byte[len];
Array.Copy(buf, readIndex, bytes, 0, len);
if (BitConverter.IsLittleEndian)
{
Array.Reverse(bytes);
}
readIndex += len;
return bytes;
} /**
* 读取一个uint16数据
*/
public ushort ReadUshort()
{
return BitConverter.ToUInt16(Read(2), 0);
} /**
* 读取一个int16数据
*/
public short ReadShort()
{
return BitConverter.ToInt16(Read(2), 0);
} /**
* 读取一个uint32数据
*/
public uint ReadUint()
{
return BitConverter.ToUInt32(Read(4), 0);
} /**
* 读取一个int32数据
*/
public int ReadInt()
{
return BitConverter.ToInt32(Read(4), 0);
} /**
* 读取一个uint64数据
*/
public ulong ReadUlong()
{
return BitConverter.ToUInt64(Read(8), 0);
} /**
* 读取一个long数据
*/
public long ReadLong()
{
return BitConverter.ToInt64(Read(8), 0);
} /**
* 读取一个float数据
*/
public float ReadFloat()
{
return BitConverter.ToSingle(Read(4), 0);
} /**
* 读取一个double数据
*/
public double ReadDouble()
{
return BitConverter.ToDouble(Read(8), 0);
} /**
* 从读取索引位置开始读取len长度的字节到disbytes目标字节数组中
* @params disstart 目标字节数组的写入索引
*/
public void ReadBytes(byte[] disbytes, int disstart, int len)
{
int size = disstart + len;
for (int i = disstart; i < size; i++)
{
disbytes[i] = this.ReadByte();
}
} /**
* 清除已读字节并重建缓存区
*/
public void DiscardReadBytes()
{
if(readIndex <= 0) return;
int len = buf.Length - readIndex;
byte[] newbuf = new byte[len];
Array.Copy(buf, readIndex, newbuf, 0, len);
buf = newbuf;
writeIndex -= readIndex;
markReadIndex -= readIndex;
if (markReadIndex < 0)
{
markReadIndex = readIndex;
}
markWirteIndex -= readIndex;
if (markWirteIndex < 0 || markWirteIndex < readIndex || markWirteIndex < markReadIndex)
{
markWirteIndex = writeIndex;
}
readIndex = 0;
} /**
* 清空此对象
*/
public void Clear()
{
buf = new byte[buf.Length];
readIndex = 0;
writeIndex = 0;
markReadIndex = 0;
markWirteIndex = 0;
} /**
* 设置开始读取的索引
*/
public void SetReaderIndex(int index)
{
if (index < 0) return;
readIndex = index;
} /**
* 标记读取的索引位置
*/
public void MarkReaderIndex()
{
markReadIndex = readIndex;
} /**
* 标记写入的索引位置
*/
public void MarkWriterIndex()
{
markWirteIndex = writeIndex;
} /**
* 将读取的索引位置重置为标记的读取索引位置
*/
public void ResetReaderIndex()
{
readIndex = markReadIndex;
} /**
* 将写入的索引位置重置为标记的写入索引位置
*/
public void ResetWriterIndex()
{
writeIndex = markWirteIndex;
} /**
* 可读的有效字节数
*/
public int ReadableBytes()
{
return writeIndex - readIndex;
} /**
* 获取可读的字节数组
*/
public byte[] ToArray()
{
byte[] bytes = new byte[writeIndex];
Array.Copy(buf, 0, bytes, 0, bytes.Length);
return bytes;
} /**
* 获取缓存区大小
*/
public int GetCapacity()
{
return this.capacity;
}
}
//以下为ByteBuffer测试代码 ByteBuffer buf = ByteBuffer.Allocate(10);
buf.WriteInt(10000);
buf.WriteByte(10);
buf.WriteShort(1000); Console.WriteLine("-----------------------------"); Console.WriteLine(buf.ReadInt());
Console.WriteLine(buf.ReadByte());
Console.WriteLine(buf.ReadShort());
最新文章
- web兼容学习分析笔记-margin 和padding浏览器解析差异
- MATLAB基础知识之内存映射
- .NET client connection Limit
- mac里git项目删除.DS_Store文件
- PLSQL数据导入导出问题解决（空表、大字段表、表空间错误等）
- 3527: [Zjoi2014]力 - BZOJ
- DC-DC升压(BOOST)电路原理
- .froxlor 玩起
- html页面button样式
- yui--datatable 更新table数据
- C#DataTable DataSet DataRow区别详解
- cocos2dx 坐标和锚点
- Appium 的安装启动
- windows API与C#的数据类型对应关系表
- jQuery源码研究——怎么看源码
- UIkit复习：UIContorl及子控件的剖析
- 二、Snapman多人协作电子表格之——软件下载安装与配置
- C#单例模式的几种实现方式
- java.util.ConcurrentModificationException异常原因及解决方法
- appium 移动端自动化测试一