ET框架学习——消息系统之三

本文主要是介绍ET框架学习——消息系统之三，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

       鉴于我之前对于游戏的网络开发部分没有经验。后面关于ET消息系统的学习都将参考这位朋友Norman_Lin的博客来学习。后面会自己再来调整文章的顺序，结构等。

• CircularBuffer

      这个应该是ET框架中消息相关的类，继承自Stream类。ChunkSize字段的代表一个字节数组的最大长度。后面两个队列应该是用于存储消息流的。

public int ChunkSize = 8192;
private readonly Queue<byte[]> bufferQueue = new Queue<byte[]>();
private readonly Queue<byte[]> bufferCache = new Queue<byte[]>();
public int LastIndex { get; set; }
public int FirstIndex { get; set; }
private byte[] lastBuffer;

 Length字段的定义和bufferQueue队列的长度有关，撇开特殊情况不说，结果如下：

 Lenght = (this.bufferQueue.Count - 1) * ChunkSize + this.LastIndex - this.FirstIndex;

     CircularBuffer在实例化是会执行AddLast方法，会将bufferCache队列中的对头元素弹出（不存在则创建一个空的元素，长度为ChunkSize），做两次赋值：

this.bufferQueue.Enqueue(buffer);
this.lastBuffer = buffer;

       后面还有几个对bufferQueue队列做操作的方法，获取bufferQueue队列的对头和队尾元素，移除对头元素（重新压入bufferCache队列中）。

       后面的几个方法是对字节数组和Stream间的互相操作，关于Stream类，可以参考这篇文章。Write方法用于将steam流写入到bufferQueue队列的尾部字节数组中去。在获取到流中还有数据后，通过一个While循环来写数据（alreadyCopyCount 和count做判断）。当字节数组还有位置时，就从流中写入数据到数组中去。Read方法用于将bufferQueue队列的头部字节数组中的数据转入到流中去。逻辑和Write方法差不多，就是反一下。

// 从stream写入CircularBuffer
public void Write(Stream stream)
{int count = (int)(stream.Length - stream.Position);   // 当前流中剩下的数据长度int alreadyCopyCount = 0;   // alreadyCopyCount 代表已经从流中写入的长度（临时的）while (alreadyCopyCount < count){// this.LastIndex是一个游标，代表已经写入到数组中的数据长度if (this.LastIndex == ChunkSize){// 对队列扩容this.AddLast();this.LastIndex = 0;}int n = count - alreadyCopyCount;  // n 代表流中还未写入的数据的长度// 数组的长度 - 已经写入的长度 > 流中还未写入的数据的长度if (ChunkSize - this.LastIndex > n)  {stream.Read(this.lastBuffer, this.LastIndex, n);//  写入完成后的长度this.LastIndex += count - alreadyCopyCount;alreadyCopyCount += n;}else // 数组中的长度不够，先写满，然后扩容再将剩余的写入{stream.Read(this.lastBuffer, this.LastIndex, ChunkSize - this.LastIndex);alreadyCopyCount += ChunkSize - this.LastIndex;this.LastIndex = ChunkSize;}}
}

 

这篇关于ET框架学习——消息系统之三的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---