From 31672e7d29b55f519feebfa8296dbb916a17273e Mon Sep 17 00:00:00 2001 From: tanghai Date: Wed, 8 Aug 2018 16:43:16 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8E=BB=E6=8E=89channel=E4=B8=80=E4=B8=AA?= =?UTF-8?q?=E5=A4=9A=E4=BD=99=E7=9A=84send=E6=96=B9=E6=B3=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../Scripts/Module/Message/Network/AChannel.cs | 8 +------- .../Module/Message/Network/KCP/KChannel.cs | 2 +- .../Module/Message/Network/TCP/TChannel.cs | 17 ----------------- 3 files changed, 2 insertions(+), 25 deletions(-) diff --git a/Unity/Assets/Scripts/Module/Message/Network/AChannel.cs b/Unity/Assets/Scripts/Module/Message/Network/AChannel.cs index 13f3ed2d..52f495e2 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 f66b8753..63074993 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 cf24deb3..efe5b1b2 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) { -- GitLab