diff --git a/Unity/Assets/Scripts/Module/Message/Network/AChannel.cs b/Unity/Assets/Scripts/Module/Message/Network/AChannel.cs index 13f3ed2d3c2c72162b87af841caf64a7ed2bf504..52f495e254d7f1d0bc8360aefca46560a6cce65d 100644 --- a/Unity/Assets/Scripts/Module/Message/Network/AChannel.cs +++ b/Unity/Assets/Scripts/Module/Message/Network/AChannel.cs @@ -1,5 +1,4 @@ using System; -using System.Collections.Generic; using System.IO; using System.Net; @@ -70,12 +69,7 @@ namespace ETModel } public abstract void Start(); - - /// - /// 发送消息 - /// - public abstract void Send(byte[] buffer, int index, int length); - + public abstract void Send(MemoryStream stream); public override void Dispose() diff --git a/Unity/Assets/Scripts/Module/Message/Network/KCP/KChannel.cs b/Unity/Assets/Scripts/Module/Message/Network/KCP/KChannel.cs index f66b87538f9133bdfde9ca36c8cd3b1edbfae77f..6307499399a2d9e590d19b99b5fbd8b4f31acd70 100644 --- a/Unity/Assets/Scripts/Module/Message/Network/KCP/KChannel.cs +++ b/Unity/Assets/Scripts/Module/Message/Network/KCP/KChannel.cs @@ -390,7 +390,7 @@ namespace ETModel this.GetService().AddToUpdateNextTime(0, this.Id); } - public override void Send(byte[] buffer, int index, int length) + private void Send(byte[] buffer, int index, int length) { if (isConnected) { diff --git a/Unity/Assets/Scripts/Module/Message/Network/TCP/TChannel.cs b/Unity/Assets/Scripts/Module/Message/Network/TCP/TChannel.cs index cf24deb30e188f47ba995e8b351466bfbcd0666f..efe5b1b28bcd5127688b0bba78fc504c33c194c2 100644 --- a/Unity/Assets/Scripts/Module/Message/Network/TCP/TChannel.cs +++ b/Unity/Assets/Scripts/Module/Message/Network/TCP/TChannel.cs @@ -95,23 +95,6 @@ namespace ETModel this.StartRecv(); this.StartSend(); } - - public override void Send(byte[] buffer, int index, int length) - { - if (this.IsDisposed) - { - throw new Exception("TChannel已经被Dispose, 不能发送消息"); - } - - cache.WriteTo(0, (ushort)length); - this.sendBuffer.Write(this.cache, 0, this.cache.Length); - this.sendBuffer.Write(buffer, index, length); - - if(!this.isSending) - { - this.StartSend(); - } - } public override void Send(MemoryStream stream) {