标签：style blog http ar color os 使用 sp for
版权所有，转载须注明出处！using System;
using System.Text;
namespace com.duoyu001.net
{
namespace buffer
{
/* ==============================================================================
* 功能描述：字节缓冲类
* 创 建 者：cjunhong
* 主 页：http://blog.csdn.net/kakashi8841
* 邮 箱：[url=mailto:john.cha@qq.com]john.cha@qq.com[/url]
* 创建日期：2014/12/02 16:22:09
* ==============================================================================*/
public class ByteBuffer
{
//增加的容量
public const short CAPACITY_INCREASEMENT = 128;
public const ushort USHORT_8 = (ushort) 8;
public const short SHORT_8 = (short) 8;
//字节数组
private byte[] buffers;
//读取索引
private int readerIndex;
//写的索引
private int writerIndex;
//上次备份的reader索引
private int readerIndexBak;
//字符数组 空字符串
public static byte[] NULL_STRING = new byte[] {(byte) 0, (byte) 0};
public ByteBuffer()
: this(8)
{
}
/// <summary>
/// 带参构造函数 初始化字节数组
/// </summary>
/// <param name="initCapacity">初始容量</param>
public ByteBuffer(int initCapacity)
{
buffers = new byte[initCapacity];
}
/// <summary>
/// 带参构造函数 向字节数组中 写字节
/// </summary>
/// <param name="buffers">字节数组</param>
public ByteBuffer(byte[] buffers)
: this(buffers.Length)
{
writeBytes(buffers);
}
public void writeBytes(byte[] data, int dataOffset, int dataSize)
{
ensureWritable(dataSize);
Array.Copy(data, dataOffset, buffers, writerIndex, dataSize);
writerIndex += dataSize;
}
public void writeBytes(byte[] data)
{
writeBytes(data, 0, data.Length);
}
public void writeByte(byte data)
{
writeBytes(new byte[] {data});
}
public void writeByte(int data)
{
writeBytes(new byte[] {(byte) data});
}
public void writeShort(int data)
{
writeBytes(new byte[] {(byte) (data >> 8), (byte) data});
}
public void writeInt(int data)
{
writeBytes(new byte[]
{
(byte) (data >> 24),
(byte) (data >> 16),
(byte) (data >> 8),
(byte) data
});
}
public void writeString(string data)
{
writeString(data, Encoding.UTF8);
}
public void writeString(string data, Encoding encoding)
{
if (data == null)
{
writeBytes(NULL_STRING);
}
else
{
byte[] b = encoding.GetBytes(data);
byte[] strBytes = new byte[b.Length + 2];
strBytes[0] = (byte) ((b.Length & 0xff00) >> 8);
strBytes[1] = (byte) (b.Length & 0xff);
b.CopyTo(strBytes, 2);
writeBytes(strBytes);
}
}
public byte readByte()
{
byte b = buffers[readerIndex];
readerIndex++;
return b;
}
public ushort readUnsignShort()
{
ushort u = (ushort) (buffers[readerIndex] << USHORT_8 | buffers[readerIndex + 1]);
readerIndex += 2;
return u;
}
public short readShort()
{
short i = (short) (buffers[readerIndex] << SHORT_8 | buffers[readerIndex + 1]);
readerIndex += 2;
return i;
}
public int readInt()
{
int i = buffers[readerIndex] << 24 | buffers[readerIndex + 1] << 16 | buffers[readerIndex + 2] << 8 |
buffers[readerIndex + 3];
readerIndex += 4;
return i;
}
public uint readUnsignInt()
{
return (uint) readInt();
}
public byte[] readBytes(int length)
{
byte[] b = new byte[length];
Array.Copy(buffers, readerIndex, b, 0, length);
readerIndex += length;
return b;
}
public string readString()
{
return readString(Encoding.UTF8);
}
public string readString(Encoding encoding)
{
ushort charLength = readUnsignShort();
byte[] strBytes = readBytes(charLength);
return encoding.GetString(strBytes);
}
public void writeBuffer(ByteBuffer buff)
{
byte[] bytes = buff.readBytes(buff.readableBytes());
writeBytes(bytes);
}
public ByteBuffer readBuffer(int length)
{
byte[] bytes = readBytes(length);
return new ByteBuffer(bytes);
}
public byte[] toArray()
{
return readBytes(readableBytes());
}
public byte[] getBytes()
{
return buffers;
}
public int readableBytes()
{
return writerIndex - readerIndex;
}
public void saveReaderIndex()
{
readerIndexBak = readerIndex;
}
public void loadReaderIndex()
{
readerIndex = readerIndexBak;
}
private void ensureWritable(int dataSize)
{
int leftCapacity = buffers.Length - writerIndex;
if (leftCapacity < dataSize)
{
int oldReaderIndex = readerIndex;
int oldWriterIndex = writerIndex;
writerIndex = readableBytes();
readerIndex = 0;
if (buffers.Length - writerIndex >= dataSize)
{
Array.Copy(buffers, oldReaderIndex, buffers, 0, oldWriterIndex - oldReaderIndex);
}
else
{
byte[] newBuffers = new byte[buffers.Length + CAPACITY_INCREASEMENT];
Array.Copy(buffers, oldReaderIndex, newBuffers, 0, oldWriterIndex - oldReaderIndex);
buffers = newBuffers;
}
}
}
public int getReaderIndex()
{
return readerIndex;
}
public int getWriterIndex()
{
return writerIndex;
}
public int getCapacity()
{
return buffers.Length;
}
public string remainBufferString()
{
string s = "";
for (int i = readerIndex; i < writerIndex; i++)
{
s += buffers;
if (i < writerIndex - 1)
{
s += ", ";
}
}
return s;
}
}
}
}标签：style blog http ar color os 使用 sp for
原文地址：http://blog.csdn.net/kakashi8841/article/details/42025367
