private TcpListener _listener;
#region 初始化 listener

 public override void Init()

        {

            try

            {

                DevInfo.Read();

               var localaddr = IPAddress.Parse(Ip);

                var port = Convert.ToInt32(port);

                _listener = new TcpListener(localaddr, port);

            }

            finally

            {

                StatusChangedEvent?.Invoke(Status);

            }

        }

#endregion

        public override void Start()

        {

            Init();

            _listener?.Start();

            Task.Factory.StartNew(MonitTcpClientConnect);

        }

        private void MonitTcpClientConnect()

        {

            while (true)

            {

                try

                {

                    var client = _listener.AcceptTcpClient();

                    Task.Factory.StartNew(MonitorRecvData, client);

                }

                catch

                {

                    _listener.Stop();

                    _listener = null;                return;

                }

            }

        }

        private void MonitorRecvData(object obj)

        {

            try

            {

                var tcpClient = obj as TcpClient;

                if (tcpClient == null)

                {

                    return;

                }

                var buffer = new byte[];var stream = tcpClient.GetStream();

                while (true)

                {

                    var count = stream.Read(buffer, , buffer.Length);

                    if (count == )

                    {

                        throw new Exception("客户端下线");

                    }

                    var str = Encoding.ASCII.GetString(buffer, , count);

                }

            }

            catch

            {

                // ignored

            }

        }