C#环形缓冲区(队列)完全实现

公司项目中经常设计到串口通信,TCP通信,而且大多都是实时的大数据的传输,然后大家都知道协议通讯肯定涉及到什么,封包、拆包、粘包、校验……什么鬼的概念一大堆,说简单点儿就是要一个高效率可复用的缓存区。按照码农的惯性思维就是去百度、谷歌搜索看有没有现成的东西可以直接拿来用,然而我并没有找到,好吧不是很难的东西自己实现一个呗。开扯……

为什么要用环形队列?
环形队列是在实际编程极为有用的数据结构,它有如下特点:
它是一个首尾相连的FIFO的数据结构,采用数组的线性空间,数据组织简单。能很快知道队列是否满为空。能以很快速度的来存取数据。
因为有简单高效的原因,甚至在硬件都实现了环形队列。

C#完全实现(可直接使用)
鄙人新手这份代码肯定有不足之处,望大家指出交流,涉及到的多线程同步问题请调用者完成,不废话直接上代码。

 public class RingBufferManager
{
  public byte[] Buffer { get; set; } // 存放内存的数组
  public int DataCount { get; set; } // 写入数据大小
  public int DataStart { get; set; } // 数据起始索引
  public int DataEnd { get; set; }  // 数据结束索引
  public RingBufferManager(int bufferSize)
  {
    DataCount = 0; DataStart = 0; DataEnd = 0;
    Buffer = new byte[bufferSize];
  }

  public byte this[int index]
  {
    get
    {
      if (index >= DataCount) throw new Exception("环形缓冲区异常,索引溢出");
      if (DataStart + index < Buffer.Length)
      {
        return Buffer[DataStart + index];
      }
      else
      {
        return Buffer[(DataStart + index) - Buffer.Length];
      }
    }
  }

  public int GetDataCount() // 获得当前写入的字节数
  {
    return DataCount;
  }

  public int GetReserveCount() // 获得剩余的字节数
  {
    return Buffer.Length - DataCount;
  }

  public void Clear()
  {
    DataCount = 0;
  }

  public void Clear(int count) // 清空指定大小的数据
  {
    if (count >= DataCount) // 如果需要清理的数据大于现有数据大小,则全部清理
    {
      DataCount = 0;
      DataStart = 0;
      DataEnd = 0;
    }
    else
    {
      if (DataStart + count >= Buffer.Length)
      {
        DataStart = (DataStart + count) - Buffer.Length;
      }
      else
      {
        DataStart += count;
      }
      DataCount -= count;
    }
  }

  public void WriteBuffer(byte[] buffer, int offset, int count)
  {
    Int32 reserveCount = Buffer.Length - DataCount;
    if (reserveCount >= count)             // 可用空间够使用
    {
      if (DataEnd + count < Buffer.Length)      // 数据没到结尾
      {
        Array.Copy(buffer, offset, Buffer, DataEnd, count);
        DataEnd += count;
        DataCount += count;
      }
      else      // 数据结束索引超出结尾 循环到开始
      {
        System.Diagnostics.Debug.WriteLine("缓存重新开始....");
        Int32 overflowIndexLength = (DataEnd + count) - Buffer.Length;   // 超出索引长度
        Int32 endPushIndexLength = count - overflowIndexLength;       // 填充在末尾的数据长度
        Array.Copy(buffer, offset, Buffer, DataEnd, endPushIndexLength);
        DataEnd = 0;
        offset += endPushIndexLength;
        DataCount += endPushIndexLength;
        if (overflowIndexLength != 0)
        {
          Array.Copy(buffer, offset, Buffer, DataEnd, overflowIndexLength);
        }
        DataEnd += overflowIndexLength;                   // 结束索引
        DataCount += overflowIndexLength;                  // 缓存大小
      }
    }
    else
    {
      // 缓存溢出,不处理
    }
  }

  public void ReadBuffer(byte[] targetBytes,Int32 offset, Int32 count)
  {
    if (count > DataCount) throw new Exception("环形缓冲区异常,读取长度大于数据长度");
    Int32 tempDataStart = DataStart;
    if (DataStart + count < Buffer.Length)
    {
      Array.Copy(Buffer, DataStart, targetBytes, offset, count);
    }
    else
    {
      Int32 overflowIndexLength = (DataStart + count) - Buffer.Length;  // 超出索引长度
      Int32 endPushIndexLength = count - overflowIndexLength;       // 填充在末尾的数据长度
      Array.Copy(Buffer, DataStart, targetBytes, offset, endPushIndexLength);

      offset += endPushIndexLength;

      if (overflowIndexLength != 0)
      {
        Array.Copy(Buffer, 0, targetBytes, offset, overflowIndexLength);
      }
    }
  }

  public void WriteBuffer(byte[] buffer)
  {
    WriteBuffer(buffer, 0, buffer.Length);
  }

}

调用实例
生产

 int len = sConn.Receive(receiveBuffer, 0, receiveBuffer.Length, SocketFlags.None, out se);
if (len <= 0) throw new Exception("disconnect..");
if (len > 0)
{
  lock (LockReceiveBuffer)
  {
    while (len + receiveBufferManager.DataCount > MAX_BUFFER_LEN)    // 缓存溢出处理
    {
      Monitor.Wait(LockReceiveBuffer,10000);
    }
    receiveBufferManager.WriteBuffer(receiveBuffer, 0, len);
    Monitor.PulseAll(LockReceiveBuffer);
  }
}

消费

 lock (LockReceiveBuffer)
{
  freame_byte = new byte[frameLen];
  receiveBufferManager.ReadBuffer(freame_byte, 0, frameLen);
  receiveBufferManager.Clear(frameLen);
}

验证 
TCP大数据连续测试一周没出现问题内存问题。

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持我们。

(0)

相关推荐

  • C#通过Semaphore类控制线程队列的方法

    本文实例讲述了C#通过Semaphore类控制线程队列的方法.分享给大家供大家参考.具体实现方法如下: using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.IO; using System.Diagnostics; using System.Threading; using System.ComponentModel; using System.Col

  • C#内置队列类Queue用法实例

    本文实例讲述了C#内置队列类Queue用法.分享给大家供大家参考.具体分析如下: 这里详细演示了C#内置的队列如何进行添加,移除等功能. using System; using System.Collections.Generic; class Example { public static void Main() { Queue<string> numbers = new Queue<string>(); numbers.Enqueue("one"); num

  • C#多线程处理多个队列数据的方法

    本文实例讲述了C#多线程处理多个队列数据的方法.分享给大家供大家参考.具体实现方法如下: using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading; using System.Collections; using System.Windows.Forms; namespace ThredProcessQueue { //用于顯示狀態的代理

  • C#环形队列的实现方法详解

    一.环形队列是什么 队列是一种常用的数据结构,这种结构保证了数据是按照"先进先出"的原则进行操作的,即最先进去的元素也是最先出来的元素.环形队列是一种特殊的队列结构,保证了元素也是先进先出的,但与一般队列的区别是,他们是环形的,即队列头部的上个元素是队列尾部,通常是容纳元素数固定的一个闭环. 二.环形队列的优点 1.保证元素是先进先出的 是由队列的性质保证的,在环形队列中通过对队列的顺序访问保证. 2.元素空间可以重复利用 因为一般的环形队列都是一个元素数固定的一个闭环,可以在环形队列

  • C#队列Queue用法实例分析

    本文实例分析了C#队列Queue用法.分享给大家供大家参考.具体分析如下: 队列(Queue)在程序设计中扮演着重要的角色,因为它可以模拟队列的数据操作.例如,排队买票就是一个队列操作,后来的人排在后面,先来的人排在前面,并且买票请求先被处理.为了模拟队列的操作,Queue在ArrayList的基础上加入了以下限制 1.元素采用先入先出机制(FIFO,First In First Out),即先进入队列的元素必须先离开队列.最先进入的元素称为队头元素. 元素只能被添加到队尾(称为入队),不允许在

  • C#数据结构与算法揭秘五 栈和队列

    这节我们讨论了两种好玩的数据结构,栈和队列. 老样子,什么是栈, 所谓的栈是栈(Stack)是操作限定在表的尾端进行的线性表.表尾由于要进行插入.删除等操作,所以,它具有特殊的含义,把表尾称为栈顶(Top) ,另一端是固定的,叫栈底(Bottom) .当栈中没有数据元素时叫空栈(Empty Stack).这个类似于送饭的饭盒子,上层放的是红烧肉,中层放的水煮鱼,下层放的鸡腿.你要把这些菜取出来,这就引出来了栈的特点先进后出(First in last out).   具体叙述,加下图. 栈通常记

  • C#队列Queue多线程用法实例

    本文实例讲述了C#队列Queue多线程用法.分享给大家供大家参考.具体分析如下: 这里展示一个例子,供学习使用: private void button_测试Queue结合多线程_Click(object sender, EventArgs e) { Console.WriteLine("初始化队列"); queue = new Queue<string>(); string[] cars = new string[]{"宝马","奔驰&quo

  • C#使用foreach语句遍历队列(Queue)的方法

    本文实例讲述了C#使用foreach语句遍历队列(Queue)的方法.分享给大家供大家参考.具体如下: using System; using System.Collections; public class QueuesW3 { static void Main(string[] args) { Queue a = new Queue(10); int x = 0; a.Enqueue(x); x++; a.Enqueue(x); foreach (int y in a) { Console.

  • 可替代log4j日志的c#简单日志类队列实现类代码分享

    复制代码 代码如下: using System;using System.Collections.Generic;using System.Globalization;using System.IO;using System.Linq;using System.Text;using System.Threading; namespace LogisTrac{    /// <summary>    /// 日志类     /// 队列 可年/月/周/日/大小分割    /// 调用方法:   

  • c#队列Queue学习示例分享

    集合>队列Queue>创建队列 System.Collections.Queue类提供了四种重载构造函数. 复制代码 代码如下: using System.Collections.Generic;using System.Linq;using System.Text;using System.Collections; namespace ConsoleApplication1{    class Program    {        static void Main(string[] arg

随机推荐