新增(Program): 增加管道配置及优化内存管理

新增对 System.Buffers 和 System.IO.Pipelines 的引用，优化内存分配和数据流处理。在 TouchSocketConfig 中新增 ReceivePipeOptions 和 SendPipeOptions 配置，支持自定义管道选项。将部分变量声明改为显式类型以提升代码可读性。新增对 System.Text.Json.Serialization 和 TouchSocket.Rpc 的引用，为后续功能扩展做准备。容器配置中新增 AddRpcStore 调用，支持 RPC 功能。

Author: RRQM

frameworks/CSharp/touchsocket/src/TouchSocketHttp/Program.cs

@@ -1,3 +1,5 @@
+using System.Buffers;
+using System.IO.Pipelines;
 using System.Text;
 using TouchSocket.Core;
 using TouchSocket.Http;
@@ -10,14 +12,32 @@ public class Program
     private static async Task Main(string[] args)
     {
         int port = 8080;
-        var service = new MyHttpService();
+        MyHttpService service = new MyHttpService();
 
         await service.SetupAsync(new TouchSocketConfig()
              .SetListenIPHosts(port)
              .SetMaxCount(1000000)
               .SetTransportOption(options =>
               {
                   options.BufferOnDemand = false;
+
+                  options.ReceivePipeOptions = new PipeOptions(
+                pool: MemoryPool<byte>.Shared,
+                readerScheduler: PipeScheduler.ThreadPool,
+                writerScheduler: PipeScheduler.ThreadPool,
+                pauseWriterThreshold: 1024 * 1024,
+                resumeWriterThreshold: 1024 * 512,
+                minimumSegmentSize: -1,
+                useSynchronizationContext: false);
+
+                  options.SendPipeOptions = new PipeOptions(
+                pool: MemoryPool<byte>.Shared,
+                readerScheduler: PipeScheduler.ThreadPool,
+                writerScheduler: PipeScheduler.ThreadPool,
+                pauseWriterThreshold: 64 * 1024,
+                resumeWriterThreshold: 32 * 1024,
+                minimumSegmentSize: -1,
+                useSynchronizationContext: false);
               })
              .ConfigureContainer(a =>
              {
@@ -48,8 +68,8 @@ internal sealed class MyHttpSessionClient : HttpSessionClient
 
     protected override async Task OnReceivedHttpRequest(HttpContext httpContext)
     {
-        var request = httpContext.Request;
-        var response = httpContext.Response;
+        HttpRequest request = httpContext.Request;
+        HttpResponse response = httpContext.Response;
 
         switch (request.RelativeURL)
         {

frameworks/CSharp/touchsocket/src/TouchSocketWebApi/Program.cs

@@ -1,3 +1,5 @@
+using System.Buffers;
+using System.IO.Pipelines;
 using System.Text;
 using System.Text.Json.Serialization;
 using TouchSocket.Core;
@@ -21,6 +23,24 @@ public static void Main(string[] args)
             .SetTransportOption(options =>
             {
                 options.BufferOnDemand = false;
+
+                options.ReceivePipeOptions = new PipeOptions(
+                pool: MemoryPool<byte>.Shared,
+                readerScheduler: PipeScheduler.ThreadPool,
+                writerScheduler: PipeScheduler.ThreadPool,
+                pauseWriterThreshold: 1024 * 1024,
+                resumeWriterThreshold: 1024 * 512,
+                minimumSegmentSize: -1,
+                useSynchronizationContext: false);
+
+                options.SendPipeOptions = new PipeOptions(
+              pool: MemoryPool<byte>.Shared,
+              readerScheduler: PipeScheduler.ThreadPool,
+              writerScheduler: PipeScheduler.ThreadPool,
+              pauseWriterThreshold: 64 * 1024,
+              resumeWriterThreshold: 32 * 1024,
+              minimumSegmentSize: -1,
+              useSynchronizationContext: false);
             })
            .ConfigureContainer(a =>
            {