[修改]1. 修改网络消息解码编码的实现方式

Author: AlianBlank

GameFrameX.NetWork.Message/BaseMessageDecoderHandler.cs

@@ -1,13 +1,12 @@
 using System.Buffers;
 using GameFrameX.NetWork.Abstractions;
-using GameFrameX.SuperSocket.ProtoBase;
 
 namespace GameFrameX.NetWork.Message;
 
 /// <summary>
 /// 基础消息解码处理器
 /// </summary>
-public abstract class BaseMessageDecoderHandler : IMessageDecoderHandler, IPackageDecoder<IMessage>
+public abstract class BaseMessageDecoderHandler : IMessageDecoderHandler
 {
     /// <summary>
     /// 解压消息处理器
@@ -45,15 +44,4 @@ public void SetDecompressionHandler(IMessageDecompressHandler decompressHandler
     {
         DecompressHandler = decompressHandler;
     }
-
-    /// <summary>
-    /// 解码
-    /// </summary>
-    /// <param name="buffer"></param>
-    /// <param name="context"></param>
-    /// <returns></returns>
-    public IMessage Decode(ref ReadOnlySequence<byte> buffer, object context)
-    {
-        return Handler(ref buffer);
-    }
 }

GameFrameX.NetWork.Message/BaseMessageEncoderHandler.cs

@@ -9,7 +9,7 @@ namespace GameFrameX.NetWork.Message;
 /// <summary>
 /// 基础消息编码处理器
 /// </summary>
-public abstract class BaseMessageEncoderHandler : IMessageEncoderHandler, IPackageEncoder<IMessage>
+public abstract class BaseMessageEncoderHandler : IMessageEncoderHandler
 {
     /// <summary>
     /// 压缩消息处理器
@@ -19,7 +19,7 @@ public abstract class BaseMessageEncoderHandler : IMessageEncoderHandler, IPacka
     /// <summary>
     /// 超过多少字节长度才启用压缩,默认512
     /// </summary>
-    public virtual uint LimitCompressLength { get; } = 512;
+    public virtual uint LimitCompressLength { get; } = 3;
 
     /// <summary>
     /// totalLength + headerLength
@@ -60,19 +60,6 @@ public void SetCompressionHandler(IMessageCompressHandler compressHandler = null
         CompressHandler = compressHandler;
     }
 
-
-    /// <summary>
-    /// </summary>
-    /// <param name="writer"></param>
-    /// <param name="pack"></param>
-    /// <returns></returns>
-    public int Encode(IBufferWriter<byte> writer, IMessage pack)
-    {
-        var bytes = Handler(pack);
-        writer.Write(bytes);
-        return bytes.Length;
-    }
-
     /// <summary>
     /// 内部消息结构写入
     /// 结构为 totalLength(uint) + headerLength(ushort) + header 数组 + body 数组

GameFrameX.NetWork.Message/MessageObjectPipelineFilter.cs

@@ -35,6 +35,6 @@ public override IMessage Filter(ref SequenceReader<byte> reader)
             reader.Advance(totalLength);
         }
 
-        return Decoder.Decode(ref readBuffer, Context);
+        return MessageHelper.MessageDecoderHandler.Handler(ref readBuffer);
     }
 }