-remove

1 files changed, 0 insertions, 250 deletions

diff --git a/NetWork/AsynClient.cs b/NetWork/AsynClient.cs
deleted file mode 100644
index 20efcc7..0000000
--- a/NetWork/AsynClient.cs
+++ /dev/null
@@ -1,250 +0,0 @@
-using System;
-using System.Net;
-using System.Net.Sockets;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading;
-
-/*
-public class Messageinfo
-{
-    public MsgHeader header;     // 消息头
-    public byte[]    databuffer; // 数据本体
-} 
-     
-*/
-
-namespace Assets.Scripts.NetWork
-{
-    // 发送出去的data buffer 
-    public class SendBufferInfo
-    {
-        public UInt32 seqId;
-        public byte[] buffer;
-        public int length;
-    }
-
-    public class AsynClient
-    {
-        public const int BufferSzie = 65500;
-        private byte[] socketCacheBuffer = new byte[BufferSzie];
-
-        private int mPort;
-        private string mServerAddress;
-
-        private volatile Socket mClient = null;
-        private volatile bool isConnectionEstablished = false;
-        // thread lock 
-        private volatile object lockThis = new object();
-
-        //private vp_Timer.Handle timerHandle = new vp_Timer.Handle();
-
-        private const int SendReceiveTimeOut = 3000;
-
-        public delegate void OnCoonectCallBack();
-        public delegate void OnConnectFail(Exception e);
-        public delegate void OnDisconnectCallBack();
-        public delegate void OnSendCallBack(SendBufferInfo bufferInfo, bool isCompleted);
-        public delegate void OnReceiveCallBack(byte[] buffer, int length);
-
-        public OnCoonectCallBack connectCallBack = null;
-        public OnConnectFail connectFailCallBack = null;
-        public OnDisconnectCallBack disConnectCallBack = null;
-        public OnSendCallBack sendCallBack = null;
-        public OnReceiveCallBack receiveCallBack = null;
-
-        // socket 
-        public void StartClient(int port, string serverAddress, int timeOutMS)
-        {
-            lock(lockThis)
-            {
-                mPort = port;
-                mServerAddress = serverAddress;
-
-                try
-                {
-                    IPAddress[] ipAddresses = Dns.GetHostAddresses(mServerAddress);
-                    if(ipAddresses.Length == 0)
-                    {
-                        return;
-                    }
-                    IPAddress ipAddress = ipAddresses[0];
-                    IPEndPoint remoteEndPoint = new IPEndPoint(ipAddress, mPort);
-
-                    mClient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
-                    mClient.BeginConnect(remoteEndPoint, new AsyncCallback(ConnectCallback), null);
-
-                    // 
-                }
-                catch(Exception e)
-                {
-                    CloseClient();
-                }
-            }
-        }
-
-        private void CloseClient()
-        {
-            try
-            {
-                if(!isConnectionEstablished)
-                {
-
-                    mClient.Close();
-                    mClient = null;
-                    if (disConnectCallBack != null)
-                        disConnectCallBack();
-                    return;
-                }
-                isConnectionEstablished = false;
-                if (mClient != null)
-                    mClient.Shutdown(SocketShutdown.Both);
-                if(mClient != null)
-                {
-                    mClient.Close();
-                    mClient = null;
-                }
-                if (disConnectCallBack != null)
-                    disConnectCallBack();
-            }
-            catch(Exception e)
-            {
-                if (disConnectCallBack != null)
-                    disConnectCallBack();
-            }
-        }
-
-        // 用来设置连接超时
-        private void timer_connection_tick()
-        {
-            //lock (lockThis)
-            //{
-            //    if(null == mClient || !mClient.Connected)
-            //    {
-            //        timerHandler.Cancel();
-            //        if (null != mCLient)
-            //            CloseClient();
-            //    }
-            //}
-        }
-
-        private void ConnectCallback(IAsyncResult ar)
-        {
-            lock (lockThis)
-            {
-                try
-                {
-                    if(null != mClient && null != ar)
-                    {
-                        mClient.EndConnect(ar);
-                        mClient.ReceiveTimeout = SendReceiveTimeOut;
-                        mClient.SendTimeout = SendReceiveTimeOut;
-
-                        isConnectionEstablished = true;
-
-                        if (connectCallBack != null)
-                            connectCallBack();
-
-                        // 接收线程
-                        Thread receiveThread = new Thread(new ThreadStart(AsyncRecive));
-                        receiveThread.Start();
-                    }
-                    else
-                    {
-                    }
-                }
-                catch(Exception e)
-                {
-                    if (connectFailCallBack != null)
-                        connectFailCallBack(e);
-                    CloseClient();
-                }
-            }
-        }
-
-        private void AsyncRecive()
-        {
-            try
-            {
-                while (true)
-                {
-                    lock (lockThis)
-                    {
-                        if (!isConnectionEstablished)
-                            break;
-                        if (null == mClient || !mClient.Connected)
-                            break;
-                        if (mClient.Available > 0)
-                        {
-                            int bytesRead = mClient.Receive(socketCacheBuffer, 0, socketCacheBuffer.Length, SocketFlags.None);
-                            if (bytesRead > 0)
-                            {
-                                if (receiveCallBack != null)
-                                {
-                                    receiveCallBack(socketCacheBuffer, bytesRead);
-                                }
-                                else
-                                {
-                                }
-                            }
-                            else
-                            {
-                                // 服务器主动断线
-                                CloseClient();
-                                break;
-                            }
-                        }
-                    }
-                    Thread.Sleep(10);
-                }
-            }
-            catch(Exception e)
-            {
-
-            }
-        }
-
-        public void Send(SendBufferInfo sendBuffer)
-        {
-            lock (lockThis)
-            {
-                if(sendBuffer.length <= 0 || sendBuffer.length > sendBuffer.buffer.Length)
-                {
-                    sendCallBack(sendBuffer, true);
-                    return;
-                }
-
-                try
-                {
-                    if(!isConnectionEstablished)
-                    {
-                        sendCallBack(sendBuffer, false);
-                        return;
-                    }
-
-                    //NetWorkData.totalSendBytes += sendBuffer.length; // 统计发送的字节
-                    mClient.Send(sendBuffer.buffer, 0, sendBuffer.length, SocketFlags.None);
-                    sendCallBack(sendBuffer, true);
-
-                }
-                catch(Exception e)
-                {
-                    sendCallBack(sendBuffer, false);
-                    CloseClient();
-                }
-            }
-        }
-
-        public void CloseNetWorkConnect()
-        {
-            lock (lockThis)
-            {
-                CloseClient();
-            }
-        }
-
-
-    }
-}
-