浅谈C#之单线程流式适配器

一、基本介绍

        在C#中，单线程流式适配器通常用于处理流式数据，如网络通信或文件操作中的连续数据流。这些数据流可能是有序的，并且数据包之间可能会发生粘连，即没有明确的分界线，导致粘包和半包问题。解决这些问题的关键在于识别数据包的标识和顺序。

二、简单操作

流式单线程适配器的基本概念

流式单线程适配器在TouchSocket框架中被定义为处理有序流式数据的核心组件，它负责解析数据，包括解决数据的粘连和分包问题，以及将收到的数据解析为数据对象。

实现流式单线程适配器

在C#中，可以通过自定义适配器来实现流式单线程处理。以下是一个简单的示例，展示了如何使用Stream和byte数组来读取和写入数据，同时处理粘包问题：

class Program
{
    static void Main(string[] args)
    {
        var directory = Directory.GetCurrentDirectory();
        var program = File.Open("Program.cs", FileMode.OpenOrCreate);
        var buffers = new byte[1024]; // 创建一个8k的缓存区
        var list = new List<byte>();
        while (true)
        {
            int length = program.Read(buffers, 0, buffers.Length);
            if (length <= 0)
            {
                break;
            }
            list.AddRange(buffers.Take(length));
        }
        program.Close();
        Console.WriteLine($"已读取：{list.Count}");
        var tempr = File.Open("Program_01.cs", FileMode.OpenOrCreate);
        tempr.Write(list.ToArray(), 0, list.Count);
        tempr.Close();
    }
}

使用流适配器

C#中的流适配器，如StreamReader和StreamWriter，提供了一种简化的方法来处理流数据。这些适配器封装了流操作，使得读写操作更加方便。例如，StreamReader可以按行读取文本，而StreamWriter可以写入文本并自动处理换行。

自定义流式单线程适配器

在更复杂的应用中，可能需要自定义流式单线程适配器来处理特定的协议或数据格式。这通常涉及到解析数据头和数据体，以及处理数据的顺序和完整性。以下是一个自定义适配器的示例，它展示了如何读取和解析数据：

var pos = byteBlock.Position; // 记录初始游标位置，防止本次无法解析时，回退游标。
var myRequestInfo = new MyRequestInfo();
// 此操作实际上有两个作用，
// 1.填充header
// 2.将byteBlock.Pos递增3的长度。
var header = byteBlock.ReadToSpan(3); // 填充header
var bodyLength = (byte)(header[0] - 2);
if (bodyLength > byteBlock.CanReadLength)
{
    // body数据不足。
    byteBlock.Position = pos; // 回退游标
    return FilterResult.Cache;
}
else
{
    // 此操作实际上有两个作用，
    // 1.填充body
    // 2.将byteBlock.Pos递增bodyLength的长度。
    var body = byteBlock.ReadToSpan(bodyLength);
    myRequestInfo.DataType = header[1];
    myRequestInfo.OrderType = header[2];
    myRequestInfo.Body = body.ToArray();
    request = myRequestInfo; // 赋值ref
    return FilterResult.Success; // 返回成功
}