[增加]1. 增加正在连接的处理

Author: AlianBlank

Runtime/Network/Network/NetworkManager.NetworkChannelBase.cs

@@ -53,9 +53,9 @@ public abstract class NetworkChannelBase : INetworkChannel, IDisposable
             protected readonly RpcState PRpcState;
             protected int PSentPacketCount;
             protected int PReceivedPacketCount;
+            protected bool PIsConnecting = false;
             private bool m_Disposed;
             private bool m_PActive;
-
             protected bool PActive
             {
                 get { return m_PActive; }
@@ -107,6 +107,7 @@ public NetworkChannelBase(string name, INetworkChannelHelper networkChannelHelpe
                 PSentPacketCount = 0;
                 PReceivedPacketCount = 0;
                 PActive = false;
+                PIsConnecting = false;
                 m_Disposed = false;
 
                 NetworkChannelConnected = null;

Runtime/Network/Network/SystemSocket/NetworkManager.SystemTcpNetworkChannel.cs

@@ -43,6 +43,11 @@ public SystemTcpNetworkChannel(string name, INetworkChannelHelper networkChannel
             /// <param name="isSsl">是否是加密</param>
             public override void Connect(IPAddress ipAddress, int port, object userData = null, bool isSsl = false)
             {
+                if (PIsConnecting)
+                {
+                    return;
+                }
+
                 m_ConnectedEndPoint = new IPEndPoint(ipAddress, port);
                 base.Connect(ipAddress, port, userData, isSsl);
                 PSystemNetSocket = new SystemNetSocket(ipAddress.AddressFamily, SocketType.Stream, ProtocolType.Tcp);
@@ -317,6 +322,7 @@ private void ConnectAsync(object userData)
             {
                 try
                 {
+                    PIsConnecting = true;
                     m_ConnectState = new ConnectState(PSystemNetSocket, userData);
                     ((SystemNetSocket)PSocket).BeginConnect(m_ConnectedEndPoint.Address, m_ConnectedEndPoint.Port, ConnectCallback, m_ConnectState);
                 }
@@ -335,6 +341,7 @@ private void ConnectAsync(object userData)
 
             private void ConnectCallback(IAsyncResult asyncResult)
             {
+                PIsConnecting = false;
                 var connectState = (ConnectState)asyncResult.AsyncState;
                 var systemNetSocket = (SystemNetSocket)connectState.Socket;
                 try

Runtime/Network/Network/WebSocket/NetworkManager.WebSocketNetworkChannel.cs

@@ -44,6 +44,11 @@ public WebSocketNetworkChannel(string name, INetworkChannelHelper networkChannel
             /// <param name="isSsl">是否是加密</param>
             public override void Connect(IPAddress ipAddress, int port, object userData = null, bool isSsl = false)
             {
+                if (PIsConnecting)
+                {
+                    return;
+                }
+
                 base.Connect(ipAddress, port, userData, isSsl);
                 PSocket = new WebSocketNetSocket(ipAddress, port, isSsl, ReceiveCallback, CloseCallback);
                 if (PSocket == null)
@@ -172,6 +177,7 @@ private async void ConnectAsync(object userData)
             {
                 try
                 {
+                    PIsConnecting = true;
                     var socketClient = (WebSocketNetSocket)PSocket;
                     await socketClient.ConnectAsync();
                     ConnectCallback(new ConnectState(PSocket, userData));
@@ -192,6 +198,7 @@ private async void ConnectAsync(object userData)
 
             private void ConnectCallback(ConnectState connectState)
             {
+                PIsConnecting = false;
                 try
                 {
                     var socketUserData = (WebSocketNetSocket)PSocket;