From 949f5accd281a051e5e2eeb3df8767b4794b6a1e Mon Sep 17 00:00:00 2001 From: chai <215380520@qq.com> Date: Sat, 14 Oct 2023 12:06:40 +0800 Subject: + Message --- Tools/Hazel-Networking/Hazel/MessageReader.cs | 19 ++++++++----------- Tools/Hazel-Networking/Hazel/MessageWriter.cs | 24 +++++++++++++++--------- 2 files changed, 23 insertions(+), 20 deletions(-) (limited to 'Tools/Hazel-Networking') diff --git a/Tools/Hazel-Networking/Hazel/MessageReader.cs b/Tools/Hazel-Networking/Hazel/MessageReader.cs index b6e35de..ab088df 100644 --- a/Tools/Hazel-Networking/Hazel/MessageReader.cs +++ b/Tools/Hazel-Networking/Hazel/MessageReader.cs @@ -88,11 +88,7 @@ namespace Hazel return output; } - /// - /// 完全复制 一份 - /// - /// - /// + // 没用 public static MessageReader Get(MessageReader source) { var output = MessageReader.GetSized(source.Buffer.Length); @@ -181,12 +177,13 @@ namespace Hazel return output; } - public MessageWriter StartWriter() - { - var output = new MessageWriter(this.Buffer); - output.Position = this.readHead; - return output; - } + // 没用,注释掉了 + //public MessageWriter StartWriter() + //{ + // var output = new MessageWriter(this.Buffer); + // output.Position = this.readHead; + // return output; + //} public MessageReader Duplicate() { diff --git a/Tools/Hazel-Networking/Hazel/MessageWriter.cs b/Tools/Hazel-Networking/Hazel/MessageWriter.cs index 68280cd..a156c77 100644 --- a/Tools/Hazel-Networking/Hazel/MessageWriter.cs +++ b/Tools/Hazel-Networking/Hazel/MessageWriter.cs @@ -24,18 +24,19 @@ namespace Hazel public static readonly ObjectPool WriterPool = new ObjectPool(() => new MessageWriter(BufferSize)); public byte[] Buffer; // 缓冲区,保存了整个包体,包括头部和内容 - public int Length; // 有效数据在buffer中的长度,可能包含多个嵌套子协议。Length>=Position + public int Length; // 有效数据在buffer中的长度,包含header,可能包含多个嵌套子协议。Length>=Position public int Position; // 写入游标 public SendOption SendOption { get; private set; } private Stack messageStarts = new Stack(); - public MessageWriter(byte[] buffer) - { - this.Buffer = buffer; - this.Length = this.Buffer.Length; - } + // 没用,注释掉了 + //public MessageWriter(byte[] buffer) + //{ + // this.Buffer = buffer; + // this.Length = this.Buffer.Length; + //} /// public MessageWriter(int bufferSize) @@ -98,10 +99,10 @@ namespace Hazel { if (this.SendOption == SendOption.None) { - return this.Length > 1 + expected; + return this.Length > 1 + expected; // header=1 byte } - return this.Length > 3 + expected; + return this.Length > 3 + expected; // header=3 bytes } /// @@ -109,9 +110,10 @@ namespace Hazel { var messageStart = this.Position; messageStarts.Push(messageStart); - this.Buffer[messageStart] = 0; // + this.Buffer[messageStart] = 0; // length this.Buffer[messageStart + 1] = 0; this.Position += 2; + //this.Length = this.Position; this.Write(typeFlag); } @@ -131,6 +133,10 @@ namespace Hazel this.Length = this.Position; } + /// + /// 重置为sendOption类型的空包 + /// + /// public void Clear(SendOption sendOption) { Array.Clear(this.Buffer, 0, this.Buffer.Length);//完全清空整个缓冲区 -- cgit v1.1-26-g67d0