set websocket send buffer to 4096

Author: LucHeart

Common/Utils/JsonWebSocketUtils.cs

@@ -1,4 +1,5 @@
 using System.Buffers;
+using System.IO.Pipelines;
 using System.Net.WebSockets;
 using System.Text.Json;
 using Microsoft.IO;
@@ -53,16 +54,16 @@ await socket.CloseAsync(WebSocketCloseStatus.NormalClosure, "Closure during mess
         }
     }
 
-    public static Task SendFullMessage<T>(T obj, WebSocket socket, CancellationToken cancelToken, int maxChunkSize = 256) =>
-        SendFullMessageBytes(JsonSerializer.SerializeToUtf8Bytes(obj), socket, cancelToken);
+    public static Task SendFullMessage<T>(T obj, WebSocket socket, CancellationToken cancelToken, int bufferSize = 4096) =>
+        SendFullMessageBytes(JsonSerializer.SerializeToUtf8Bytes(obj), socket, cancelToken, bufferSize);
 
-    public static async Task SendFullMessageBytes(byte[] msg, WebSocket socket, CancellationToken cancelToken, int maxChunkSize = 256)
+    public static async Task SendFullMessageBytes(byte[] msg, WebSocket socket, CancellationToken cancelToken, int bufferSize)
     {
         var doneBytes = 0;
 
         while (doneBytes < msg.Length)
         {
-            var bytesProcessing = Math.Min(maxChunkSize, msg.Length - doneBytes);
+            var bytesProcessing = Math.Min(bufferSize, msg.Length - doneBytes);
             var buffer = msg.AsMemory(doneBytes, bytesProcessing);
 
             doneBytes += bytesProcessing;

Common/Websocket/WebsockBaseController.cs

@@ -22,8 +22,6 @@ public abstract class WebsocketBaseController<T> : OpenShockControllerBase, IAsy
     /// <inheritdoc />
     public abstract Guid Id { get; }
 
-    public virtual int MaxChunkSize => 256;
-
     /// <summary>
     /// Logger
     /// </summary>
@@ -182,7 +180,7 @@ private async Task MessageLoop()
     /// <returns></returns>
     [NonAction]
     protected virtual Task SendWebSocketMessage(T message, WebSocket websocket, CancellationToken cancellationToken) =>
-        JsonWebSocketUtils.SendFullMessage(message, websocket, cancellationToken, MaxChunkSize);
+        JsonWebSocketUtils.SendFullMessage(message, websocket, cancellationToken);
 
 
     #endregion