骑行代码迁移，赛事逻辑初步框架完成

Assets/Scripts/Scenes/Ride/Scripts/Network/TcpService1.cs

@@ -0,0 +1,123 @@
+using Assets.Scenes.Ride.Scripts.Model;
+using Assets.Scripts;
+using System;
+using System.Collections.Generic;
+using System.Diagnostics;
+using System.Linq;
+using System.Net;
+using System.Net.Sockets;
+using System.Text;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace Assets.Scenes.Ride.Scripts.Network
+{
+    public class TcpService1 : IService
+    {
+        private bool isExit = false;
+        private PfTcpClient _tcpClient;
+        private IPEndPoint iPEndPoint;
+        //private Action<List<ReceiveMsgModel>> _action;
+
+        public void Start(Action<List<ReceiveMsgModel>> action)
+        {
+            if (_tcpClient == null)
+            {
+                //if (!IPAddress.TryParse(ConfigHelper.ServerIpAdress, out var ipString))
+                //{
+                //    throw new ArgumentException("IP地址不正确");
+                //}                    
+
+                //服务端端口
+                iPEndPoint = App.TcpAddress;
+                _tcpClient = new PfTcpClient(iPEndPoint.Address.ToString(), iPEndPoint.Port, action);
+                _tcpClient.OptionNoDelay = true;
+                //_action = action;
+
+                _tcpClient.ConnectAsync();
+            }
+        }
+
+        public void Send(byte[] dgram, int bytes)
+        {
+            if (_tcpClient == null) return;
+            if (_tcpClient.IsConnected == false) return;
+            //_tcpClient.WriteLine(System.Text.Encoding.ASCII.GetString(dgram));
+            var txt = System.Text.Encoding.ASCII.GetString(dgram);
+            //Debug.WriteLine("发送："+txt);
+            _tcpClient.Send(txt);
+        }
+
+        public void Close()
+        {
+            isExit = true;
+            _tcpClient.DisconnectAndStop();
+
+            _tcpClient = null;
+        }
+
+
+        class PfTcpClient : NetCoreServer.TcpClient
+        {
+            private bool _stop;
+            Action<List<ReceiveMsgModel>> _action;
+            public PfTcpClient(string address, int port, Action<List<ReceiveMsgModel>> action) : base(address, port)
+            {
+                _action = action;
+            }
+
+            public void DisconnectAndStop()
+            {
+                _stop = true;
+                DisconnectAsync();
+                while (IsConnected)
+                {
+                    Thread.Yield();
+                }
+            }
+
+            protected override void OnConnected()
+            {
+                base.OnConnected();
+            }
+
+            protected override void OnDisconnected()
+            {
+                //base.OnDisconnected();
+                Debug.WriteLine("tcp断线，3秒后重连");
+                Thread.Sleep(3000);
+
+                if (!_stop)
+                {
+                    ConnectAsync();
+                }
+            }
+
+            protected override void OnReceived(byte[] buffer, long offset, long size)
+            {
+                //base.OnReceived(buffer, offset, size);
+                var returnData = Encoding.UTF8.GetString(buffer, (int)offset, (int)size);
+                //Debug.WriteLine("收到：" + returnData+"\r\n");
+                //System.IO.File.AppendAllText(System.Environment.CurrentDirectory + "接收到的数据.txt", returnData.Trim().Replace("\0", "")+"\r\n", Encoding.UTF8);
+                var list = new List<ReceiveMsgModel>();
+                var itemList = returnData.Split('|');
+
+                foreach (var item in itemList)
+                {
+                    var info = ReceiveMsgModel.Parse(item);
+                    if (info != null)
+                    {
+                        list.Add(info);
+                    }
+                }
+                _action(list);
+            }
+
+            protected override void OnError(SocketError error)
+            {
+                //base.OnError(error);
+                Debug.WriteLine(error);
+            }
+        }
+    }
+}