一、基本介紹

????????在C#中，單線程流式適配器通常用于處理流式數(shù)據(jù)，如網(wǎng)絡(luò)通信或文件操作中的連續(xù)數(shù)據(jù)流。這些數(shù)據(jù)流可能是有序的，并且數(shù)據(jù)包之間可能會發(fā)生粘連，即沒有明確的分界線，導(dǎo)致粘包和半包問題。解決這些問題的關(guān)鍵在于識別數(shù)據(jù)包的標(biāo)識和順序。

二、簡單操作

流式單線程適配器的基本概念

流式單線程適配器在TouchSocket框架中被定義為處理有序流式數(shù)據(jù)的核心組件，它負(fù)責(zé)解析數(shù)據(jù)，包括解決數(shù)據(jù)的粘連和分包問題，以及將收到的數(shù)據(jù)解析為數(shù)據(jù)對象。

實現(xiàn)流式單線程適配器

在C#中，可以通過自定義適配器來實現(xiàn)流式單線程處理。以下是一個簡單的示例，展示了如何使用Stream和byte數(shù)組來讀取和寫入數(shù)據(jù)，同時處理粘包問題：

class Program
{static void Main(string[] args){var directory = Directory.GetCurrentDirectory();var program = File.Open("Program.cs", FileMode.OpenOrCreate);var buffers = new byte[1024]; // 創(chuàng)建一個8k的緩存區(qū)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，提供了一種簡化的方法來處理流數(shù)據(jù)。這些適配器封裝了流操作，使得讀寫操作更加方便。例如，StreamReader可以按行讀取文本，而StreamWriter可以寫入文本并自動處理換行。

自定義流式單線程適配器

在更復(fù)雜的應(yīng)用中，可能需要自定義流式單線程適配器來處理特定的協(xié)議或數(shù)據(jù)格式。這通常涉及到解析數(shù)據(jù)頭和數(shù)據(jù)體，以及處理數(shù)據(jù)的順序和完整性。以下是一個自定義適配器的示例，它展示了如何讀取和解析數(shù)據(jù)：

var pos = byteBlock.Position; // 記錄初始游標(biāo)位置，防止本次無法解析時，回退游標(biāo)。
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數(shù)據(jù)不足。byteBlock.Position = pos; // 回退游標(biāo)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; // 賦值refreturn FilterResult.Success; // 返回成功
}